OnixS C++ Eurex T7 Market and Reference Data Interface (EMDI, RDI, EOBI) Handlers  8.1.0
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)

Definition at line 316 of file EobiPacketProcessor.cpp.

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