void DataLogger::Report ( const EventImp &  evt, SubscriptionType &  sub  )

private

Reporting method for the services info received.

Get SunRise. Copied from drivectrl.cc Used to know when to close and reopen fileswrite infos to log files.

Parameters

I	The current DimInfo
sub	The dataLogger's subscription corresponding to this DimInfo

Definition at line 1319 of file datalogger.cc.

References CheckForOfstreamError(), CompileFileNameWithPath(), MessageImp::Debug(), MessageImp::Error(), SubscriptionType::fConv, fCurrentDay, fQuality, StateMachineImp::GetCurrentState(), EventImp::GetData(), EventImp::GetFormat(), EventImp::GetName(), Time::GetNextSunRise(), EventImp::GetQoS(), EventImp::GetSize(), EventImp::GetTime(), GoToReady(), MessageImp::Info(), MessageImp::kAlarm, MessageImp::kInfo, MessageImp::kMessage, kSM_BadFolder, StateMachineImp::kSM_Ready, lastFlush, SubscriptionType::lastReceivedEvent, OpenTextFile(), MessageImp::Out(), RemoveService(), SubscriptionType::server, SubscriptionType::service, StateMachineDim::SetCurrentState(), str, updateSubscriptionList(), and MessageImp::Write().

Referenced by infoCallback().

