void ConnectionLidar::HandleRead ( const boost::system::error_code &  err, size_t  bytes_received  )

inlineprotected

Definition at line 47 of file magiclidar.cc.

References data, Error(), MagicLidar::DimLidar::fAz, MagicLidar::DimLidar::fCloudBaseHeight, MagicLidar::DimLidar::fT12, MagicLidar::DimLidar::fT3, MagicLidar::DimLidar::fT6, MagicLidar::DimLidar::fT9, MagicLidar::DimLidar::fZd, Time::GetAsStr(), and str.

Referenced by StartReadReport().

    {
        // 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.");

            // 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;
        }

        fLastReception = Time();

        const string str(fArray.data(), bytes_received);
        memset(fArray.data(), 0, fArray.size());

        if (fIsVerbose)
            Out() << str << endl;

        bool isheader = true;

        DimLidar data;

        int hh=0, mm=0, ss=0, y=0, m=0, d=0;

        bool keepalive = false;
        bool failed = false;

        stringstream is(str);
        string line;
        while (getline(is, line))
        {
            if (line.size()==1 && line[0]==13)
            {
                isheader = false;
                continue;
            }

            if (isheader)
            {
                const size_t p = line.find_first_of(": ");
                if (p==string::npos)
                    continue;

                std::transform(line.begin(), line.end(), line.begin(), (int(&)(int))std::tolower);

                const string key = line.substr(0, p);
                const string val = line.substr(p+2);

                if (key=="connection" && val=="keep-alive")
                    keepalive = true;
            }
            else
            {
                try
                {
                    if (line.substr(0, 2)=="ZD")
                        data.fZd = stoi(line.substr(2));
                    if (line.substr(0, 2)=="AZ")
                        data.fAz = stof(line.substr(2));

                    //if (line.substr(0, 3)=="PBL")
                    //    data.fPBL = stof(line.substr(3));
                    //if (line.substr(0, 3)=="CHE")
                    //    data.fCHE = stof(line.substr(3));
                    //if (line.substr(0, 3)=="COT")
                    //    data.fCOT = stof(line.substr(3));

                    if (line.substr(0, 2)=="T3")
                        data.fT3 = stof(line.substr(2));
                    if (line.substr(0, 2)=="T6")
                        data.fT6 = stof(line.substr(2));
                    if (line.substr(0, 2)=="T9")
                        data.fT9 = stof(line.substr(2));
                    if (line.substr(0, 3)=="T12")
                        data.fT12 = stof(line.substr(3));

                    if (line.substr(0, 3)=="CLB")
                        data.fCloudBaseHeight = stof(line.substr(3));

                    if (line.substr(0, 4)=="HOUR")
                        hh = stoi(line.substr(4));
                    if (line.substr(0, 6)=="MINUTS")
                        mm = stoi(line.substr(6));
                    if (line.substr(0, 7)=="SECONDS")
                        ss = stoi(line.substr(7));

                    if (line.substr(0, 4)=="YEAR")
                        y = stoi(line.substr(4));
                    if (line.substr(0, 5)=="MONTH")
                        m = stoi(line.substr(5));
                    if (line.substr(0, 3)=="DAY")
                        d = stoi(line.substr(3));
                }
                catch (const exception &e)
                {
                    Warn("Conversion of received data failed");
                    failed = true;
                    break;
                }
            }
        }

        if (!keepalive)
            PostClose(false);

        if (failed)
            return;

        try
        {
            const Time tm = Time(y>999 ? y : 2000+y, m, d, hh, mm, ss);
            if (tm==fLastReport)
                return;

            fLastReport = tm;

            if (data.fT3==0 && data.fT6==0 && data.fT9==0 && data.fT12==0)
                return;

            ostringstream msg;
            msg << tm.GetAsStr("%H:%M:%S") << ":"
                //<< " PBL=" << data.fPBL
                //<< " CHE=" << data.fCHE
                //<< " COT=" << data.fCOT
                << " T3-12=" << data.fT3
                << "/" << data.fT6
                << "/" << data.fT9
                << "/" << data.fT12
                << " H="  << data.fCloudBaseHeight/1000 << "km"
                << " Zd="  << data.fZd  << "°"
                << " Az="  << data.fAz  << "°";
            Message(msg);

            UpdateLidar(tm, data);
        }
        catch (const exception &e)
        {
            Warn("Corrupted time received.");
        }

    }

Here is the call graph for this function:

Here is the caller graph for this function: