void ConnectionAgilent::HandleReceivedData ( const bs::error_code &  err, size_t  bytes_received, int  line  )

inlineprivate

Definition at line 131 of file agilentctrl.cc.

References Error(), Agilent::Data::fCurrentLimit, Agilent::Data::fCurrentMeasured, Agilent::Data::fVoltageMeasured, Agilent::Data::fVoltageSet, kBold, and str.

Referenced by StartRead().

    {

        // Do not schedule a new read if the connection failed.
        if (bytes_received==0 || err)
        {
            if (err==ba::error::eof)
                Warn("Connection closed by remote host (FTM).");

            // 107: Transport endpoint is not connected (bs::error_code(107, bs::system_category))
            // 125: Operation canceled
            if (err && err!=ba::error::eof &&                     // Connection closed by remote host
                err!=ba::error::basic_errors::not_connected &&    // Connection closed by remote host
                err!=ba::error::basic_errors::operation_aborted)  // Connection closed by us
            {
                ostringstream str;
                str << "Reading from " << URL() << ": " << err.message() << " (" << err << ")";// << endl;
                Error(str);
            }
            PostClose(err!=ba::error::basic_errors::operation_aborted);
            return;
        }


        if (fDebugRx)
        {
            Out() << kBold << "Received (" << bytes_received << ", " << fBuffer.size() << " bytes):" << endl;
            Out() << "-----\n" << string(ba::buffer_cast<const char*>(fBuffer.data()), bytes_received) << "-----\n";
        }

        istream is(&fBuffer);

        string str;
        getline(is, str, '\n');

        try
        {
            switch (line)
            {
            case 1:  Out() << "ID: " << str << endl; break;
            case 2:  fData.fVoltageSet      = stof(str); break;
            case 3:  fData.fVoltageMeasured = stof(str); break;
            case 4:  fData.fCurrentMeasured = stof(str); break;
            case 5:  fData.fCurrentLimit    = stof(str); break;
            default:
                return;
            }
        }
        catch (const exception &e)
        {
            Error("String conversion failed for '"+str+" ("+e.what()+")");

            // We need to synchronize the stream again
            PostClose(true);
            return;
        }

        if (line==5)
        {
            if (fIsVerbose)
            {
                Out() << "Voltage: " << fData.fVoltageMeasured << "V/" << fData.fVoltageSet   << "V\n";
                Out() << "Current: " << fData.fCurrentMeasured << "A/" << fData.fCurrentLimit << "A\n" << endl;
            }

            UpdateDim(fData);

            fLastReceived = Time();

            line = 0;

        }

        StartRead(line);
    }

Here is the call graph for this function:

Here is the caller graph for this function: