GetDiagnosticSetting.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Server/GetDiagnosticSetting.h>

#include <fesa-core/Server/RequestEvent.h>
#include <fesa-core/DataStore/GlobalDevice.h>
#include <fesa-core/Diagnostic/DiagnosticUtils.h>
#include <fesa-core/Diagnostic/Diagnostics.h>

#include <cmw-rda/Data.h>
#include <cmw-log/Logger.h>


namespace
{

const std::string serverActionTopic = fesa::DiagnosticUtils::getActionProfilingStr;

} // namespace


namespace fesa
{

GetDiagnosticSetting::GetDiagnosticSetting(ServerActionConfig& actionConfig, const AbstractServiceLocator* serviceLocator, const std::map<std::string, const AbstractServiceLocator*> serviceLocatorRelatedClasses) :
    AbstractServerAction(actionConfig, serviceLocator, serviceLocatorRelatedClasses)
{
}


GetDiagnosticSetting::~GetDiagnosticSetting()
{
}


bool
GetDiagnosticSetting::needFilter()
{
    return false;
}


void
GetDiagnosticSetting::execute(RequestEvent* event, AbstractDevice& device, const rdaData& filter,
                              rdaData& data, IOType ioType, RequestType requestType)
{
    const boost::shared_ptr<Diagnostics>& diagnostics = AbstractEquipment::getInstance()->getDiagnostics();
    DiagnosticUtils::DiagnosticMessage diagMsg;
    diagMsg.side = DiagnosticUtils::framework;
    diagMsg.source = DiagnosticUtils::server;
    diagMsg.name = getName();
    diagMsg.action = DiagnosticUtils::start;
    diagnostics->log(serverActionTopic, diagMsg);
    GlobalDevice& globalDevice = static_cast<GlobalDevice&>(device);
    MultiplexingContext* context = event->getMultiplexingContext();
    // Just restore the last setting from GlobalStore
    data.insert("enableDiagMode", globalDevice.enableDiagMode.get(context));
    const std::string hostName = globalDevice.hostName.get(context);
    data.insert("hostName", hostName.c_str());
    data.insert("portNumber", static_cast<long int>(globalDevice.portNumber.get(context)));
    data.insert("requestConfig", false);
    data.insert("requestState", false);
    data.insert("fwkTopic", static_cast<long int>(globalDevice.fwkTopic.get(context)));
    data.insert("customTopic", static_cast<long int>(globalDevice.customTopic.get(context)));
    data.insert("traceDevices", globalDevice.traceDevices.get(context));
    data.insert("bypassActions", globalDevice.bypassActions.get(context));
    diagMsg.action = DiagnosticUtils::stop;
    diagnostics->log(serverActionTopic, diagMsg);
}


void
GetDiagnosticSetting::performCommit(MultiplexingContext& context, AbstractDevice* transactionDevice)
{
}


void
GetDiagnosticSetting::performRollback(MultiplexingContext& context, AbstractDevice* transactionDevice)
{
}

} // fesa