doc/html/boost_asio/example/services/daytime_client.cpp

   1 //
   2 // daytime_client.cpp
   3 // ~~~~~~~~~~~~~~~~~~
   4 //
   5 // Copyright (c) 2003-2012 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 "logger.hpp"
  15 #include "stream_socket_service.hpp"
  16
  17 typedef boost::asio::basic_stream_socket<boost::asio::ip::tcp,
  18     services::stream_socket_service<boost::asio::ip::tcp> > debug_stream_socket;
  19
  20 char read_buffer[1024];
  21
  22 void read_handler(const boost::system::error_code& e,
  23     std::size_t bytes_transferred, debug_stream_socket* s)
  24 {
  25   if (!e)
  26   {
  27     std::cout.write(read_buffer, bytes_transferred);
  28
  29     s->async_read_some(boost::asio::buffer(read_buffer),
  30         boost::bind(read_handler, boost::asio::placeholders::error,
  31           boost::asio::placeholders::bytes_transferred, s));
  32   }
  33 }
  34
  35 void connect_handler(const boost::system::error_code& e, debug_stream_socket* s)
  36 {
  37   if (!e)
  38   {
  39     s->async_read_some(boost::asio::buffer(read_buffer),
  40         boost::bind(read_handler, boost::asio::placeholders::error,
  41           boost::asio::placeholders::bytes_transferred, s));
  42   }
  43   else
  44   {
  45     std::cerr << e.message() << std::endl;
  46   }
  47 }
  48
  49 int main(int argc, char* argv[])
  50 {
  51   try
  52   {
  53     if (argc != 2)
  54     {
  55       std::cerr << "Usage: daytime_client <host>" << std::endl;
  56       return 1;
  57     }
  58
  59     boost::asio::io_service io_service;
  60
  61     // Set the name of the file that all logger instances will use.
  62     services::logger logger(io_service, "");
  63     logger.use_file("log.txt");
  64
  65     // Resolve the address corresponding to the given host.
  66     boost::asio::ip::tcp::resolver resolver(io_service);
  67     boost::asio::ip::tcp::resolver::query query(argv[1], "daytime");
  68     boost::asio::ip::tcp::resolver::iterator iterator = resolver.resolve(query);
  69
  70     // Start an asynchronous connect.
  71     debug_stream_socket socket(io_service);
  72     boost::asio::async_connect(socket, iterator,
  73         boost::bind(connect_handler,
  74           boost::asio::placeholders::error, &socket));
  75
  76     // Run the io_service until all operations have finished.
  77     io_service.run();
  78   }
  79   catch (std::exception& e)
  80   {
  81     std::cerr << e.what() << std::endl;
  82   }
  83
  84   return 0;
  85 }