MessageImp.cc

Go to the documentation of this file.

// **************************************************************************
// **************************************************************************
#include "MessageImp.h"

#include <stdarg.h>

#include <mutex>

#include "tools.h"
#include "Time.h"
#include "WindowLog.h"

using namespace std;

// --------------------------------------------------------------------------
//
//
MessageImp::MessageImp(ostream &out) : fOut(out)
{
}

// --------------------------------------------------------------------------
//
//
void MessageImp::StateChanged(const Time &time, const string &server, const string &msg, int state)
{
    if (state<-1)
        return;

    ostringstream out;
    out << server << ": Changed state to " << state << " '" << msg << "' received.";

    Write(time, out.str(), MessageImp::kInfo);

    IndicateStateChange(time, server);
}

// --------------------------------------------------------------------------
//
//
int MessageImp::WriteImp(const Time &time, const string &txt, int severity)
{
    if (severity==kAlarm && txt.length()==0)
        return 0;

    static mutex mtx;
    const lock_guard<mutex> guard(mtx);

    switch (severity)
    {
    case kMessage: fOut << kDefault       << " -> "; break;
    case kComment: fOut << kDefault       << " #> "; break;
    case kInfo:    fOut << kGreen         << " I> "; break;
    case kWarn:    fOut << kYellow        << " W> "; break;
    case kError:
    case kAlarm:   fOut << kRed           << " E> "; break;
    case kFatal:   fOut << kRed << kBlink << " !> "; break;
    case kDebug:   fOut << kBlue          << "    "; break;
    default:       fOut << kBold          << " >> "; break;
    }
    fOut << time.GetAsStr("%H:%M:%S.%f") << " - " << txt << endl;

    return 0;
}

int MessageImp::Write(const Time &time, const string &txt, int severity)
{
    const uint32_t mjd = time.Mjd();

    if (fLastMjd != mjd)
        WriteImp(time, "=================== "+time.GetAsStr("%Y-%m-%d")+" ["+to_string(mjd)+"] ==================");

    fLastMjd = mjd;

    WriteImp(time, txt, severity);
    return 0;
}

// --------------------------------------------------------------------------
//
//
int MessageImp::Update(const string &txt, int severity)
{
    Write(Time(), txt, severity);
    return 0;
}

// --------------------------------------------------------------------------
//
//
/*
int MessageImp::Update(int severity, const char *fmt, ...)
{
    va_list ap;
    va_start(ap, fmt);
    string str = Tools::Format(fmt, ap);
    va_end(ap);
    return Update(str, severity);
}
*/