#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 |
|
|||||
|
|
|
|||||||||
|
|
|
||||||||||||||||||||
|
|
|
|||||||||
|
|
|
||||||||||
|
|
|
|||||||||
|
|
|
|||||
|
|
|
|||||
|
|
|
|||||
|
|
1.4.4