#include <AsyncProducerPolicies.h>
Public Types | |
typedef DescriptionPolicy::Description | Description |
Public Member Functions | |
void | setProducerSemaphore (Semaphore sem, bool dest=false) |
bool | signalProduction (Description desc) |
Protected Member Functions | |
virtual bool | _isTimeToProduce () const |
Returns true if a product description is waiting to be gotten. | |
virtual bool | _waitForProductionTime (unsigned secs, unsigned nanos) |
virtual Description | _productDesc () |
SignaledCreation () | |
virtual | ~SignaledCreation () |
Static Protected Attributes | |
static const unsigned | DescriptionQueueLength = 32 |
Private Attributes | |
Fifo< Description > | _prodDescs |
Semaphore | _sem |
bool | _destSem |
|
|
|
|
|
|
|
Returns true if a product description is waiting to be gotten.
|
|
Gets the next pending product description, or throws Underflow if no description is available. _isTimeToProduce() or _waitForProductionTime() should return true before you call this method. |
|
Waits until a product description is available, or the specified timeout elapses. Returns true if a product description is waiting to be gotten. |
|
Sets the producer semaphore to sem, and hands responsibility flag for destruction. Destroys any old semaphores we are responsible for. |
|
Signal production of a new product with description 'desc'. Returns true if a production was scheduled, or false if unable to schedule production. |
|
|
|
|
|
|
|
|