ceph/src/boost/libs/asio/example/cpp03/serialization/client.cpp

   1 //
   2 // client.cpp
   3 // ~~~~~~~~~~
   4 //
   5 // Copyright (c) 2003-2017 Christopher M. Kohlhoff (chris at kohlhoff dot com)
   6 //
   7 // Distributed under the Boost Software License, Version 1.0. (See accompanying
   8 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
   9 //
  10
  11 #include <boost/asio.hpp>
  12 #include <boost/bind.hpp>
  13 #include <iostream>
  14 #include <vector>
  15 #include "connection.hpp" // Must come before boost/serialization headers.
  16 #include <boost/serialization/vector.hpp>
  17 #include "stock.hpp"
  18
  19 namespace s11n_example {
  20
  21 /// Downloads stock quote information from a server.
  22 class client
  23 {
  24 public:
  25   /// Constructor starts the asynchronous connect operation.
  26   client(boost::asio::io_context& io_context,
  27       const std::string& host, const std::string& service)
  28     : connection_(io_context)
  29   {
  30     // Resolve the host name into an IP address.
  31     boost::asio::ip::tcp::resolver resolver(io_context);
  32     boost::asio::ip::tcp::resolver::query query(host, service);
  33     boost::asio::ip::tcp::resolver::iterator endpoint_iterator =
  34       resolver.resolve(query);
  35
  36     // Start an asynchronous connect operation.
  37     boost::asio::async_connect(connection_.socket(), endpoint_iterator,
  38         boost::bind(&client::handle_connect, this,
  39           boost::asio::placeholders::error));
  40   }
  41
  42   /// Handle completion of a connect operation.
  43   void handle_connect(const boost::system::error_code& e)
  44   {
  45     if (!e)
  46     {
  47       // Successfully established connection. Start operation to read the list
  48       // of stocks. The connection::async_read() function will automatically
  49       // decode the data that is read from the underlying socket.
  50       connection_.async_read(stocks_,
  51           boost::bind(&client::handle_read, this,
  52             boost::asio::placeholders::error));
  53     }
  54     else
  55     {
  56       // An error occurred. Log it and return. Since we are not starting a new
  57       // operation the io_context will run out of work to do and the client will
  58       // exit.
  59       std::cerr << e.message() << std::endl;
  60     }
  61   }
  62
  63   /// Handle completion of a read operation.
  64   void handle_read(const boost::system::error_code& e)
  65   {
  66     if (!e)
  67     {
  68       // Print out the data that was received.
  69       for (std::size_t i = 0; i < stocks_.size(); ++i)
  70       {
  71         std::cout << "Stock number " << i << "\n";
  72         std::cout << "  code: " << stocks_[i].code << "\n";
  73         std::cout << "  name: " << stocks_[i].name << "\n";
  74         std::cout << "  open_price: " << stocks_[i].open_price << "\n";
  75         std::cout << "  high_price: " << stocks_[i].high_price << "\n";
  76         std::cout << "  low_price: " << stocks_[i].low_price << "\n";
  77         std::cout << "  last_price: " << stocks_[i].last_price << "\n";
  78         std::cout << "  buy_price: " << stocks_[i].buy_price << "\n";
  79         std::cout << "  buy_quantity: " << stocks_[i].buy_quantity << "\n";
  80         std::cout << "  sell_price: " << stocks_[i].sell_price << "\n";
  81         std::cout << "  sell_quantity: " << stocks_[i].sell_quantity << "\n";
  82       }
  83     }
  84     else
  85     {
  86       // An error occurred.
  87       std::cerr << e.message() << std::endl;
  88     }
  89
  90     // Since we are not starting a new operation the io_context will run out of
  91     // work to do and the client will exit.
  92   }
  93
  94 private:
  95   /// The connection to the server.
  96   connection connection_;
  97
  98   /// The data received from the server.
  99   std::vector<stock> stocks_;
 100 };
 101
 102 } // namespace s11n_example
 103
 104 int main(int argc, char* argv[])
 105 {
 106   try
 107   {
 108     // Check command line arguments.
 109     if (argc != 3)
 110     {
 111       std::cerr << "Usage: client <host> <port>" << std::endl;
 112       return 1;
 113     }
 114
 115     boost::asio::io_context io_context;
 116     s11n_example::client client(io_context, argv[1], argv[2]);
 117     io_context.run();
 118   }
 119   catch (std::exception& e)
 120   {
 121     std::cerr << e.what() << std::endl;
 122   }
 123
 124   return 0;
 125 }