OnixS C++ ICE Binary Order Entry Handler 1.1.1
API Documentation
Loading...
Searching...
No Matches
ExternalThreadMode.cpp File Reference

Go to the source code of this file.

Functions

int main (int argc, char *argv[])

Function Documentation

◆ main()

int main ( int argc,
char * argv[] )

Definition at line 35 of file ExternalThreadMode.cpp.

36{
37 // `--help` to show options.
38 const AppConfiguration<
40 > cfg{"ExternalThreadMode", argc, argv};
41
42 try
43 {
45
46 auto settings = fillSettings(cfg);
47 const auto emulator = createEmulator(settings, cfg);
48
49 // Request Binary Order Gateway credentials from Binary Utility Service Gateway.
50 const auto bgwCredentials = receiveBgwCredentials(settings, cfg.host(), cfg.port());
51
52 Listener listener;
53 TcpStandardStack stack;
54
55 settings.threadingModel(ThreadingModel::External);
56
57 // A 'BGW' session.
58 const auto bgwSession= std::make_unique<BgwSession>(stack, settings, &listener, cfg.storage());
59 const auto connectTask = bgwSession->connectAsync(bgwCredentials);
60
61 while (!connectTask.is_ready())
62 stack.dispatchEvents();
63
64 bgwSession->send(Helper::createTraderLogonRequest(cfg.traderId(), cfg.traderPwd()));
65 Samples::wait(stack, listener.traderLoggedOn).get();
66
67 bgwSession->send(Helper::createOrder(cfg.traderId()));
68
69 std::clog << "\nPress <Ctrl+C> to disconnect the BGW session and terminate the application." << std::endl;
70
72 stack.dispatchEvents();
73
74 bgwSession->send(Helper::createTraderLogoutRequest(cfg.traderId()));
75
76 const auto disconnectTask = bgwSession->disconnectAsync("The BGW session is disconnected");
77
78 while (!disconnectTask.is_ready() || !stack.isQuiescent())
79 stack.dispatchEvents();
80 }
81 catch(const std::exception & ex)
82 {
83 std::cerr << "\nEXCEPTION: " << ex.what() << std::endl;
84 return 1;
85 }
86
87 return 0;
88}
A high-level wrapper over the TCP standard stack.
ONIXS_ICEBOE_FORCEINLINE void dispatchEvents() override
Processes events on a stack and performs the necessary handling.
ONIXS_ICEBOE_FORCEINLINE bool isQuiescent() const override
static MessageHolder< NewOrderRequest > createOrder(const std::string &traderId)
Definition Helpers.h:104
static MessageHolder< TraderLogoutRequest > createTraderLogoutRequest(const std::string &traderId)
Definition Helpers.h:95
static MessageHolder< TraderLogonRequest > createTraderLogonRequest(const std::string &traderId, const std::string &traderPwd)
Definition Helpers.h:77
std::promise< void > traderLoggedOn
Definition Listener.h:223
std::pair< std::unique_ptr< GatewayEmulatorThread< BusSessionGatewayListener > >, std::unique_ptr< GatewayEmulatorThread< GatewayListener > > > createEmulator(const SessionSettings &settings, const ConnectivityConfiguration &cfg, bool tcpDirect=false)
Definition Emulator.h:157
BgwCredentials receiveBgwCredentials(SessionSettings settings, std::string host, Port port)
Definition Listener.h:264
SessionSettings fillSettings(const LogonConfiguration &logonCfg, const ConnectivityConfiguration &connCfg, const SettingsConfiguration &settingsCfg)
Definition Settings.h:32
std::future< T > wait(Stack &stack, std::promise< T > &promise, std::chrono::seconds timeout=std::chrono::seconds{30})
Definition Listener.h:227
@ External
Session events are handled by rolling an event loop in a user thread.
static ONIXS_ICEBOE_FORCEINLINE bool interruptDetected() noexcept
Definition Signal.h:52
static void manageSignals() noexcept
Definition Signal.h:46