#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.