MessageDim.cc

Go to the documentation of this file.

#include "MessageDim.h"

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

using namespace std;

// **************************************************************************
// **************************************************************************

// --------------------------------------------------------------------------
//
//
MessageDimTX::MessageDimTX(const std::string &name, std::ostream &out)
    : DimDescribedService(name + "/MESSAGE", const_cast<char*>("C"),
                          "A general logging service providing a quality of service (severity)"
                          "|Message[string]:The message"),
    MessageImp(out), fDebug(false),
    fMsgQueue(std::bind(&MessageDimTX::UpdateService, this, placeholders::_1))
{
    // This is a message which will never arrive because
    // the time to establish a client-sever connection is
    // too short.
    Message("MessageDimTX started.");
}

// --------------------------------------------------------------------------
//
//
MessageDimTX::~MessageDimTX()
{
    // Everything here will never be sent by dim because the
    // dim services have been stopped already. This is necessary,
    // to have them available already during startup
    Message("MessageDimTX shutting down ["+to_string(fMsgQueue.size())+"]");
    fMsgQueue.wait();
}

bool MessageDimTX::UpdateService(const tuple<Time,string,int> &data)
{
    setData(get<1>(data));
    setQuality(get<2>(data));

    const int rc = DimDescribedService::Update(get<0>(data));
    if (rc==0 && fDebug)
        Out() << " !! " << get<0>(data).GetAsStr() << " - Sending failed!" << endl;

    return true;
}

// --------------------------------------------------------------------------
//
//
int MessageDimTX::Write(const Time &t, const string &txt, int qos)
{
    MessageImp::Write(t, txt, qos);
    fMsgQueue.emplace(t, txt, qos);
    return 1;
}

// **************************************************************************
// **************************************************************************

// --------------------------------------------------------------------------
//
//
MessageDimRX::MessageDimRX(const std::string &name, MessageImp &imp)
: fMinLogLevel(0), fConnected(false), fMsg(imp),
fDimMessage((name+"/MESSAGE").c_str(), (void*)NULL, 0, this)
{
}

// --------------------------------------------------------------------------
//
//
void MessageDimRX::infoHandler()
{
    if (getInfo()!=&fDimMessage)
        return;

    const string name   = fDimMessage.getName();
    const string server = name.substr(0, name.find_first_of('/'));

    fConnected = fDimMessage.getSize()!=0;

    // The server is diconnected. Do nothing
    if (!fConnected)
    {
        // We cannot print this message because it is produced by
        // every server which doesn't have the MESSAGE service, too.
        //fMsg.Message(server+": Disconnected.");
        return;
    }

    // skip all messages with a severity smaller than the minimum log level
    if (fDimMessage.getQuality()<fMinLogLevel)
        return;

    const string msg = server+": "+fDimMessage.getString();

    // Make sure getTimestamp is called _before_ getTimestampMillisecs
    // Must be in exactly this order!
    const int tsec = fDimMessage.getTimestamp();
    const int tms  = fDimMessage.getTimestampMillisecs();

    // Write the received message to the output
    fMsg.Write(Time(tsec, tms*1000), msg, fDimMessage.getQuality());
}