23 #include <OnixS/SgxTitan/MarketData/Itch/Bootstrap.h> 30 ONIXS_SGXTITAN_ITCH_NAMESPACE_BEGIN
38 typedef std::set<CpuIndex> CpuIndexes;
54 void copyTo(CpuIndexes&)
const;
69 std::string toString()
const;
85 UInt32 spinBeforeIdleTime_;
87 UInt32 socketBufferSize_;
107 return threadAffinity_;
119 return threadAffinity_;
133 threadCount_ = value;
147 return dataWaitTime_;
153 dataWaitTime_ = value;
166 return spinBeforeIdleTime_;
172 spinBeforeIdleTime_ = value;
180 return socketBufferSize_;
186 socketBufferSize_ = value;
190 std::string toString()
const;
276 ONIXS_SGXTITAN_ITCH_NAMESPACE_END
virtual void onFeedEngineThreadBegin(const FeedEngine &)
Represents set of CPU indices.
UInt32 socketBufferSize() const
void socketBufferSize(UInt32 value)
Sets udpSocketBufferSize.
virtual void onFeedEngineThreadEnd(const FeedEngine &)
void dataWaitTime(UInt32 value)
Sets dataWaitTime.
size_t CpuIndex
Zero-based index of CPU.
Identifies reasons feed engine threads becomes idle.
void spinBeforeIdleTime(UInt32 value)
Sets redundancySpinTime.
const ThreadAffinity & threadAffinity() const
UInt32 spinBeforeIdleTime() const
virtual void onFeedEngineThreadIdle(const FeedEngine &, FeedEngineThreadIdle::Reason, UInt32 &)
UInt32 dataWaitTime() const
UInt32 threadCount() const
Collection of settings affecting Feed Engine behavior.
ONIXS_SGXTITAN_ITCH_API std::ostream & operator<<(std::ostream &stream, const FeedEngineSettings &settings)
#define ONIXS_SGXTITAN_ITCH_API_DECL(typeKind, typeName)
void threadCount(UInt32 value)
Sets threadsCount.
ThreadAffinity & threadAffinity()
Manages processing machinery for market data received from feeds.