Logo
ApraPipes 1.0
Loading...
Searching...
No Matches
QuePushStrategy Class Reference

#include <QuePushStrategy.h>

Inheritance diagram for QuePushStrategy:
Inheritance graph
Collaboration diagram for QuePushStrategy:
Collaboration graph

Public Types

enum  QuePushStrategyType { BLOCKING , NON_BLOCKING_ANY , NON_BLOCKING_ALL_OR_NONE }
 

Public Member Functions

 QuePushStrategy (std::string &srcModuleId)
 
virtual ~QuePushStrategy ()
 
void addQue (std::string dstModuleId, boost::shared_ptr< FrameContainerQueue > &que)
 
virtual void push (std::string dstModuleId, frame_container &frames)
 
virtual bool flush ()
 

Static Public Member Functions

static boost::shared_ptr< QuePushStrategygetStrategy (QuePushStrategyType type, std::string &srcModuleId)
 

Protected Attributes

std::map< std::string, boost::shared_ptr< FrameContainerQueue > > mQueByModule
 
std::string mId
 

Member Enumeration Documentation

◆ QuePushStrategyType

Enumerator
BLOCKING 
NON_BLOCKING_ANY 
NON_BLOCKING_ALL_OR_NONE 

Constructor & Destructor Documentation

◆ QuePushStrategy()

QuePushStrategy::QuePushStrategy ( std::string & srcModuleId)
Here is the caller graph for this function:

◆ ~QuePushStrategy()

QuePushStrategy::~QuePushStrategy ( )
virtual

Member Function Documentation

◆ addQue()

void QuePushStrategy::addQue ( std::string dstModuleId,
boost::shared_ptr< FrameContainerQueue > & que )

◆ flush()

virtual bool QuePushStrategy::flush ( )
inlinevirtual

◆ getStrategy()

boost::shared_ptr< QuePushStrategy > QuePushStrategy::getStrategy ( QuePushStrategyType type,
std::string & srcModuleId )
static
Here is the call graph for this function:
Here is the caller graph for this function:

◆ push()

void QuePushStrategy::push ( std::string dstModuleId,
frame_container & frames )
virtual

Member Data Documentation

◆ mId

std::string QuePushStrategy::mId
protected

◆ mQueByModule

std::map<std::string, boost::shared_ptr<FrameContainerQueue> > QuePushStrategy::mQueByModule
protected

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