38 typedef std::set<CpuIndex> CpuIndexes;
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;
#define ONIXS_ESPEED_ITCH_API_DECL(typeKind, typeName)
#define ONIXS_ESPEED_ITCH_NAMESPACE_BEGIN
#define ONIXS_ESPEED_ITCH_NAMESPACE_END
ONIXS_ESPEED_ITCH_API std::ostream & operator<<(std::ostream &stream, const FeedEngineSettings &settings)
ONIXS_ESPEED_ITCH_NAMESPACE_BEGIN typedef size_t CpuIndex
Zero-based index of CPU.
Collection of settings affecting Feed Engine behavior.
std::string toString() const
Returns the string representation.
void threadCount(UInt32 value)
Sets threadsCount.
UInt32 spinBeforeIdleTime() const
FeedEngineSettings()
Initializes options with default values.
ThreadAffinity & threadAffinity()
const ThreadAffinity & threadAffinity() const
void socketBufferSize(UInt32 value)
Sets udpSocketBufferSize.
~FeedEngineSettings()
Cleans everything up.
void spinBeforeIdleTime(UInt32 value)
Sets redundancySpinTime.
UInt32 dataWaitTime() const
UInt32 threadCount() const
UInt32 socketBufferSize() const
void dataWaitTime(UInt32 value)
Sets dataWaitTime.
Manages processing machinery for market data received from feeds.
const FeedEngineSettings & settings() const
Settings used define behavior of given instance.
friend class FeedEngineImpl
~FeedEngine()
Destructs given instance.
FeedEngine(const FeedEngineSettings &, FeedEngineListener *=ONIXS_ESPEED_ITCH_NULLPTR)
Initializes engine with given configuration.
Represents set of CPU indices.
ThreadAffinity()
Initializes empty set.
std::string toString() const
Returns the string representation.
ThreadAffinity(const ThreadAffinity &)
Initializes as copy of other set.
bool empty() const
Indicates whether is empty.
~ThreadAffinity()
Utilizes all the resources.
bool erase(CpuIndex index)
Removes CPU index from the set.
void clear()
Makes set empty.
bool insert(CpuIndex index)
Adds CPU index into set.
void copyTo(CpuIndexes &) const
Copies set into another set.
virtual void onFeedEngineThreadBegin(const FeedEngine &)
virtual void onFeedEngineThreadEnd(const FeedEngine &)
virtual void onFeedEngineThreadIdle(const FeedEngine &, FeedEngineThreadIdle::Reason, UInt32 &)
Identifies reasons feed engine threads becomes idle.