jaus++/2.0/src/jaus/core/liveness/liveness.cpp

Go to the documentation of this file.

#include "jaus/core/liveness/liveness.h"
#include "jaus/core/events/event.h"
#include <iostream>

using namespace JAUS;

const std::string Liveness::Name = "urn:jaus:jss:core:Liveness";

Liveness::Liveness() : Child(Service::ID(Liveness::Name, 1.0), 
                             Service::ID(Events::Name, 1.0))
{

}


Liveness::~Liveness()
{
}


bool Liveness::GenerateEvent(const Events::Subscription& info) const
{
    if(info.mpQueryMessage->GetMessageCode() == QUERY_HEARTBEAT_PULSE)
    {
        ReportHeartbeatPulse report;
        SendEvent(info, &report);
        return true;
    }

    return false;
}


bool Liveness::IsEventSupported(const Events::Type type,
                                const double requestedPeriodicRate,
                                const Message* queryMessage,
                                double& confirmedPeriodicRate,
                                std::string& errorMessage) const
{
    // Support any type of event for REPORT_HEARTBEAT_PULSE data.
    if(queryMessage->GetMessageCode() == QUERY_HEARTBEAT_PULSE)
    {
        confirmedPeriodicRate = requestedPeriodicRate;
        return true;
    }
    return false;
}


void Liveness::Receive(const Message* message)
{
    switch(message->GetMessageCode())
    {
    case QUERY_HEARTBEAT_PULSE:
        {
            ReportHeartbeatPulse response(message->GetSourceID(), GetComponentID());
            Send(&response);
        }
        break;
    case REPORT_HEARTBEAT_PULSE:
        {
            if(mDebugMessagesFlag)
            {
                Mutex::ScopedLock lock(&mDebugMessagesMutex);
                std::cout << "[" << GetServiceID().ToString() << "-" << mComponentID.ToString() << "] - Received Heartbeat Pulse from " << message->GetSourceID().ToString() << std::endl;
            }
        }
        break;
    default:
        break;
    }
}


Message* Liveness::CreateMessage(const UShort messageCode) const
{
    Message* message;
    switch(messageCode)
    {
    case QUERY_HEARTBEAT_PULSE:
        message = new QueryHeartbeatPulse();
        break;
    case REPORT_HEARTBEAT_PULSE:
        message = new ReportHeartbeatPulse();
        break;
    default:
        message = NULL;
        break;
    }
    return message;
}


/*  End of File */