QueueingSocketSink. More...
#include <senf/PPI/QueueingSocketSink.hh>
Public Types | |
typedef Writer::Handle | Handle |
Handle type requested by writer. More... | |
typedef Writer::PacketType | PacketType |
Public Member Functions | |
PassiveQueueingSocketSink (Handle const &handle, QueueingAlgorithm::ptr qAlgorithm) | |
Writer & | writer () |
Access the Writer. More... | |
Handle & | handle () |
Access handle. More... | |
void | handle (Handle const &handle) |
Set handle. More... | |
QueueingAlgorithm & | qAlgorithm () const |
void | qAlgorithm (QueueingAlgorithm::ptr qAlgorithm) |
Public Member Functions inherited from senf::ppi::module::Module | |
virtual | ~Module () |
Public Attributes | |
connector::PassiveInput< PacketType > | input |
Input connector from which data is received. More... | |
console::ScopedDirectory | dir |
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 () |
QueueingSocketSink.
Definition at line 35 of file QueueingSocketSink.hh.
typedef Writer::Handle senf::ppi::module::PassiveQueueingSocketSink< Writer >::Handle |
Handle type requested by writer.
Definition at line 37 of file QueueingSocketSink.hh.
typedef Writer::PacketType senf::ppi::module::PassiveQueueingSocketSink< Writer >::PacketType |
Definition at line 41 of file QueueingSocketSink.hh.
|
explicit |
Handle& senf::ppi::module::PassiveQueueingSocketSink< Writer >::handle | ( | ) |
Access handle.
void senf::ppi::module::PassiveQueueingSocketSink< Writer >::handle | ( | Handle const & | handle | ) |
Set handle.
Assigning an empty or in-valid() handle will disable the module until a new valid handle is assigned.
QueueingAlgorithm& senf::ppi::module::PassiveQueueingSocketSink< Writer >::qAlgorithm | ( | ) | const |
void senf::ppi::module::PassiveQueueingSocketSink< Writer >::qAlgorithm | ( | QueueingAlgorithm::ptr | qAlgorithm | ) |
Writer& senf::ppi::module::PassiveQueueingSocketSink< Writer >::writer | ( | ) |
Access the Writer.
console::ScopedDirectory senf::ppi::module::PassiveQueueingSocketSink< Writer >::dir |
Definition at line 44 of file QueueingSocketSink.hh.
connector::PassiveInput<PacketType> senf::ppi::module::PassiveQueueingSocketSink< Writer >::input |
Input connector from which data is received.
Definition at line 43 of file QueueingSocketSink.hh.