OnixS C++ eSpeed ITCH Market Data Handler  1.7.3
API documentation
FeedEngineListener Struct Reference

#include <OnixS/eSpeed/MarketData/Itch/FeedEngine.h>

Public Member Functions

virtual void onFeedEngineThreadBegin (const FeedEngine &)
 
virtual void onFeedEngineThreadEnd (const FeedEngine &)
 
virtual void onFeedEngineThreadIdle (const FeedEngine &, FeedEngineThreadIdle::Reason, UInt32 &)
 

Detailed Description

Listener for thread-related events.

Members of this classes are invoked to reflect various life-time events of threads spawned and used by the feed engine while processing market data.

Definition at line 219 of file FeedEngine.h.

Member Function Documentation

virtual void onFeedEngineThreadBegin ( const FeedEngine )
inlinevirtual

Member invoked by feed engine when a new processing thread is spawned.

Note
Invocation is done within newly started thread.

Definition at line 226 of file FeedEngine.h.

virtual void onFeedEngineThreadEnd ( const FeedEngine )
inlinevirtual

Member is invoked by feed engine when processing thread is about to end.

Note
Invocation is done within the thread that is about to end.

Definition at line 233 of file FeedEngine.h.

virtual void onFeedEngineThreadIdle ( const FeedEngine ,
FeedEngineThreadIdle::Reason  ,
UInt32 &   
)
inlinevirtual

Is called when feed engine's thread is idle.

Thread becomes idle when either no data is received within time interval defined by FeedEngineSettings::dataWaitTime parameter or no pending data is available for processing. In the first case, callback is invoked with 'DataWaitTimeout' reason. In the second case, thread is considered as redundant and thus callback is invoked with 'Redundant' reason. After callback invocation threads may sleep in kernel to reduce load onto CPU and racing between feed engine working threads.

Integer parameter-variable defines amount of time feed engine suggest for thread to sleep in kernel after invoking given member.

Definition at line 248 of file FeedEngine.h.


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