OnixS C++ Eurex T7 Market and Reference Data Interface (EMDI, RDI, EOBI) Handlers  7.4.2
API documentation
PacketProcessor< TPacketHeader > Class Template Reference

#include </work/src/PacketProcessor.h>

Collaboration diagram for PacketProcessor< TPacketHeader >:

Public Types

typedef boost::function< void(DataSource &, const char *, size_t, size_t)> OnPacketData
 
typedef boost::function< void()> OnGap
 
typedef boost::function< void(unsigned int, unsigned int, SequenceNumber, SequenceNumber)> OnSenderCompIdChange
 
typedef boost::function< void()> OnInactivity
 
typedef boost::function< void(FE::NetFeedRole::Enum)> OnFeedInactivity
 

Public Member Functions

 PacketProcessor (unsigned int, unsigned int, unsigned int, Concurrency::RecursiveMutex *)
 
virtual ~PacketProcessor ()
 
void reset () override
 
bool tryAcquire () override
 
void release () override
 
void onPacket (FE::PacketContainer &) override
 
void onTimeout (const FE::NetFeed &) override
 
void onFailure (const FE::NetFeed &, const char *) override
 
void subscribeOnPacketData (OnPacketData callback)
 
void subscribeOnGap (OnGap callback)
 
void subscribeOnSenderCompIdChange (OnSenderCompIdChange callback)
 
void subscribeOnInactivity (OnInactivity callback)
 
void subscribeOnFeedInactivity (OnFeedInactivity callback)
 

Protected Member Functions

virtual bool filterPacket (const TPacketHeader *)
 
virtual void fillDataSource (FE::PacketContainer &packetContainer, DataSource &dataSource)
 

Detailed Description

template<class TPacketHeader>
class OnixS::Eurex::MarketData::Implementation::PacketProcessor< TPacketHeader >

Definition at line 97 of file PacketProcessor.h.

Member Typedef Documentation

typedef boost::function<void(FE::NetFeedRole::Enum)> OnFeedInactivity

Definition at line 115 of file PacketProcessor.h.

typedef boost::function<void()> OnGap

Definition at line 112 of file PacketProcessor.h.

typedef boost::function<void()> OnInactivity

Definition at line 114 of file PacketProcessor.h.

typedef boost::function<void(DataSource&, const char*, size_t, size_t)> OnPacketData

Definition at line 111 of file PacketProcessor.h.

typedef boost::function<void(unsigned int, unsigned int, SequenceNumber, SequenceNumber)> OnSenderCompIdChange

Definition at line 113 of file PacketProcessor.h.

Constructor & Destructor Documentation

PacketProcessor ( unsigned int  maxPacketWaitingTimeInMs,
unsigned int  inactivityWaitingTimeInSec,
unsigned int  outOfOrderMaxInterval,
Concurrency::RecursiveMutex *  lock 
)

Definition at line 178 of file PacketProcessor.h.

virtual ~PacketProcessor ( )
inlinevirtual

Definition at line 101 of file PacketProcessor.h.

Member Function Documentation

void fillDataSource ( FE::PacketContainer &  packetContainer,
DataSource dataSource 
)
protectedvirtual

Reimplemented in EmdiPacketProcessor, and MdiPacketProcessor.

Definition at line 225 of file PacketProcessor.h.

virtual bool filterPacket ( const TPacketHeader *  )
inlineprotectedvirtual

Reimplemented in EmdiPacketProcessor.

Definition at line 143 of file PacketProcessor.h.

void onFailure ( const FE::NetFeed &  ,
const char *   
)
inlineoverride

Definition at line 108 of file PacketProcessor.h.

void onPacket ( FE::PacketContainer &  packetContainer)
override

Definition at line 257 of file PacketProcessor.h.

void onTimeout ( const FE::NetFeed &  feed)
override

Definition at line 329 of file PacketProcessor.h.

void release ( )
override

Definition at line 218 of file PacketProcessor.h.

void reset ( )
override

Definition at line 193 of file PacketProcessor.h.

void subscribeOnFeedInactivity ( OnFeedInactivity  callback)
inline

Definition at line 137 of file PacketProcessor.h.

void subscribeOnGap ( OnGap  callback)
inline

Definition at line 122 of file PacketProcessor.h.

void subscribeOnInactivity ( OnInactivity  callback)
inline

Definition at line 132 of file PacketProcessor.h.

void subscribeOnPacketData ( OnPacketData  callback)
inline

Definition at line 117 of file PacketProcessor.h.

void subscribeOnSenderCompIdChange ( OnSenderCompIdChange  callback)
inline

Definition at line 127 of file PacketProcessor.h.

bool tryAcquire ( )
override

Definition at line 211 of file PacketProcessor.h.


The documentation for this class was generated from the following file: