// $Id$
//
// Copyright (C) 2007
-// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS)
-// Kompetenzzentrum fuer Satelitenkommunikation (SatCom)
+// Fraunhofer Institute for Open Communication Systems (FOKUS)
+// Competence Center NETwork research (NET), St. Augustin, GERMANY
// Stefan Bund <g0dil@berlios.de>
//
// This program is free software; you can redistribute it and/or modify
SENF_PPI_MODULE(RateFilter);
public:
- connector::ActiveInput input;
- connector::ActiveOutput output;
+ connector::ActiveInput<> input;
+ connector::ActiveOutput<> output;
RateFilter(senf::ClockService::clock_type interval);
{
route(input,timer);
route(timer,output);
- registerEvent(&RateFilter::timeout, timer);
+ registerEvent(timer, &RateFilter::timeout);
}
void RateFilter::timeout()
RateFilter rateFilter;
public:
- connector::PassiveInput & input;
- connector::ActiveOutput & output;
+ connector::PassiveInput<> & input;
+ connector::ActiveOutput<> & output;
RateStuffer(senf::ClockService::clock_type interval,
senf::Packet packet,
// +----------------------------------------------------+
// | stuffer |
// | |
-// [ udpReader ] O-->:---> [ queue ] -->O [ ] |
-// | [ join ] -->O [ rateFilter] O-->:O--> [ udpWriter ]
+// [ udpSource ] O-->:---> [ queue ] -->O [ ] |
+// | [ join ] -->O [ rateFilter] O-->:O--> [ udpSink ]
// | [ generator ] -->O [ ] |
// | |
// +----------------------------------------------------+
senf::ConnectedUDPv4ClientSocketHandle outputSocket(
senf::INet4SocketAddress("localhost:44345"));
- module::ActiveSocketReader<> udpReader ( inputSocket );
- RateStuffer stuffer ( 1000000000ul,
- senf::DataPacket::create(std::string("<idle>\n")),
- 2u, 1u );
- module::PassiveSocketWriter<> udpWriter ( outputSocket );
+ module::ActiveSocketSource<> udpSource ( inputSocket );
+ RateStuffer stuffer ( 1000000000ul,
+ senf::DataPacket::create(std::string("<idle>\n")),
+ 2u, 1u );
+ module::PassiveSocketSink<> udpSink ( outputSocket );
- ppi::connect( udpReader, stuffer );
- ppi::connect( stuffer, udpWriter );
+ ppi::connect( udpSource, stuffer );
+ ppi::connect( stuffer, udpSink );
ppi::run();