#include <senf/PPI/QueueSocketSourceSink.hh>

Public Types | |
| typedef Packet | PacketType |
| typedef senf::ClientSocketHandle< senf::MakeSocketPolicy< senf::QueueWritePolicy, senf::DatagramFramingPolicy, senf::ConnectedCommunicationPolicy >::policy > | Handle |
Public Member Functions | |
| PassiveQueueSocketSink () | |
| PassiveQueueSocketSink (Handle const &handle) | |
| Handle | handle () const |
| void | handle (Handle const &handle) |
| std::tuple< unsigned, unsigned, unsigned > | dropped () |
| void | send () |
| void | flush () |
| void | setREDFilterCallback (REDFilterCallback const &cb) |
Public Member Functions inherited from senf::ppi::module::Module | |
| virtual | ~Module () |
Public Attributes | |
| Connector | input |
Additional Inherited Members | |
Protected Member Functions inherited from senf::ppi::module::Module | |
| Module () | |
| Route< connector::InputConnector, connector::OutputConnector > & | route (connector::InputConnector &input, connector::OutputConnector &output) |
| Define flow information. More... | |
| Route< connector::InputConnector, EventDescriptor > & | route (connector::InputConnector &input, EventDescriptor &output) |
| Define flow information. More... | |
| Route< EventDescriptor, connector::OutputConnector > & | route (EventDescriptor &input, connector::OutputConnector &output) |
| Define flow information. More... | |
| void | noroute (connector::Connector &connector) |
| Define terminal connectors. More... | |
| template<class Target > | |
| void | registerEvent (EventDescriptor &descriptor, Target target) |
| Register an external event. More... | |
| ClockService::clock_type const & | time () const |
| Time-stamp of the currently processing event. More... | |
| ClockService::clock_type const & | now () const |
| Current time of the currently processing event. More... | |
| virtual void | v_init () |
| Called after module setup. More... | |
| console::DirectoryNode & | sysConsoleDir () const |
| void | destroy () |
Definition at line 110 of file QueueSocketSourceSink.hh.
| typedef senf::ClientSocketHandle< senf::MakeSocketPolicy< senf::QueueWritePolicy, senf::DatagramFramingPolicy, senf::ConnectedCommunicationPolicy >::policy > senf::ppi::module::PassiveQueueSocketSink< Connector >::Handle |
Definition at line 119 of file QueueSocketSourceSink.hh.
| typedef Packet senf::ppi::module::PassiveQueueSocketSink< Connector >::PacketType |
Definition at line 113 of file QueueSocketSourceSink.hh.
| senf::ppi::module::PassiveQueueSocketSink< Connector >::PassiveQueueSocketSink | ( | ) |
|
explicit |
| std::tuple<unsigned,unsigned,unsigned> senf::ppi::module::PassiveQueueSocketSink< Connector >::dropped | ( | ) |
| void senf::ppi::module::PassiveQueueSocketSink< Connector >::flush | ( | ) |
| Handle senf::ppi::module::PassiveQueueSocketSink< Connector >::handle | ( | ) | const |
| void senf::ppi::module::PassiveQueueSocketSink< Connector >::handle | ( | Handle const & | handle | ) |
| void senf::ppi::module::PassiveQueueSocketSink< Connector >::send | ( | ) |
| void senf::ppi::module::PassiveQueueSocketSink< Connector >::setREDFilterCallback | ( | REDFilterCallback const & | cb | ) |
| Connector senf::ppi::module::PassiveQueueSocketSink< Connector >::input |
Definition at line 121 of file QueueSocketSourceSink.hh.