senf::ppi::module::PassiveQueueSocketSink< Connector > Class Template Reference

#include <senf/PPI/QueueSocketSourceSink.hh>

Inheritance diagram for senf::ppi::module::PassiveQueueSocketSink< Connector >:

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::DirectoryNodesysConsoleDir () const
 
void destroy ()
 

Detailed Description

template<class Connector = connector::PassiveInput<>>
class senf::ppi::module::PassiveQueueSocketSink< Connector >

Definition at line 110 of file QueueSocketSourceSink.hh.

Member Typedef Documentation

◆ Handle

◆ PacketType

template<class Connector = connector::PassiveInput<>>
typedef Packet senf::ppi::module::PassiveQueueSocketSink< Connector >::PacketType

Definition at line 113 of file QueueSocketSourceSink.hh.

Constructor & Destructor Documentation

◆ PassiveQueueSocketSink() [1/2]

template<class Connector = connector::PassiveInput<>>
senf::ppi::module::PassiveQueueSocketSink< Connector >::PassiveQueueSocketSink ( )

◆ PassiveQueueSocketSink() [2/2]

template<class Connector = connector::PassiveInput<>>
senf::ppi::module::PassiveQueueSocketSink< Connector >::PassiveQueueSocketSink ( Handle const &  handle)
explicit

Member Function Documentation

◆ dropped()

template<class Connector = connector::PassiveInput<>>
std::tuple<unsigned,unsigned,unsigned> senf::ppi::module::PassiveQueueSocketSink< Connector >::dropped ( )

◆ flush()

template<class Connector = connector::PassiveInput<>>
void senf::ppi::module::PassiveQueueSocketSink< Connector >::flush ( )

◆ handle() [1/2]

template<class Connector = connector::PassiveInput<>>
Handle senf::ppi::module::PassiveQueueSocketSink< Connector >::handle ( ) const

◆ handle() [2/2]

template<class Connector = connector::PassiveInput<>>
void senf::ppi::module::PassiveQueueSocketSink< Connector >::handle ( Handle const &  handle)

◆ send()

template<class Connector = connector::PassiveInput<>>
void senf::ppi::module::PassiveQueueSocketSink< Connector >::send ( )

◆ setREDFilterCallback()

template<class Connector = connector::PassiveInput<>>
void senf::ppi::module::PassiveQueueSocketSink< Connector >::setREDFilterCallback ( REDFilterCallback const &  cb)

Member Data Documentation

◆ input

template<class Connector = connector::PassiveInput<>>
Connector senf::ppi::module::PassiveQueueSocketSink< Connector >::input

Definition at line 121 of file QueueSocketSourceSink.hh.


The documentation for this class was generated from the following file: