52 std::string feedANetworkInterfaces_;
53 std::string feedBNetworkInterfaces_;
78 , heartbeatInterval_(heartbeat)
96 other.heartbeatInterval_)
97 , feedANetworkInterfaces_(
98 other.feedANetworkInterfaces_)
99 , feedBNetworkInterfaces_(
100 other.feedBNetworkInterfaces_)
129 other.heartbeatInterval_;
131 feedANetworkInterfaces_ =
132 other.feedANetworkInterfaces_;
134 feedBNetworkInterfaces_ =
135 other.feedBNetworkInterfaces_;
168 return heartbeatInterval_;
179 "Heartbeat Interval",
198 return feedANetworkInterfaces_;
206 const std::string& interfaces)
211 "Feed A Network Interfaces",
212 feedANetworkInterfaces_,
230 return feedBNetworkInterfaces_;
238 const std::string& interfaces)
243 "Feed B Network Interfaces",
244 feedBNetworkInterfaces_,
286ONIXS_CONFLATEDUDP_EXPORTED
331 Base::assignNoControl(other);
345 FeedAWithFailoverToFeedB,
353 :
Base(static_cast<const
Base&>(other))
371 "Multicast Recovery Feed Settings",
372 &MulticastRecoveryFeedSettings::assignNoControl,
382ONIXS_CONFLATEDUDP_EXPORTED
397 toStr(str, settings);
424 UInt32 connectionAttempts_;
425 UInt32 connectionTimeout_;
432 Base::assignNoControl(other);
434 connectionAttempts_ =
435 other.connectionAttempts_;
438 other.connectionTimeout_;
457 , connectionAttempts_(3)
458 , connectionTimeout_(500)
472 , connectionAttempts_(
473 other.connectionAttempts_)
474 , connectionTimeout_(
475 other.connectionTimeout_)
494 return connectionAttempts_;
507 "Connection Attempts",
523 return connectionTimeout_;
538 "Connection Timeout",
581 "TCP Recovery Feed Settings",
582 &TcpRecoveryFeedSettings::assignNoControl,
592ONIXS_CONFLATEDUDP_EXPORTED
606 toStr(str, settings);
650ONIXS_CONFLATEDUDP_EXPORTED
690 UInt32 outOfOrderPacketMaxInterval_;
691 UInt32 lostPacketWaitTime_;
697 Base::assignNoControl(other);
699 outOfOrderPacketMaxInterval_ =
700 other.outOfOrderPacketMaxInterval_;
702 lostPacketWaitTime_ =
703 other.lostPacketWaitTime_;
716 BothFeedsWithArbitrage,
718 , outOfOrderPacketMaxInterval_(3)
719 , lostPacketWaitTime_(100000)
732 , outOfOrderPacketMaxInterval_(
733 other.outOfOrderPacketMaxInterval_)
734 , lostPacketWaitTime_(
735 other.lostPacketWaitTime_)
775 return outOfOrderPacketMaxInterval_;
787 "Out Of Order Packet Max Interval",
788 outOfOrderPacketMaxInterval_,
817 return lostPacketWaitTime_;
829 "Lost Packet Wait Time",
845 "Realtime Feed Settings",
846 &RealtimeFeedSettings::assignNoControl,
856ONIXS_CONFLATEDUDP_EXPORTED
870 toStr(str, settings);
888 std::string connectivityConfigurationFile_;
918 connectivityConfigurationFile_ =
919 other.connectivityConfigurationFile_;
922 other.packetMaxSize_;
926 other.incrementalFeeds_);
930 other.instrumentFeeds_);
934 other.snapshotFeeds_);
938 other.mboSnapshotFeeds_);
942 other.historicalFeeds_);
944 engine_ = other.engine_;
950 assignFeedAInterfaces(
951 const std::string& interfaces)
954 feedANetworkInterfaces_ =
957 feedANetworkInterfaces_ =
960 feedANetworkInterfaces_ =
963 feedANetworkInterfaces_ =
966 feedANetworkInterfaces_ =
974 assignFeedBInterfaces(
975 const std::string& interfaces)
978 feedBNetworkInterfaces_ =
981 feedBNetworkInterfaces_ =
984 feedBNetworkInterfaces_ =
987 feedBNetworkInterfaces_ =
990 feedBNetworkInterfaces_ =
1000 : SettingGroup(controller)
1001 , packetMaxSize_(1420)
1002 , incrementalFeeds_(&group())
1003 , instrumentFeeds_(&group())
1004 , snapshotFeeds_(&group())
1005 , mboSnapshotFeeds_(&group())
1006 , historicalFeeds_(&group())
1016 , connectivityConfigurationFile_(
1017 other.connectivityConfigurationFile_)
1019 other.packetMaxSize_)
1020 , incrementalFeeds_(
1021 other.incrementalFeeds_)
1023 other.instrumentFeeds_)
1025 other.snapshotFeeds_)
1026 , mboSnapshotFeeds_(
1027 other.mboSnapshotFeeds_)
1029 other.historicalFeeds_)
1040 return connectivityConfigurationFile_;
1046 const std::string& configurationFile)
1051 "Connectivity Configuration File",
1052 connectivityConfigurationFile_,
1062 const std::string& interfaces)
1067 "Feed A Network Interfaces for All Feeds",
1068 &FeedSettings::assignFeedAInterfaces,
1079 const std::string& interfaces)
1084 "Feed B Network Interfaces for All Feeds",
1085 &FeedSettings::assignFeedBInterfaces,
1096 return packetMaxSize_;
1118 return incrementalFeeds_;
1125 return incrementalFeeds_;
1133 return instrumentFeeds_;
1140 return instrumentFeeds_;
1148 return snapshotFeeds_;
1155 return snapshotFeeds_;
1163 return mboSnapshotFeeds_;
1170 return mboSnapshotFeeds_;
1178 return historicalFeeds_;
1185 return historicalFeeds_;
1219 &FeedSettings::assignNoControl,
1229ONIXS_CONFLATEDUDP_EXPORTED
1243 toStr(str, settings);
#define ONIXS_CONFLATEDUDP_LTWT_STRUCT
#define ONIXS_CONFLATEDUDP_LTWT_CLASS
#define ONIXS_CONFLATEDUDP_EXPORTED_CLASS_DECL(typeName)
#define ONIXS_CONFLATEDUDP_NAMESPACE_END
#define ONIXS_CONFLATEDUDP_LTWT_CLASS_DECL(name)
#define ONIXS_CONFLATEDUDP_NAMESPACE_BEGIN
void feedANetworkInterfaces(const std::string &interfaces)
void assignNoControl(const FeedSettingsBase &other)
RecoveryFeedLayout::Enum layout() const
const SettingGroup & group() const
const std::string & feedANetworkInterfaces() const
void layout(Layout value)
Defines feed layout for recovery feed group.
const std::string & feedBNetworkInterfaces() const
UInt32 heartbeatInterval() const
friend class FeedSettings
void heartbeatInterval(UInt32 interval)
Specifies maximal time interval between two packets.
FeedSettingsBase(const SettingGroup *group, Layout layout, UInt32 heartbeat)
FeedSettingsBase(const FeedSettingsBase &other)
void feedBNetworkInterfaces(const std::string &interfaces)
void feedANetworkInterfaces(const std::string &interfaces)
RealtimeFeedSettings & incrementalFeeds()
The settings related to incremental feeds.
NetFeedEngine * engine() const
FeedSettings(const FeedSettings &other)
void connectivityConfigurationFile(const std::string &configurationFile)
Sets path to the connectivity configuration file.
void packetMaxSize(PacketSize value)
Max size for network packet transmitted by MDP.
const MulticastRecoveryFeedSettings & instrumentFeeds() const
The settings related to instrument feeds.
const std::string & connectivityConfigurationFile() const
Path to the connectivity configuration file.
TcpRecoveryFeedSettings & historicalFeeds()
The settings related to historical (TCP Recovery) feeds.
PacketSize packetMaxSize() const
void engine(NetFeedEngine *engine)
Defines instance of the Feed Engine to be used by the Handler.
const MulticastRecoveryFeedSettings & snapshotFeeds() const
The settings related to snapshot feeds.
const RealtimeFeedSettings & incrementalFeeds() const
The settings related to incremental feeds.
MulticastRecoveryFeedSettings & instrumentFeeds()
The settings related to instrument feeds.
FeedSettings(SettingAssignController *controller=NULL)
Initializes the instance with the default values.
friend class HandlerSettings
const MulticastRecoveryFeedSettings & mboSnapshotFeeds() const
The settings related to snapshot feeds.
void feedBNetworkInterfaces(const std::string &interfaces)
MulticastRecoveryFeedSettings & snapshotFeeds()
The settings related to snapshot feeds.
MulticastRecoveryFeedSettings & mboSnapshotFeeds()
The settings related to snapshot feeds.
const TcpRecoveryFeedSettings & historicalFeeds() const
The settings related to historical (TCP recovery) feeds.
Collection of parameters affecting recovery feeds behavior.
MulticastRecoveryFeedSettings(const SettingGroup *group=NULL)
~MulticastRecoveryFeedSettings()
Finalizes the instance.
friend class FeedSettings
MulticastRecoveryFeedSettings(const MulticastRecoveryFeedSettings &other)
Initializes the instance as a copy of the other one.
Collection of parameters affecting real-time feeds behavior.
void outOfOrderPacketMaxInterval(UInt32 intervalLength)
RealtimeFeedSettings(const RealtimeFeedSettings &other)
~RealtimeFeedSettings()
Finalizes the instance.
RealtimeFeedSettings(const SettingGroup *group=NULL)
void lostPacketWaitTime(UInt32 waitTime)
friend class FeedSettings
UInt32 lostPacketWaitTime() const
UInt32 outOfOrderPacketMaxInterval() const
Base services for settings grouped by a certain criteria.
void controlAssignment(const Char *description, Assignee &assignee, Value value) const
Collection of parameters affecting recovery feeds behavior.
UInt32 connectionAttempts() const
~TcpRecoveryFeedSettings()
Finalizes the instance.
UInt32 connectionTimeout() const
UInt32 sendTimeout() const
void connectionAttempts(UInt32 attemptQty)
void sendTimeout(UInt32 sendTimeout)
friend class FeedSettings
TcpRecoveryFeedSettings(const TcpRecoveryFeedSettings &other)
TcpRecoveryFeedSettings(const SettingGroup *group=NULL)
void connectionTimeout(UInt32 connectionTimeout)
ONIXS_CONFLATEDUDP_EXPORTED void toStr(std::string &, BookState::Enum)
Serializes book state value into a string.
UInt16 PacketSize
Integral type for measuring packets.
@ FeedBOnly
Indicates only feed B is used as source for market data.
@ FeedBWithFailoverToFeedA
@ BothFeedsWithArbitrage
Handler arbitrates between both feeds A and B.
@ FeedAWithFailoverToFeedB
@ FeedAOnly
Indicates only feed A is used as source for market data.
@ FeedBOnly
Indicates only feed B is used as source for market data.
@ FeedBWithFailoverToFeedA
@ FeedAWithFailoverToFeedB
@ FeedAOnly
Indicates only feed A is used as source for market data.