Boost logo

Boost :

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
>


Boost list run by bdawes at acm.org, gregod at cs.rpi.edu, cpdaniel at pacbell.net, john at johnmaddock.co.uk