diff options
Diffstat (limited to 'client/cmixclient.cpp')
| -rw-r--r-- | client/cmixclient.cpp | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/client/cmixclient.cpp b/client/cmixclient.cpp new file mode 100644 index 0000000..e3f5ac4 --- /dev/null +++ b/client/cmixclient.cpp @@ -0,0 +1,42 @@ + +#include "cmixclient.hpp" + +void CMixClient::initialized() { + BOOST_LOG_TRIVIAL(trace) << "Client connections were made"; + for(auto&& connection : network_connections) { + cmix_proto::Bye bye; + connection.send(bye); + } + io_service.stop(); +} + +void CMixClient::initialize_connections() { + network_connections.reserve(network_details.size()); + + int i = network_details.size(); + auto handler = [this, i]() mutable { + cmix_proto::ImAClient imaclient; + network_connections.at(network_details.size() - i).send(imaclient); + + if(--i == 0) { + initialized(); + } + }; + + for(auto&& details : network_details) { + network_connections.emplace_back(boost::asio::ip::tcp::socket(io_service)); + network_connections.back().async_connect(details.host, details.port, handler); + } +} + +CMixClient::CMixClient(std::vector<NodeDetails> details) +: io_service() +, network_details(details) +, network_connections() +{ + initialize_connections(); +} + +void CMixClient::run() { + io_service.run(); +} |
