X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=PPI%2FJoins.hh;h=3f7087cc2d19acec7183ff579a42739a081d9e2c;hb=6f50bf49e282c0528f51faa0a245bbfa2b867399;hp=f7c1c3e68e2a8b0e1bc8bf91603544445490969d;hpb=416cdd1c85cdf2669785e93a71426a3206166758;p=senf.git diff --git a/PPI/Joins.hh b/PPI/Joins.hh index f7c1c3e..3f7087c 100644 --- a/PPI/Joins.hh +++ b/PPI/Joins.hh @@ -53,8 +53,8 @@ namespace module { /** \brief Join multiple packet streams with passive inputs The PassiveJoin will combine any number of packet streams. You may connect any number of - GenericActiveOutput's to the PassiveJoin instance. The combined stream is then provided on the - GenericActiveOutput \a output. + ActiveOutput<>'s to the PassiveJoin instance. The combined stream is then provided on the + ActiveOutput<> \a output. Since PassiveJoin allows any number of incoming packet streams, the input connectors are dynamically managed. A special senf::ppi::connect() overload is used to dynamically create @@ -74,12 +74,12 @@ namespace module { { SENF_PPI_MODULE(PassiveJoin); public: - connector::GenericActiveOutput output; + connector::ActiveOutput<> output; PassiveJoin(); private: - connector::GenericPassiveInput & newInput(); + connector::PassiveInput<> & newInput(); #ifndef DOXYGEN // I didn't get template friend functions to work ... @@ -93,15 +93,15 @@ namespace module { void onThrottle(); void onUnthrottle(); - typedef boost::ptr_vector Inputs; + typedef boost::ptr_vector > Inputs; Inputs inputs_; }; /** \brief Join multiple packet streams with active inputs The PriorityJoin will combine any number of packet streams. You may connect any number of - GenericPassiveInput's to the PassiveJoin instance. The combined stream is then provided on the - GenericPassiveOutput \a output. + PassiveInput<>'s to the PassiveJoin instance. The combined stream is then provided on the + PassiveOutput<> \a output. When a packet request is received on Priorityjoin's \a output, The request will be serviced from the first unthrottled input. The order, in which connectors are connected to the @@ -128,12 +128,12 @@ namespace module { { SENF_PPI_MODULE(PriorityJoin); public: - connector::GenericPassiveOutput output; + connector::PassiveOutput<> output; PriorityJoin(); private: - connector::GenericActiveInput & newInput(); + connector::ActiveInput<> & newInput(); #ifndef DOXYGEN public: @@ -146,7 +146,7 @@ namespace module { void onThrottle(); void onUnthrottle(); - typedef boost::ptr_vector Inputs; + typedef boost::ptr_vector > Inputs; Inputs inputs_; };