B2BITS FIX Antenna HFT  1.0.16
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Public Attributes | List of all members
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
 
}; 
 
MsgPipeElemelem
 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...
 
PersistentDatapersistentData
 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
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.