|
CPN
Computational Process Networks
|
#include "common_priv.h"#include "RemoteQueue.h"#include "RemoteQueueHolder.h"#include <cpn/QueueAttr.h>#include <cpn/bits/KernelBase.h>#include <cpn/Exceptions.h>#include <cpn/utils/AutoLock.h>#include <cpn/utils/AutoUnlock.h>#include <cpn/threading/PthreadFunctional.h>#include "ConnectionServer.h"#include <cpn/utils/ErrnoException.h>#include <cpn/utils/ThrowingAssert.h>#include <cpn/d4r/D4RNode.h>#include <errno.h>#include <algorithm>#include <sstream>
Include dependency graph for RemoteQueue.cc:Go to the source code of this file.
Namespaces | |
| CPN | |
Macros | |
| #define | FUNC_TRACE(logger) |
Functions | |
| const char * | CPN::BoolString (bool tf) |
Definition in file RemoteQueue.cc.
| #define FUNC_TRACE | ( | logger | ) |
Definition at line 43 of file RemoteQueue.cc.
Referenced by CPN::RemoteQueue::D4RTagPacket(), CPN::RemoteQueue::DequeuePacket(), CPN::RemoteQueue::EndOfReadPacket(), CPN::RemoteQueue::EndOfWritePacket(), CPN::RemoteQueue::EnqueuePacket(), CPN::RemoteQueue::FlushPacket(), CPN::RemoteQueue::GrowPacket(), CPN::RemoteQueue::InternalDequeue(), CPN::RemoteQueue::InternalEnqueue(), CPN::RemoteQueue::ReadBlockPacket(), CPN::RemoteQueue::ResetPacket(), CPN::RemoteQueue::SendD4RTagPacket(), CPN::RemoteQueue::SendDequeuePacket(), CPN::RemoteQueue::SendEndOfReadPacket(), CPN::RemoteQueue::SendEndOfWritePacket(), CPN::RemoteQueue::SendEnqueuePacket(), CPN::RemoteQueue::SendFlushPacket(), CPN::RemoteQueue::SendGrowPacket(), CPN::RemoteQueue::SendReadBlockPacket(), CPN::RemoteQueue::SendResetPacket(), CPN::RemoteQueue::SendWriteBlockPacket(), CPN::RemoteQueue::UnlockedGrow(), CPN::RemoteQueue::UnlockedShutdown(), CPN::RemoteQueue::UnlockedSignalReaderTagChanged(), CPN::RemoteQueue::UnlockedSignalWriterTagChanged(), CPN::RemoteQueue::WaitForData(), CPN::RemoteQueue::WaitForFreespace(), CPN::RemoteQueue::WriteBlockPacket(), and CPN::RemoteQueue::~RemoteQueue().
1.8.5