42 typedef std::set<CpuIndex> CpuIndexes;
58 void copyTo(CpuIndexes&)
const;
61 bool insert(CpuIndex index);
64 bool erase(CpuIndex index);
73 std::string toString()
const;
89 UInt32 spinBeforeIdleTime_;
91 UInt32 socketBufferSize_;
111 return threadAffinity_;
123 return threadAffinity_;
137 threadCount_ = value;
151 return dataWaitTime_;
157 dataWaitTime_ = value;
170 return spinBeforeIdleTime_;
176 spinBeforeIdleTime_ = value;
184 return socketBufferSize_;
190 socketBufferSize_ = value;
194 std::string toString()
const;
255 class FeedEngineImpl;
276 friend class FeedEngineImpl;
278 FeedEngineImpl* impl_;
virtual void onFeedEngineThreadIdle(const FeedEngine &, FeedEngineThreadIdle::Reason, UInt32 &)
size_t CpuIndex
Zero-based index of CPU.
Manages processing machinery for market data received from feeds.
UInt32 socketBufferSize() const
void dataWaitTime(UInt32 value)
Sets dataWaitTime.
void spinBeforeIdleTime(UInt32 value)
Sets redundancySpinTime.
UInt32 dataWaitTime() const
const ThreadAffinity & threadAffinity() const
ONIXS_EUROTLX_GTP_API_DECL(class, FeedEngine)
UInt32 threadCount() const
virtual void onFeedEngineThreadBegin(const FeedEngine &)
Represents set of CPU indices.
Identifies reasons feed engine threads becomes idle.
UInt32 spinBeforeIdleTime() const
virtual void onFeedEngineThreadEnd(const FeedEngine &)
Collection of settings affecting Feed Engine behavior.
void socketBufferSize(UInt32 value)
Sets udpSocketBufferSize.
ONIXS_EUROTLX_GTP_API std::ostream & operator<<(std::ostream &stream, const ServiceDescriptor &descriptor)
ThreadAffinity & threadAffinity()
void threadCount(UInt32 value)
Sets threadsCount.