_NOT_SOCKET enum value | IO_Processor | |
_PACKET_HAS_META_DATA enum value | IO_Processor | |
_PACKET_HAS_RECEIVE_TIME enum value | IO_Processor | |
_PACKET_HAS_SOURCE enum value | IO_Processor | |
bfrManager | IO_Processor | |
blockingMode | IO_Processor | |
BlockMode enum name | IO_Processor | |
BOTH_THREADS enum value | IO_Processor | |
bufferAddress(SharedBufferAllocRecord *rec, size_t *bufferLen=nullptr) const OME_ALWAYS_INLINE | IO_Processor | inline |
bufferHeaderAddress(SharedBufferAllocRecord *rec, size_t *headerLen=nullptr) const OME_ALWAYS_INLINE | IO_Processor | inline |
condition | IO_Processor | |
consumeRoutine | IO_Processor | |
consumeThreadID | IO_Processor | |
CONTIGUOUS_BYTE_STREAM enum value | IO_Processor | |
CONTIGUOUS_FILE_STREAM enum value | IO_Processor | |
currentThreadState | IO_Processor | |
dataOffset() const OME_ALWAYS_INLINE | IO_Processor | inline |
descriptor | IO_Processor | |
descriptorFlags | IO_Processor | |
desiredThreadState | IO_Processor | |
doConsumeLoop(IO_Processor *controller) | IO_Processor | static |
doProcessLoop(IO_Processor *controller) | IO_Processor | static |
extraData | IO_Processor | |
getExtraData() const OME_ALWAYS_INLINE | IO_Processor | inline |
getLabel() const OME_ALWAYS_INLINE NONNULL_RETURN | IO_Processor | inline |
getReadAttempts() const OME_ALWAYS_INLINE | IO_Processor | inline |
getReadTimeout() const OME_ALWAYS_INLINE | IO_Processor | inline |
getThreadMode() const OME_ALWAYS_INLINE | IO_Processor | inline |
interruptThread(uint32_t modes, bool force=false) | IO_Processor | |
IO_Processor(SharedMemoryVariableNode *parentNode, BufferRegion *mgr, IO_processBlockFP b_func, OS_HANDLE_TYPE h, ThreadMode tMode=NONE, void *userData=nullptr, BlockMode bMode=PACKET, IO_receiveBlockFP r_func=recvConsume, IO_consumeFP c_func=doConsumeLoop, IO_processFP p_func=doProcessLoop) | IO_Processor | |
label | IO_Processor | |
lastReadTimeout | IO_Processor | |
maxPacketSize | IO_Processor | |
mutex | IO_Processor | |
NONE enum value | IO_Processor | |
noteDataToProcess(bool alreadyLocked=false) | IO_Processor | |
PACKET enum value | IO_Processor | |
PACKET_WITH_SOURCE enum value | IO_Processor | |
PACKET_WITH_SOURCE_AND_TIME enum value | IO_Processor | |
PACKET_WITH_TIME enum value | IO_Processor | |
packetsProcessedIncrement | IO_Processor | |
PROCESS_DURING_READ enum value | IO_Processor | |
PROCESS_THREAD enum value | IO_Processor | |
processBlockRoutine | IO_Processor | |
processRoutine | IO_Processor | |
processThreadID | IO_Processor | |
READ_AND_PROCESS_ON_SAME_THREAD enum value | IO_Processor | |
READ_THREAD enum value | IO_Processor | |
recvConsume(SharedBufferAllocRecord *rec, class IO_Processor *controller) | IO_Processor | static |
recvRoutine | IO_Processor | |
SEPARATE_READ_AND_PROCESS_THREADS enum value | IO_Processor | |
setBlockingMode(BlockMode mode) | IO_Processor | |
setConsumeLoopRoutine(IO_consumeFP func) OME_ALWAYS_INLINE | IO_Processor | inline |
setConsumeRoutine(IO_receiveBlockFP func) OME_ALWAYS_INLINE | IO_Processor | inline |
setExtraData(void *data) OME_ALWAYS_INLINE | IO_Processor | inline |
setLabel(const char *name) OME_ALWAYS_INLINE NONNULL_CLASS_PARAMETERS(2) | IO_Processor | inline |
setMaxPacketSize(size_t bytes) OME_ALWAYS_INLINE | IO_Processor | inline |
setPacketsProcessedIncrement(int32_t incVal) | IO_Processor | inline |
setProcessLoopRoutine(IO_processFP func) OME_ALWAYS_INLINE | IO_Processor | inline |
setProcessRoutine(IO_processBlockFP func) OME_ALWAYS_INLINE | IO_Processor | inline |
setReadAttempts(uint32_t count) OME_ALWAYS_INLINE | IO_Processor | inline |
setReadTimeout(uint32_t count) OME_ALWAYS_INLINE | IO_Processor | inline |
setThreadMode(ThreadMode mode) | IO_Processor | |
statistics | IO_Processor | |
stopRequested | IO_Processor | |
stopThread(uint32_t modes) | IO_Processor | |
submitOrProcessBlock(SharedBufferAllocRecord *rec) | IO_Processor | |
ThreadMode enum name | IO_Processor | |
threadStartedState | IO_Processor | |
waitForDataToProcess(bool alreadyLocked=false) | IO_Processor | |
waitForDataToProcessOrUntil(const struct timespec *maxWaitUntil, bool alreadyLocked=false) | IO_Processor | |
waitForThreadExit(uint32_t modes) | IO_Processor | |
waitForThreadStart(uint32_t mode) | IO_Processor | |
~IO_Processor() | IO_Processor | virtual |