Re: [boost] [asio] Randomly having problems reading from the socket

Subject: Re: [boost] [asio] Randomly having problems reading from the socket
From: Torben Wiggerich (torben.wiggerich_at_[hidden])
Date: 2011-05-04 04:59:40

Hi Jinqiang,

thanks for your answer.

What I forgot to mention was that I'm using the localhost for the socket 
connection. So there shouldn't be any errors caused by the physical 
network, I guess.

I changed the code to evaluate the 'ignored error'. But an error never 
occurs there . It just falls asleep for 5 seconds.

Kind regards
Torben

>
>
> -------- Original-Nachricht --------
> Betreff: 	Re: [boost] [asio] Randomly having problems reading from the 
> socket
> Datum: 	Tue, 3 May 2011 08:57:27 +1000
> Von: 	Jinqiang Zhang <jasonzha_at_[hidden]> <mailto:jasonzha_at_[hidden]>
> Antwort an: 	boost_at_[hidden] <mailto:boost_at_[hidden]>
> An: 	boost_at_[hidden] <mailto:boost_at_[hidden]>
>
>
>
> Hi Torben,
>
> Firstly I claim I always use async way of asio, so I don't get the same
> problem as yours. But for your code, I might suggest, because you are
> transferring big chunk of data, if network condition is bad, you might get
> some error, so maybe you want to see the 'error' while not use 'ignored
> error' ?
>
> cheers,
> Jinqiang
>
> On Mon, May 2, 2011 at 10:28 PM, Torben Wiggerich<torben.wiggerich_at_[hidden]
> >  <mailto:torben.wiggerich_at_[hidden]>  wrote:
>
> >  Hi all,
> >
> >  I have some problems using the boost.asio.read for a TCP-socket. So far it
> >  works fine, but it randomly stops the transfer for at least 5 seconds.
> >  To resolve the error I used a simple synchronous server and client from the
> >  boost examples and modified it too send a larger amount of data. (307400
> >  Bytes; this size comes from the program I'm trying to get run). On the
> >  client side I also changed the reading from the socket to read the complete
> >  data with boost.asio.read and transfer_all as argument.
> >
> >  Both, server and client, measure the time for sending and reading to the
> >  socket and will give an error if it needs more than 1 second.
> >
> >  Here is the sourcecode for the server:
> >
> >  #include<iostream>
> >  #include<string>
> >  #include<boost/asio.hpp>
> >  #include<boost/date_time/posix_time/posix_time.hpp>
> >
> >  using boost::asio::ip::tcp;
> >  using namespace boost::posix_time;
> >
> >  int main()
> >  {
> >     try
> >     {
> >         boost::asio::io_service io_service;
> >
> >         tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 8002));
> >
> >         tcp::socket socket(io_service);
> >         acceptor.accept(socket);
> >
> >         unsigned char * array = new unsigned char[307400];
> >
> >         for (;;)
> >         {
> >             boost::system::error_code ignored_error;
> >
> >             ptime startTime = microsec_clock::universal_time();
> >
> >             boost::asio::write(socket, boost::asio::buffer( array, 307400 ),
> >                 boost::asio::transfer_all(), ignored_error);
> >
> >             time_duration neededTime = microsec_clock::universal_time() -
> >  startTime;
> >
> >             if ( neededTime.total_milliseconds()>  1000 ) {
> >                 std::cout<<  "ERROR needed too much time: "<<
> >  neededTime.total_milliseconds()<<  "ms"<<  std::endl;
> >             }
> >         }
> >     }
> >     catch (std::exception&  e)
> >     {
> >         std::cerr<<  e.what()<<  std::endl;
> >     }
> >
> >     return 0;
> >  }
> >
> >
> >  My client sourcecode:
> >
> >  #include<iostream>
> >  #include<boost/array.hpp>
> >  #include<boost/asio.hpp>
> >  #include<boost/date_time/posix_time/posix_time.hpp>
> >
> >  using boost::asio::ip::tcp;
> >  using namespace boost::posix_time;
> >
> >  int main(int argc, char* argv[])
> >  {
> >   try
> >   {
> >     if (argc != 2)
> >     {
> >       std::cerr<<  "Usage: client<host>"<<  std::endl;
> >       return 1;
> >     }
> >
> >     boost::asio::io_service io_service;
> >     boost::asio::ip::tcp::endpoint endpoint(
> >  boost::asio::ip::address::from_string( argv[1] ), 8002 );
> >
> >     tcp::socket socket(io_service);
> >     boost::system::error_code error = boost::asio::error::host_not_found;
> >     socket.connect( endpoint, error );
> >     if (error)
> >       throw boost::system::system_error(error);
> >
> >     int counter = 0;
> >     unsigned char* array = new unsigned char[307400];
> >     for (;;)
> >     {
> >       boost::system::error_code error;
> >
> >       ptime startTime = microsec_clock::universal_time();
> >       size_t len = boost::asio::read( socket,
> >                                      boost::asio::buffer( array, 307400 ),
> >                                      boost::asio::transfer_all(),
> >                                      error );
> >       time_duration neededTime = microsec_clock::universal_time() -
> >  startTime;
> >
> >       if ( error ) {
> >         printf( "body read error %s\n", error.message().c_str() );
> >       }
> >
> >       if ( counter % 5000 == 0 ) {
> >         std::cout<<  "passed: "<<  counter<<  "\r";
> >       }
> >       ++counter;
> >
> >       if ( neededTime.total_milliseconds()>  1000 ) {
> >         std::cout<<  "ERROR needed too much time: "<<
> >  neededTime.total_milliseconds()<<  "ms"<<  std::endl;
> >       }
> >     }
> >   }
> >   catch (std::exception&  e)
> >   {
> >     std::cerr<<  e.what()<<  std::endl;
> >   }
> >
> >   return 0;
> >  }
> >
> >  To reproduce the error just let it run for a while. It can take up to 30
> >  minutes or even more...
> >  After a while it will produce the line: "ERROR needed too much time:
> >  5007ms". Maybe with slightly different times, but all around 5 seconds.
> >  I tested it on different machines with Windows Vista and Seven.
> >
> >  So am I'm doing sth. wrong? Is the reading from the socket correct?
> >
> >  I'm using boost version 1.44.
> >
> >  Kind regards
> >  Torben Wiggerich
> >
> >  _______________________________________________
> >  Unsubscribe&  other changes:
> >  http://lists.boost.org/mailman/listinfo.cgi/boost
> >
> _______________________________________________
> Unsubscribe&  other changes:http://lists.boost.org/mailman/listinfo.cgi/boost
>
>
> -----
> eMail ist virenfrei.
> Von AVG uberpruft -www.avg.de  <http://www.avg.de>
> Version: 10.0.1209 / Virendatenbank: 1500/3610 - Ausgabedatum: 02.05.2011
>