104 toStr(str, handling);
211 , servingTimeLimit_(10)
221 , service_(other.service_)
222 , attempts_(other.attempts_)
223 , servingTimeLimit_(other.servingTimeLimit_)
246 group_.controlAssignment(
"TCP Recovery Service Instance", service_,
service);
268 group_.controlAssignment(
"TCP Recovery Attempt Quantity", attempts_, qty);
283 return servingTimeLimit_;
294 group_.controlAssignment(
"TCP Recovery Serving Time Limit", servingTimeLimit_,
servingTimeLimit);
303 group_.controlChange(
304 "TCP Recovery Session Settings", &TcpRecoverySessionSettings::assignNoControl, *
this, other
325 service_ = other.service_;
327 attempts_ = other.attempts_;
329 servingTimeLimit_ = other.servingTimeLimit_;
342 toStr(str, settings);
359 , tcpRecovery_(&
group())
367 , joinRecovery_(other.joinRecovery_)
368 , gapAndErrorHandling_(other.gapAndErrorHandling_)
369 , instrumentRecovery_(other.instrumentRecovery_)
370 , marketRecovery_(other.marketRecovery_)
371 , tcpRecovery_(other.tcpRecovery_)
385 return joinRecovery_;
392 group().controlAssignment(
"Join Recovery Strategy", joinRecovery_, recovery);
404 return gapAndErrorHandling_;
411 group().controlAssignment(
"Gap And Error Handling Strategy", gapAndErrorHandling_, handling);
421 return instrumentRecovery_;
427 group().controlAssignment(
"Instrument Recovery Strategy", instrumentRecovery_, recovery);
437 return marketRecovery_;
443 group().controlAssignment(
"Market Recovery Strategy", marketRecovery_, recovery);
485 tcpRecovery_.assignNoControl(other.tcpRecovery_);
490 joinRecovery_ = other.joinRecovery_;
492 gapAndErrorHandling_ = other.gapAndErrorHandling_;
494 instrumentRecovery_ = other.instrumentRecovery_;
496 marketRecovery_ = other.marketRecovery_;
521 toStr(str, settings);
649#if !defined(ONIXS_CMEMDH_NO_DEPRECATED)
#define ONIXS_CMEMDH_NAMESPACE_BEGIN
#define ONIXS_CMEMDH_LTWT
#define ONIXS_CMEMDH_LTWT_CLASS_DECL(name)
#define ONIXS_CMEMDH_EXPORTED_CLASS_DECL(typeName)
#define ONIXS_CMEMDH_NAMESPACE_END
#define ONIXS_CMEMDH_NULLPTR
#define ONIXS_CMEMDH_EXPORTED
SessionSettings & marketRecovery(MarketRecoveryOptions::Enum recovery)
Defines market recovery options.
SessionSettings & gapAndErrorHandling(GapAndErrorHandlingOptions::Enum handling)
SessionSettings & instrumentRecovery(InstrumentRecoveryOptions::Enum recovery)
Defines how instrument definitions are recovered.
void assignNoControlLegacy(const SessionSettings &other)
~SessionSettings()
Cleans everything up.
InstrumentRecoveryOptions::Enum instrumentRecovery() const
SessionSettings(const SessionSettings &other)
const SettingGroup & group() const
JoinRecoveryOptions::Enum joinRecovery() const
friend struct LegacyAssigner
const TcpRecoverySessionSettings & tcpRecovery() const
Set of TCP recovery settings.
SessionSettings & joinRecovery(JoinRecoveryOptions::Enum recovery)
SessionSettings(SettingChangeController *controller=nullptr)
Initializes parameters with default values.
void assignNoControl(const SessionSettings &other)
GapAndErrorHandlingOptions::Enum gapAndErrorHandling() const
MarketRecoveryOptions::Enum marketRecovery() const
TcpRecoverySessionSettings & tcpRecovery()
Editable set of TCP recovery settings.
SessionSettings & operator=(const SessionSettings &other)
friend class HandlerSettings
Base services for settings grouped by a certain criteria.
SettingGroup(SettingChangeController *controller=nullptr)
Collection of session settings related to TCP recovery.
~TcpRecoverySessionSettings()
Finalizes the instance.
TcpRecoverySessionSettings(const SettingGroup *group=nullptr)
TcpRecoverySessionSettings & operator=(const TcpRecoverySessionSettings &other)
TcpRecoveryService * service() const
UInt32 servingTimeLimit() const
TcpRecoverySessionSettings & service(TcpRecoveryService *service)
TcpRecoverySessionSettings & servingTimeLimit(UInt32 servingTimeLimit)
friend class SessionSettings
Lets grouping and value assignment control functioning.
TcpRecoverySessionSettings & attempts(UInt32 qty)
TcpRecoverySessionSettings(const TcpRecoverySessionSettings &other)
void setSessionToRecoverInstrumentsFast(SessionSettings &settings)
void setSessionToJoinInPreopening(SessionSettings &settings)
void setSessionToRecoverMboBooksOnly(SessionSettings &settings)
void setSessionToRecoverMbpBooksOnly(SessionSettings &settings)
void setSessionToNaturalRefresh(SessionSettings &settings)
void setSessionToFullRecoverUponRealtimeIssues(SessionSettings &settings)
void toStr(std::string &, BookState::Enum)
Serializes book state value into a string.
void setSessionToRecoverBothMboAndMbpBooks(SessionSettings &settings)
void setSessionToRecoverInstrumentsAccurately(SessionSettings &settings)
void setSessionToContinueRealtimeProcessingUponIssues(SessionSettings &settings)
void setSessionToLateJoin(SessionSettings &settings)
void setSessionToRecoverBooksUponRealtimeIssues(SessionSettings &settings)
void setSessionToAccurateLateJoin(SessionSettings &settings)
void setSessionToAccuratePreopening(SessionSettings &settings)
AccurateLateJoinMboSession()
AccurateLateJoinMbpSession()
AccurateLateJoinSession()
AccuratePreopeningMboSession()
AccuratePreopeningMbpSession()
AccuratePreopeningSession()
@ ContinueProcessing
Handler continues processing of real-time market data.
@ RecoverMarketState
Handler recovers market state from snapshots.
@ RecoverInstrumentsAndMarketState
Handler recovers instruments and market state afterwards.
Defines different ways of instrument definition recovery.
@ InstrumentsAndMarketState
Defines market state recovery options.