Engine::FIXMessageProcessElem Struct Reference

#include <B2BITS_FIXMessagePool.h>

Collaboration diagram for Engine::FIXMessageProcessElem:

Public Member Functions
	FIXMessageProcessElem (unsigned long long nTimestamp1970=0)
void	resetFlags ()

Public Attributes
union {
struct {
char   canThrottle
	defines if last recv() added 0 bytes because the buffer is full More...
char   committed
	defines if the message was stored to the log More...
char   offloadAdminMessage
	defines if the message processing should be scheduled to be performed in the pool and the socket reading should be paused until it is done (admin messages only) More...
char   pauseRead
	defines if the session should pause reading until Engine::Session::resumeRead() is called. More...
char   pipelined
	defines if the elem was passed for further processing and will be returned to the pool manually More...
char   throttled
	defines if the message processing should be delayed More...
}
System::u64   flags
};
MsgPipeElem *	elem
	The element of the message pool that can be passed for further processing. More...
char *	msgBuf
	The incoming message to commit. More...
int	msgSize
	The incoming message size. More...
PersistentData *	persistentData
	The persistent data to commit with the incoming message. More...
System::u64	sessionGlobalID_
	N/A. More...
unsigned long long	timestamp1970
	The message received time in microseconds. More...

Constructor & Destructor Documentation

Engine::FIXMessageProcessElem::FIXMessageProcessElem ( unsigned long long  nTimestamp1970 = 0 )

inlineexplicit

References flags.

Member Function Documentation

void Engine::FIXMessageProcessElem::resetFlags ( )

inline

References flags.

Member Data Documentation

union { ... }

char Engine::FIXMessageProcessElem::canThrottle

defines if last recv() added 0 bytes because the buffer is full

char Engine::FIXMessageProcessElem::committed

defines if the message was stored to the log

MsgPipeElem* Engine::FIXMessageProcessElem::elem

The element of the message pool that can be passed for further processing.

System::u64 Engine::FIXMessageProcessElem::flags

Referenced by FIXMessageProcessElem(), and resetFlags().

char* Engine::FIXMessageProcessElem::msgBuf

The incoming message to commit.

int Engine::FIXMessageProcessElem::msgSize

The incoming message size.

char Engine::FIXMessageProcessElem::offloadAdminMessage

defines if the message processing should be scheduled to be performed in the pool and the socket reading should be paused until it is done (admin messages only)

char Engine::FIXMessageProcessElem::pauseRead

defines if the session should pause reading until Engine::Session::resumeRead() is called.

Warning

if the session is paused for long time, it will be disconnected by hearbeat timeout

PersistentData* Engine::FIXMessageProcessElem::persistentData

The persistent data to commit with the incoming message.

char Engine::FIXMessageProcessElem::pipelined

defines if the elem was passed for further processing and will be returned to the pool manually

System::u64 Engine::FIXMessageProcessElem::sessionGlobalID_

N/A.

char Engine::FIXMessageProcessElem::throttled

defines if the message processing should be delayed

unsigned long long Engine::FIXMessageProcessElem::timestamp1970

The message received time in microseconds.