X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Examples%2FRateStuffer%2Fratestuffer.cc;h=631210e84bd637c0f005e73d888da901b9a5cf6e;hb=a479735a65e334af538b895f182f8efd36a541c5;hp=8d3456e551bf6bec001c82fd71f8f3262948f88f;hpb=fa368bbbcb79a9aad8daf7cb25a9adee8270d1b8;p=senf.git

diff --git a/Examples/RateStuffer/ratestuffer.cc b/Examples/RateStuffer/ratestuffer.cc
index 8d3456e..631210e 100644
--- a/Examples/RateStuffer/ratestuffer.cc
+++ b/Examples/RateStuffer/ratestuffer.cc
@@ -117,8 +117,8 @@ public:
 //                   +----------------------------------------------------+
 //                   | stuffer                                            |
 //                   |                                                    |
-// [ udpReader ] O-->:---> [ queue ] -->O [      ]                        |
-//                   |                    [ join ] -->O [ rateFilter] O-->:O--> [ udpWriter ]
+// [ udpSource ] O-->:---> [ queue ] -->O [      ]                        |
+//                   |                    [ join ] -->O [ rateFilter] O-->:O--> [ udpSink ]
 //                   | [ generator ] -->O [      ]                        |
 //                   |                                                    |
 //                   +----------------------------------------------------+
@@ -131,14 +131,14 @@ int main(int argc, char * argv[])
     senf::ConnectedUDPv4ClientSocketHandle outputSocket(
         senf::INet4SocketAddress("localhost:44345"));
 
-    module::ActiveSocketReader<>  udpReader  ( inputSocket );
+    module::ActiveSocketSource<>  udpSource  ( inputSocket );
     RateStuffer                   stuffer    ( 1000000000ul, 
                                                senf::DataPacket::create(std::string("<idle>\n")),
                                                2u, 1u );
-    module::PassiveSocketWriter<> udpWriter  ( outputSocket );
+    module::PassiveSocketSink<> udpSink  ( outputSocket );
 
-    ppi::connect( udpReader, stuffer   );
-    ppi::connect( stuffer,   udpWriter );
+    ppi::connect( udpSource, stuffer   );
+    ppi::connect( stuffer,   udpSink );
 
     ppi::run();