_alloc | ark::MemoryDeallocServer | [private] |
_deallocBuffer(void *buff, unsigned n) | ark::MemoryDeallocServer | [inline, private] |
_removeQueueAtAddress(IQueueType *q) | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
_waitForMessage(MemoryMessage &msg, unsigned sec, unsigned nanos) | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
addClient(MemoryGate< P1, P2, P3, P4, P5 > &mgate) | ark::MemoryDeallocServer | [inline] |
addInputQueue(boost::shared_ptr< IQueueType > const &mport) | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline] |
AsyncConsumer() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
beginProducers() | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
beginProducers() const | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
consume(MemoryMessage &msg, SourceQueue &q) | ark::MemoryDeallocServer | [inline] |
ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue >::consume(typename boost::add_reference< MemoryMessage >::type msg, SourceQueue &)=0 | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [pure virtual] |
consumeLoop() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
consumeLoopOnce() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
consumerDone() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline, virtual] |
consumptionWaitTime() const | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
endProducers() | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
endProducers() const | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
IQueueType typedef | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | |
isConsuming() const | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
MemoryDeallocServer() | ark::MemoryDeallocServer | [inline] |
MultiMessagePortQueue() | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |
PortList typedef | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [protected] |
removeClient(MemoryGate< P1, P2, P3, P4, P5 > &mgate) | ark::MemoryDeallocServer | [inline] |
removeInputQueue(boost::shared_ptr< IQueueType > const &mport) | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline] |
scheduleConsumption(typename boost::add_reference< MemoryMessage >::type t) | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
setConsumptionWaitTime(unsigned secs, unsigned nanos) | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline] |
SourceQueue typedef | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | |
startConsuming() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline, virtual] |
stopConsuming(bool wait=false) | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline, virtual] |
updateSource() | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline] |
whileNotConsuming() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline, virtual] |
~AsyncConsumer() | ark::AsyncConsumer< MemoryMessage, async_consumer_policies::MultiMessagePortQueue > | [inline, virtual] |
~MultiMessagePortQueue() | ark::async_consumer_policies::MultiMessagePortQueue< MemoryMessage > | [inline, protected] |