StateMachineDim.cc

Go to the documentation of this file.

// **************************************************************************
// **************************************************************************
#include "StateMachineDim.h"

#include "tools.h"

#include "EventDim.h"
#include "ServiceDim.h"

using namespace std;

const int StateMachineDim::fVersion = 42;

// --------------------------------------------------------------------------
//
//
StateMachineDim::StateMachineDim(ostream &out, const std::string &name)
    : DimLog(out, name), DimStart(name, DimLog::fLog), StateMachineImp(out, name),
    fDescriptionStates(name+"/STATE_LIST", "C",
                       "Provides a list with descriptions for each service."
                       "|StateList[string]:A \\n separated list of the form id:name=description"),
    fSrvState(name+"/STATE", "C",
              "Provides the state of the state machine as quality of service."
              "|Text[string]:A human readable string sent by the last state change.")
    //    fSrvVersion((name+"/VERSION").c_str(), const_cast<int&>(fVersion)),
{
    SetDefaultStateNames();
}

// --------------------------------------------------------------------------
//
EventImp *StateMachineDim::CreateEvent(const string &name, const string &fmt)
{
    return new EventDim(GetName()+"/"+name, fmt, this);
}

EventImp *StateMachineDim::CreateService(const string &name)
{
    return new ServiceDim(name, this);
}

// --------------------------------------------------------------------------
//
bool StateMachineDim::AddStateName(const int state, const std::string &name, const std::string &doc)
{
    if (name.empty())
        return false;

    const bool rc = HasState(state) || GetStateIndex(name)!=kSM_NotAvailable;

    StateMachineImp::AddStateName(state, name, doc);

    string str;
    for (auto it=fStateNames.begin(); it!=fStateNames.end(); it++)
        str += to_string(it->first)+':'+it->second.first+'='+it->second.second+'\n';

    fDescriptionStates.Update(str);

    return rc;
}

// --------------------------------------------------------------------------
//
string StateMachineDim::SetCurrentState(int state, const char *txt, const std::string &cmd)
{
    const string msg = StateMachineImp::SetCurrentState(state, txt, cmd);
    if (msg.empty())
        return "";

    fSrvState.setQuality(state);
    fSrvState.Update(msg);

    return msg;
}

// --------------------------------------------------------------------------
//
void StateMachineDim::Lock()
{
    dim_lock();
}

// --------------------------------------------------------------------------
//
void StateMachineDim::UnLock()
{
    dim_unlock();
}

void StateMachineDim::infoHandler()
{
    DimInfo *inf = getInfo();
    if (!inf)
        return;

    const EventImp *evt = dynamic_cast<EventImp*>(inf);

    if (HasEvent(evt))
        PostEvent(*evt);
}

// --------------------------------------------------------------------------
//
//
void StateMachineDim::commandHandler()
{
    DimCommand *cmd = getCommand();
    if (!cmd)
        return;

    const EventImp *evt = dynamic_cast<EventImp*>(cmd);

    if (HasEvent(evt))
        PostEvent(*evt);
}

// --------------------------------------------------------------------------
//
//
int StateMachineDim::Write(const Time &time, const string &txt, int qos)
{
    return DimLog::fLog.Write(time, txt, qos);
}

// --------------------------------------------------------------------------
//
//
void StateMachineDim::exitHandler(int code)
{
    Out() << " -- " << Time().GetAsStr() << " - EXIT(" << code << ") command received." << endl;
    if (code<0) // negative values reserved for internal use
    {
        Out() << " -- " << Time().GetAsStr() << ": ignored." << endl;
        return;
    }

    Stop(code);
    if (code==42)
        exit(128);
    if (code==0x42)
        abort();
}