OnixS C++ Eurex T7 Market and Reference Data Interface (EMDI, RDI, EOBI) Handlers  7.4.2
API documentation
EobiSnapshotPacketProcessor Class Reference

#include </work/src/EOBI/EobiPacketProcessor.h>

Collaboration diagram for EobiSnapshotPacketProcessor:

Public Member Functions

 EobiSnapshotPacketProcessor (unsigned int maxPacketWaitingTimeInMs, unsigned int inactivityWaitingTimeInSec, unsigned int outOfOrderMaxInterval, Concurrency::RecursiveMutex *lock)
 
void onPacket (FE::PacketContainer &) override
 
- Public Member Functions inherited from EobiPacketProcessor
 EobiPacketProcessor (unsigned int maxPacketWaitingTimeInMs, unsigned int inactivityWaitingTimeInSec, unsigned int outOfOrderMaxInterval, Concurrency::RecursiveMutex *lock)
 
virtual ~EobiPacketProcessor ()
 
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 processHoldOnPackets (const FE::Timestamp &now)
 
void subscribeOnPacketData (const OnPacketData callback)
 
void subscribeOnGap (const OnGap callback)
 
void subscribeOnApplSeqReset (const OnApplSeqReset callback)
 
void subscribeOnInactivity (const OnInactivity callback)
 
void subscribeOnFeedInactivity (const OnFeedInactivity callback)
 

Additional Inherited Members

- Public Types inherited from EobiPacketProcessor
typedef boost::function< void(DataSource &dataSource, const char *data, size_t length)> OnPacketData
 
typedef boost::function< void()> OnGap
 
typedef boost::function< void()> OnInactivity
 
typedef boost::function< void(FE::NetFeedRole::Enum)> OnFeedInactivity
 
typedef boost::function< void()> OnApplSeqReset
 
- Protected Member Functions inherited from EobiPacketProcessor
DataSource createDataSource (FE::PacketContainer &packetContainer, SequenceNumber packetSeqNum)
 
- Protected Attributes inherited from EobiPacketProcessor
OnPacketData onPacketData_
 
OnGap onGap_
 
OnApplSeqReset onApplSeqReset_
 
OnInactivity onInactivity_
 
OnFeedInactivity onFeedInactivity_
 
SequenceNumber nextPacketSeqNum_
 
const FE::TimeSpan maxPacketWaitingTimeSpan_
 
const FE::TimeSpan inactivityWaitingTimeSpan_
 
const UInt32 outOfOrderMaxInterval_
 
bool inactivityFlag_
 
bool inactivityFlagA_
 
bool inactivityFlagB_
 
bool applSeqResetting_
 
FE::Timestamp lastReceptionTimeFe_
 
FE::Timestamp lastReceptionTimeFeA_
 
FE::Timestamp lastReceptionTimeFeB_
 
FE::SortedPackets< PacketHelperoutOfOrder_
 
OnixS::Concurrency::RecursiveMutex * lock_
 

Detailed Description

Definition at line 132 of file EobiPacketProcessor.h.

Constructor & Destructor Documentation

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

Definition at line 307 of file EobiPacketProcessor.cpp.

Member Function Documentation

void onPacket ( FE::PacketContainer &  packetContainer)
override

Definition at line 316 of file EobiPacketProcessor.cpp.


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