#include <OnixS/B3/MarketData/UMDF/FeedEngine.h>
Public Member Functions | |
| EfViFeedEngine (const LoggerSettings &loggerSettings, UInt32 receiveRingSize=4095, WatchService &watch=NicWatch::service()) | |
| EfViFeedEngine (UInt32 receiveRingSize=4095, WatchService &watch=NicWatch::service()) | |
| NetFeedEngineProcessResult | process () |
| ~EfViFeedEngine () override | |
| Public Member Functions inherited from FeedEngine | |
| std::string | info () |
| virtual | ~FeedEngine () |
Additional Inherited Members | |
| Protected Member Functions inherited from FeedEngine | |
| FeedEngine (void *impl) | |
| FeedEngine (const FeedEngine &)=delete | |
| FeedEngine & | operator= (const FeedEngine &)=delete |
| Protected Attributes inherited from FeedEngine | |
| void *const | impl_ |
Definition at line 247 of file FeedEngine.h.
| EfViFeedEngine | ( | const LoggerSettings & | loggerSettings, |
| UInt32 | receiveRingSize = 4095, | ||
| WatchService & | watch = NicWatch::service() ) |
Constructor.
| loggerSettings | Defines feed engine logging settings. |
| receiveRingSize | Number of buffers in a virtual interface receive ring. Single buffer is used for a single network packet. Thus the receive ring must be capacious enough to place incoming packets during market data bursts. |
| watch | Watch service to be used by Feed Engine. |
Watch is used by Feed Engine to assign time points to packets received from the feeds.
|
explicit |
|
override |
| NetFeedEngineProcessResult process | ( | ) |
Carries out pending actions like data retrieval and event dispatching.
This function must be invoked after each handler-associated action (i.e., start, stop).