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

Subject: Re: [boost] [asio] Randomly having problems reading from the socket
From: 肖锋 (xfxyjwf_at_[hidden])
Date: 2011-05-05 02:15:09

On Mon, May 2, 2011 at 8:28 PM, Torben Wiggerich
<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.
>

 Your server program exits immediately on my Win7 machine with an exception
thrown from the line "tcp::acceptor acceptor(...)".
It gives the same error message as yours after I change the port from 8002
to 8003.
And the program works fine after I change the port to 18002.
So I guess the problem is the port you are using. Maybe it's reserved for
some other usage and you can not use these ports.

Regards,
Feng

>
> Kind regards
> Torben Wiggerich
>
> _______________________________________________
> Unsubscribe & other changes:
> http://lists.boost.org/mailman/listinfo.cgi/boost
>