{
    const string fmt(evt.GetFormat());

    const bool isItaReport = fmt!="C";

    if (!fNightlyLogFile.is_open())
        return;

    if (fDebugIsOn && string(evt.GetName())!="DATA_LOGGER/MESSAGE")
    {
        ostringstream str;
        str << "Logging " << evt.GetName() << " [" << evt.GetFormat() << "] (" << evt.GetSize() << ")";
        Debug(str);
    }

    //
    // Check whether we should close and reopen daily text files or not
    // calculate time "centered" around noon instead of midnight
    // if number of days has changed, then files should be closed and reopenned.
    const Time timeNow;
//    const Time nowMinusTwelve = timeNow-boost::posix_time::hours(12);
//    int newDayNumber = (int)(nowMinusTwelve.Mjd());

    //also check if we should flush the nightly files
    if (lastFlush < timeNow-boost::posix_time::minutes(1))
    {
        lastFlush = timeNow;
        SubscriptionsListType::iterator x;
        map<string, SubscriptionType>::iterator y;
        for (x=fServiceSubscriptions.begin(); x != fServiceSubscriptions.end(); x++)
        {//find current service is subscriptions
            for (y=x->second.begin(); y!=x->second.end();y++)
                if (y->second.nightlyFile.IsOpen())
                {
                    y->second.nightlyFile.Flush();
                }
        }
        if (fDebugIsOn)
            Debug("Just flushed nightly fits files to the disk");
    }
    //check if we should close and reopen the nightly files
    if (timeNow > fCurrentDay)//GetSunRise(fCurrentDay)+boost::posix_time::minutes(30)) //if we went past 30 minutes after sunrise
    {
        //set the next closing time. If we are here, we have passed 30 minutes after sunrise.
        fCurrentDay = timeNow.GetNextSunRise();//GetSunRise(timeNow-boost::posix_time::minutes(30))+boost::posix_time::minutes(30);
        //crawl through the subcriptions and close any open nightly file
        SubscriptionsListType::iterator x;
        map<string, SubscriptionType>::iterator y;
        for (x=fServiceSubscriptions.begin(); x != fServiceSubscriptions.end(); x++)
        {//find current service is subscriptions
            for (y=x->second.begin(); y!=x->second.end();y++)
            {
                if (y->second.nightlyFile.IsOpen())
                {
                    y->second.nightlyFile.Close();
                }
                y->second.increment = 0;
            }
        }

        if (fDebugIsOn)
            Debug("Day have changed! Closing and reopening nightly files");

        fNightlyLogFile << endl;
        fNightlyLogFile.close();
//        fNightlyReportFile.close();

        Info("Closed: "+fFullNightlyLogFileName);
//        Info("Closed: "+fFullNightlyReportFileName);

        fFullNightlyLogFileName = CompileFileNameWithPath(fFilePath, "", "log");
        if (!OpenTextFile(fNightlyLogFile, fFullNightlyLogFileName))
        {
            GoToReady();
            SetCurrentState(kSM_BadFolder, "Report");
            return;
        }
        fNightlyLogFile << endl;

//        fFullNightlyReportFileName = CompileFileNameWithPath(fFilePath, "", "rep");
//        if (!OpenTextFile(fNightlyReportFile, fFullNightlyReportFileName))
//        {
//            GoToReady();
//            SetCurrentState(kSM_BadFolder, "Report");
//            return;
//        }
    }
    //create the converter for that service
    if (!sub.fConv)
    {
        sub.fConv = shared_ptr<Converter>(new Converter(Out(), evt.GetFormat()));
        if (!sub.fConv->valid())
        {
            ostringstream str;
            str << "Couldn't properly parse the format... service " << evt.GetName() << " ignored.";
            Error(str);
            return;    
        }
    }
    //construct the header
    ostringstream header;
    const Time cTime(evt.GetTime());
    fQuality = evt.GetQoS();

    //update subscription last received time
    sub.lastReceivedEvent = cTime;
    //update subscription list service if required
    updateSubscriptionList();

    fMjD = cTime.Mjd() ? cTime.Mjd()-40587 : 0;

    if (isItaReport)
    {
//DISABLED REPORT WRITING BY THOMAS REQUEST
        //write text header
/*        string serviceName = (sub.service == "MESSAGE") ? "" : "_"+sub.service;
        header << sub.server << serviceName << " " << fQuality << " ";
        header << evt.GetTime() << " ";

        string text;
        try
        {
            text = sub.fConv->GetString(evt.GetData(), evt.GetSize());
        }
        catch (const runtime_error &e)
        {
            ostringstream str;
            str << "Parsing service " << evt.GetName();
            str << " failed: " << e.what() << " removing the subscription to " << sub.server << "/" << sub.service;
            Warn(str);
            //remove this subscription from the list.
            //because these operators use references to elements, and because they're supposed here to erase these objects on the way, I'm not too sure... so duplicate the names !
            RemoveService(sub.server, sub.service, false);
            return;
        }

        if (text.empty())
        {
            ostringstream str;
            str << "Service " << evt.GetName() << " sent an empty string";
            Info(str);
            return;
        }
        //replace bizarre characters by white space
        replace(text.begin(), text.end(), '\n', '\\');
        replace_if(text.begin(), text.end(), ptr_fun<int, int>(&iscntrl), ' ');
        
        //write entry to Nightly report
        if (fNightlyReportFile.is_open())
        {
            fNightlyReportFile << header.str() << text << endl;
            if (!CheckForOfstreamError(fNightlyReportFile, true))
                return;
        }
*/
#ifdef HAVE_FITS
        //check if the last received event was before noon and if current one is after noon.
        //if so, close the file so that it gets reopened.
//        sub.lastReceivedEvent = cTime;
        if (!sub.nightlyFile.IsOpen())
            if (GetCurrentState() != kSM_Ready)
                OpenFITSFiles(sub);
        WriteToFITS(sub, evt.GetData());
#endif
    }
    else
    {//write entry to Nightly log
        vector<string> strings;
        try
        {
           strings = sub.fConv->ToStrings(evt.GetData());
        }
        catch (const runtime_error &e)
        {
            ostringstream str;
            str << "Parsing service " << evt.GetName();
            str << " failed: " << e.what() << " removing the subscription for now.";
            Error(str);
            //remove this subscription from the list.
            //because these operators use references to elements, and because they're supposed here to erase these objects on the way, I'm not too sure... so duplicate the names !
            RemoveService(sub.server, sub.service, false);
            return;
        }
        if (strings.size() > 1)
        {
            ostringstream err;
            err << "There was more than one string message in service " << evt.GetName() << " going to fatal error state";
            Error(err.str());
        }

        bool isMessage = (sub.service == "MESSAGE");
        ostringstream msg;
        string serviceName = isMessage ? "" : "_"+sub.service;
        msg << sub.server << serviceName;


        //in case of non messages message (i.e. binary data written to logs)
        //we override the quality before writing to .log, otherwise it will wrongly decorate the log entry
        //because fQuality is really the system state in some cases.
        //so save a backup of the original value before writing to fits
        int backup_quality = fQuality;

        //fix the quality of non message "messages"
        if (!isMessage)
        {
            msg << "[" << fQuality << "]";
            fQuality = kMessage;
        }

        //special case for alarm reset
        if (isMessage && (fQuality == kAlarm) && (strings[0] == ""))
        {
            fQuality = kInfo;
            strings[0] = "Alarm reset";
        }
        msg << ": " << strings[0];

        if (fNightlyLogFile.is_open())
        {
            fNightlyLogImp.Write(cTime, msg.str().c_str(), fQuality);
            if (!CheckForOfstreamError(fNightlyLogFile, true))
                return;
        }

        //in case we have overriden the fQuality before writing to log, restore the original value before writing to FITS
        if (!isMessage)
            fQuality = backup_quality;

//        sub.lastReceivedEvent = cTime;
        if (!sub.nightlyFile.IsOpen())
            if (GetCurrentState() != kSM_Ready)
                OpenFITSFiles(sub);
        WriteToFITS(sub, evt.GetData());
    }
}

Here is the call graph for this function:

Here is the caller graph for this function: