void ConnectionFAD::HandleReceivedData ( const bs::error_code &  error, size_t  bytes_received, int    )

inline

Definition at line 85 of file dclient5.cc.

References buffer, Error(), Connection::HandleReadTimeout(), and str.

    {
        // Do not schedule a new read if the connection failed.
        if (bytes_received==0 || error)
        {
            // 107: Transport endpoint is not connected
            // 125: Operation canceled
            if (error && error!=ba::error::basic_errors::not_connected)
            {
                ostringstream str;
                str << "Reading from " << URL() << ": " << error.message() << " (" << error << ")";// << endl;
                Error(str);
            }
            PostClose(error!=ba::error::basic_errors::operation_aborted);
            return;
        }

        string txt;

        if (bytes_received==2)
        {
            txt = string(fReadBuffer, bytes_received);
            //std::vector<char> buf(128);
            //bytes_transferred = sock.receive(boost::asio::buffer(d3));

            fMsg() << "Received b=" << bytes_received << ": " << (int)fReadBuffer[0] << " " << (int)txt[0] << " '" << txt << "' " << " " << error.message() << "  (" << error << ")" << endl;

            if (fReadBuffer[0]=='T')
            {
                // AsyncRead + Deadline
                // Do all manipulation to the buffer BEFORE this call!
                AsyncRead(ba::buffer(fReadBuffer+2, 21)/*,
                          &Connection::HandleReceivedData*/);
                AsyncWait(fInTimeout, 5000, &Connection::HandleReadTimeout);
            }
            else
            {
                // AsyncRead + Deadline
                // Do all manipulation to the buffer BEFORE this call!
                AsyncRead(ba::buffer(fReadBuffer+2, 35)/*,
                          &Connection::HandleReceivedData*/);
                AsyncWait(fInTimeout, 5000, &Connection::HandleReadTimeout);
            }
        }
        else
        {
            txt = string(fReadBuffer, bytes_received+2);
            const int s = atoi(fReadBuffer+35);
            if (s==9)
                Info("Requested time received: "+txt);
            else
                state = s;

            Out() << "Received b=" << bytes_received << ": " << (int)fReadBuffer[0] << " " << (int)txt[0] << " '" << txt << "' " << " " << error.message() << "  (" << error << ")" << endl;
            memset(fReadBuffer, 0, 100);

            // Do all manipulation to the buffer BEFORE this call!
            AsyncRead(ba::buffer(fReadBuffer, 2)/*,
                      &Connection::HandleReceivedData*/);


        }
    }

Here is the call graph for this function: