![]() |
ApraPipes 1.0
|
#include <QuePushStrategy.h>
Public Member Functions | |
NonBlockingAllOrNonePushStrategy (std::string &srcModuleId) | |
virtual | ~NonBlockingAllOrNonePushStrategy () |
virtual void | push (std::string dstModuleId, frame_container &frames) |
virtual bool | flush () |
![]() | |
QuePushStrategy (std::string &srcModuleId) | |
virtual | ~QuePushStrategy () |
void | addQue (std::string dstModuleId, boost::shared_ptr< FrameContainerQueue > &que) |
Private Types | |
typedef std::map< std::string, frame_container > | frames_by_module |
Private Attributes | |
frames_by_module | mFramesByModule |
Additional Inherited Members | |
![]() | |
enum | QuePushStrategyType { BLOCKING , NON_BLOCKING_ANY , NON_BLOCKING_ALL_OR_NONE } |
![]() | |
static boost::shared_ptr< QuePushStrategy > | getStrategy (QuePushStrategyType type, std::string &srcModuleId) |
![]() | |
std::map< std::string, boost::shared_ptr< FrameContainerQueue > > | mQueByModule |
std::string | mId |
|
private |
NonBlockingAllOrNonePushStrategy::NonBlockingAllOrNonePushStrategy | ( | std::string & | srcModuleId | ) |
|
virtual |
|
virtual |
Reimplemented from QuePushStrategy.
|
virtual |
Reimplemented from QuePushStrategy.
|
private |