ark::async_consumer_policies::MultiMessagePortQueue< T > Member List

This is the complete list of members for ark::async_consumer_policies::MultiMessagePortQueue< T >, including all inherited members.

_doRemoval()	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, private]
_finishedPorts	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_hasNewPorts	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_lastIter	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_mmpqMutex	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_mports	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_pendingPorts	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_removePorts	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_removeQueueAtAddress(IQueueType *q)	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
_sharedSem	ark::async_consumer_policies::MultiMessagePortQueue< T >	[private]
_waitForMessage(T &msg, unsigned sec, unsigned nanos)	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
addInputQueue(boost::shared_ptr< IQueueType > const &mport)	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline]
beginProducers()	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
beginProducers() const	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
endProducers()	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
endProducers() const	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
IQueueType typedef	ark::async_consumer_policies::MultiMessagePortQueue< T >
MultiMessagePortQueue()	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]
PortList typedef	ark::async_consumer_policies::MultiMessagePortQueue< T >	[protected]
removeInputQueue(boost::shared_ptr< IQueueType > const &mport)	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline]
scoped_lock typedef	ark::async_consumer_policies::MultiMessagePortQueue< T >	[protected]
updateSource()	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline]
~MultiMessagePortQueue()	ark::async_consumer_policies::MultiMessagePortQueue< T >	[inline, protected]

---