38 : packetMaxSize_(1420)
40 , socketBufferSize_(8 * 1024 * 1024)
53 return packetMaxSize_;
59 packetMaxSize_ = value;
86 return socketBufferSize_;
92 socketBufferSize_ = value;
106 return dataWaitTime_;
112 dataWaitTime_ = value;
132 toStr(str, settings);
176 Workhorse* workhorse_;
#define ONIXS_CMEMDH_NAMESPACE_BEGIN
#define ONIXS_CMEMDH_LTWT
#define ONIXS_CMEMDH_NAMESPACE_END
#define ONIXS_CMEMDH_EXPORTED
#define ONIXS_CMEMDH_OVERRIDE
Designed to reflect various aspects of feed engine processing flow.
NetFeedEngine()
Construction through the descendants.
Abstraction of a link used by the NetFeed instances to cover transportation layer.
Base attributes of market data feed.
Represents a collection of settings affecting the behavior of the multi-threaded feed engine while wo...
SocketFeedEngineSettings()
Initializes the given instance of the network settings with the default values.
void packetMaxSize(PacketSize value)
Max size for network packet transmitted by MDP.
void socketBufferSize(UInt32 value)
Sets socketBufferSize.
~SocketFeedEngineSettings()
Cleans everything up.
void watch(WatchService &watch)
Watch service to be used by Feed Engine.
PacketSize packetMaxSize() const
Max size for network packet transmitted by MDP.
UInt32 dataWaitTime() const
Defines amount of time Feed Engine spends on socket waiting for I/O while running master processing l...
UInt32 socketBufferSize() const
Defines size of receiving buffer in bytes for sockets.
void dataWaitTime(UInt32 value)
Sets dataWaitTime.
WatchService & watch() const
Watch service to be used by Feed Engine.
void info(std::string &) override
Appends information on the given implementation to the given string.
~SocketFeedEngine() override
Destructs the given instance.
SocketFeedEngine()
Initializes the engine with the default settings.
NetFeedLink & allocate(const NetFeed &) override
Allocates a link for the given feed.
NetFeedEngineProcessResult process() override
Carries out pending actions like data retrieval and event dispatching.
WatchService & watch() override
Exposes an instance of the watch service used while manipulating the feed links.
SocketFeedEngine(const SocketFeedEngineSettings &)
Initializes the engine according to the given configuration.
void toStr(std::string &, BookState::Enum)
Serializes book state value into a string.
UInt16 PacketSize
Integral type for measuring packets.