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