CPN
Computational Process Networks
CPN::RemoteQueue Member List

This is the complete list of members for CPN::RemoteQueue, including all inherited members.

actionCondCPN::RemoteQueueprivate
actionThreadCPN::RemoteQueueprivate
ActionThreadEntryPoint()CPN::RemoteQueueprivate
actionTickCPN::RemoteQueueprivate
alphaCPN::RemoteQueueprivate
bytecountCPN::RemoteQueueprivate
clockCPN::RemoteQueueprivate
ClockString() const CPN::RemoteQueueprivate
condCPN::QueueBaseprotected
Count() const CPN::QueueBase
D4RTagPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
datatypeCPN::QueueBaseprotected
deadCPN::RemoteQueueprivate
Dequeue(unsigned count)CPN::QueueBase
DequeueChannelStride() const CPN::QueueBase
DequeuePacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
dequeuethreshCPN::QueueBaseprotected
dequeueUseOldCPN::ThresholdQueueprotected
Detect()CPN::QueueBaseprotectedvirtual
Empty() const CPN::QueueBase
EndOfReadPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
EndOfWritePacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
Enqueue(unsigned count)CPN::QueueBase
EnqueueChannelStride() const CPN::QueueBase
EnqueuePacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
enqueuethreshCPN::QueueBaseprotected
enqueueUseOldCPN::ThresholdQueueprotected
fileThreadCPN::RemoteQueueprivate
FileThreadEntryPoint()CPN::RemoteQueueprivate
FirePacket(const Packet &packet)CPN::PacketHandlerprivate
Flush()CPN::QueueBase
Flushed() const CPN::QueueBase
flushedCPN::QueueBaseprotected
FlushPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
Freespace() const CPN::QueueBase
Full() const CPN::QueueBase
GetDatatype() const CPN::QueueBaseinline
GetDecoderBytes(unsigned &amount)CPN::PacketDecoderprivate
GetKey() const CPN::RemoteQueueinlinevirtual
GetMode() const CPN::RemoteQueueinline
GetRawDequeuePtr(unsigned thresh, unsigned chan)CPN::QueueBase
GetRawEnqueuePtr(unsigned thresh, unsigned chan)CPN::QueueBase
GetReaderKey() const CPN::QueueBaseinline
GetState()CPN::RemoteQueueprivate
GetWriterKey() const CPN::QueueBaseinline
Grow(unsigned queueLen, unsigned maxThresh)CPN::QueueBase
GrowPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
HandleError(const ErrnoException &e)CPN::RemoteQueueprivate
holderCPN::RemoteQueueprivate
IDReaderPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
IDWriterPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
incommD4R::QueueBaseprotected
indequeueCPN::QueueBaseprotected
inenqueueCPN::QueueBaseprotected
InternalCheckStatus()CPN::RemoteQueueprivate
InternalDequeue(unsigned count)CPN::RemoteQueueprivatevirtual
InternalEnqueue(unsigned count)CPN::RemoteQueueprivatevirtual
InternalFlush()CPN::RemoteQueueprivatevirtual
InternalGetRawDequeuePtr(unsigned thresh, unsigned chan)CPN::ThresholdQueueprotectedvirtual
InternalGetRawEnqueuePtr(unsigned thresh, unsigned chan)CPN::ThresholdQueueprotectedvirtual
InternalReset()CPN::RemoteQueueprivatevirtual
IsReaderShutdown()CPN::QueueBase
IsWriterShutdown()CPN::QueueBase
kernelCPN::QueueBaseprotected
Lock() const CPN::QueueBaseinlinevirtual
lockCPN::QueueBasemutableprotected
loggerCPN::QueueBaseprotected
LogState()CPN::RemoteQueuevirtual
MaxThreshold() const CPN::QueueBase
maxwritethresholdCPN::RemoteQueueprivate
mocknodeCPN::RemoteQueueprivate
modeCPN::RemoteQueueprivate
Mode_t enum nameCPN::RemoteQueue
NotifyData()CPN::QueueBaseprotected
NotifyFreespace()CPN::QueueBaseprotected
NotifyTerminate()CPN::QueueBase
NumBytes() const CPN::PacketDecoderinlineprivate
NumChannels() const CPN::QueueBase
NumDequeued() const CPN::QueueBase
NumEnqueued() const CPN::QueueBase
oldqueueCPN::ThresholdQueueprotected
PacketDecoder()CPN::PacketDecoderprivate
PacketEncoder()CPN::PacketEncoderprivate
pendingActionCPN::RemoteQueueprivate
pendingBlockCPN::RemoteQueueprivate
pendingD4RTagCPN::RemoteQueueprivate
pendingFlushCPN::RemoteQueueprivate
pendingGrowCPN::RemoteQueueprivate
pendingResetCPN::RemoteQueueprivate
postpadCPN::QueueBaseprotected
prepadCPN::QueueBaseprotected
queueCPN::ThresholdQueueprotected
QueueBase(KernelBase *k, const SimpleQueueAttr &attr)CPN::QueueBaseprotected
D4R::QueueBase::QueueBase()D4R::QueueBase
QueueLength(unsigned length, unsigned maxthresh, double alpha, Mode_t mode)CPN::RemoteQueueprivatestatic
CPN::ThresholdQueue::QueueLength() const CPN::QueueBase
RawDequeue(void *data, unsigned count, unsigned numChans, unsigned chanStride)CPN::QueueBase
RawDequeue(void *data, unsigned count)CPN::QueueBase
RawEnqueue(const void *data, unsigned count, unsigned numChans, unsigned chanStride)CPN::QueueBase
RawEnqueue(const void *data, unsigned count)CPN::QueueBase
Read()CPN::RemoteQueueprivate
READ enum valueCPN::RemoteQueue
ReadBlock()D4R::QueueBaseprotected
ReadBlocked()CPN::QueueBaseprotectedvirtual
ReadBlockPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
readclockCPN::RemoteQueueprivate
readerD4R::QueueBaseprotected
readerkeyCPN::QueueBaseprotected
readerlengthCPN::RemoteQueueprivate
ReadRequest()CPN::QueueBase
readrequestCPN::QueueBaseprotected
readshutdownCPN::QueueBaseprotected
readtagchangedD4R::QueueBaseprotected
ReleaseDecoderBytes(unsigned amount)CPN::PacketDecoderprivate
RemoteQueue(KernelBase *k, Mode_t mode, ConnectionServer *s, RemoteQueueHolder *h, const SimpleQueueAttr &attr, bool usembs)CPN::RemoteQueue
CPN::Reset()CPN::QueueBase
CPN::PacketDecoder::Reset()CPN::PacketDecoderprivate
ResetPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
SendD4RTagPacket()CPN::RemoteQueueprivate
SendDequeuePacket()CPN::RemoteQueueprivate
SendEndOfReadPacket()CPN::RemoteQueueprivate
SendEndOfWritePacket()CPN::RemoteQueueprivate
SendEnqueue(const Packet &packet, Queue_t &queue)CPN::PacketEncoderinlineprivate
SendEnqueuePacket()CPN::RemoteQueueprivate
SendFlushPacket()CPN::RemoteQueueprivate
SendGrowPacket()CPN::RemoteQueueprivate
SendPacket(const Packet &packet)CPN::PacketEncoderprivate
SendPacket(const Packet &packet, void *data)CPN::PacketEncoderprivate
SendReadBlockPacket()CPN::RemoteQueueprivate
SendResetPacket()CPN::RemoteQueueprivate
SendWriteBlockPacket()CPN::RemoteQueueprivate
sentEndCPN::RemoteQueueprivate
serverCPN::RemoteQueueprivate
SetReaderNode(shared_ptr< Node > n)D4R::QueueBase
SetupPacket(Packet &packet)CPN::RemoteQueueprivate
SetWriterNode(shared_ptr< Node > n)D4R::QueueBase
Shutdown()CPN::RemoteQueuevirtual
ShutdownReader()CPN::QueueBase
ShutdownWriter()CPN::QueueBase
Signal()CPN::RemoteQueueprivatevirtual
SignalReaderTagChanged()D4R::QueueBase
SignalWriterTagChanged()D4R::QueueBase
sockCPN::RemoteQueueprivate
Start()CPN::RemoteQueuevirtual
tagUpdatedCPN::RemoteQueueprivate
ThresholdQueue(KernelBase *k, const SimpleQueueAttr &attr, bool usembs)CPN::ThresholdQueue
ThresholdQueue(KernelBase *k, const SimpleQueueAttr &attr, unsigned length, bool usembs)CPN::ThresholdQueue
TickClock()CPN::RemoteQueueprivate
Unlock() const CPN::QueueBaseinlinevirtual
UnlockedCount() const CPN::RemoteQueueprivatevirtual
UnlockedDequeueChannelStride() const CPN::ThresholdQueueprotectedvirtual
UnlockedEmpty() const CPN::RemoteQueueprivatevirtual
UnlockedEnqueueChannelStride() const CPN::ThresholdQueueprotectedvirtual
UnlockedFreespace() const CPN::ThresholdQueueprotectedvirtual
UnlockedFull() const CPN::ThresholdQueueprotectedvirtual
UnlockedGrow(unsigned queueLen, unsigned maxThresh)CPN::RemoteQueueprivatevirtual
UnlockedMaxThreshold() const CPN::ThresholdQueueprotectedvirtual
UnlockedNumChannels() const CPN::ThresholdQueueprotectedvirtual
UnlockedNumDequeued() const CPN::ThresholdQueueprotectedvirtual
UnlockedNumEnqueued() const CPN::ThresholdQueueprotectedvirtual
UnlockedQueueLength() const CPN::RemoteQueueprivatevirtual
UnlockedShutdown()CPN::RemoteQueueprivate
UnlockedShutdownReader()CPN::QueueBaseprotectedvirtual
UnlockedShutdownWriter()CPN::QueueBaseprotectedvirtual
UnlockedSignalReaderTagChanged()CPN::RemoteQueueprivatevirtual
UnlockedSignalWriterTagChanged()CPN::RemoteQueueprivatevirtual
UpdateClock(const Packet &packet)CPN::RemoteQueueprivate
useD4RCPN::QueueBaseprotected
Wait()CPN::QueueBaseinlineprotectedvirtual
WaitForData()CPN::RemoteQueueprivatevirtual
WaitForFreespace()CPN::RemoteQueueprivatevirtual
WRITE enum valueCPN::RemoteQueue
WriteBlock(unsigned qsize)D4R::QueueBaseprotected
WriteBlocked()CPN::QueueBaseprotectedvirtual
WriteBlockPacket(const Packet &packet)CPN::RemoteQueueprivatevirtual
WriteBytes(const iovec *iov, unsigned iovcnt)CPN::RemoteQueueprivatevirtual
writeclockCPN::RemoteQueueprivate
writerD4R::QueueBaseprotected
WriteRequest()CPN::QueueBase
writerequestCPN::QueueBaseprotected
writerkeyCPN::QueueBaseprotected
writerlengthCPN::RemoteQueueprivate
writeshutdownCPN::QueueBaseprotected
writetagchangedD4R::QueueBaseprotected
~PacketDecoder()CPN::PacketDecoderprivatevirtual
~PacketEncoder()CPN::PacketEncoderprivatevirtual
~PacketHandler()CPN::PacketHandlerprivatevirtual
~QueueBase()CPN::QueueBasevirtual
~RemoteQueue()CPN::RemoteQueue
~RemoteQueueBase()CPN::RemoteQueueBasevirtual
~ThresholdQueue()CPN::ThresholdQueue