#include <AsyncConsumerPolicies.h>
Public Types | |
typedef MessagePort< T > | IQueueType |
Public Member Functions | |
void | setInputQueue (boost::shared_ptr< IQueueType > const &mport) |
void | updateSource () |
Protected Member Functions | |
boost::shared_ptr< IQueueType > | inputQueue () |
IQueueType * | _waitForMessage (T &msg, unsigned sec, unsigned nanos) |
MessagePortQueue () | |
Private Attributes | |
boost::shared_ptr< IQueueType > | _mport |
boost::shared_ptr< IQueueType > | _newPort |
Atomic< bool > | _switch |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|