ProxyReplyHandler.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Proxy/ProxyReplyHandler.h>
#include <fesa-core/Utilities/Lock.h>

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

#include <iostream>

namespace
{

CMW::Log::Logger& logger = CMW::Log::LoggerFactory::getLogger("FESA.FWK.fesa-core.Proxy.ProxyReplyHandler");

}


namespace fesa
{

ProxyReplyHandler::ProxyReplyHandler()
{
    mtx_.lock();
}

ProxyReplyHandler::~ProxyReplyHandler()
{

}

void ProxyReplyHandler::handleReply(const rdaRequest& request, const rdaData& value)
{
    Lock lock(mtx_);
    value_ = value;
    deviceName_ = (request.getDeviceHandle())->getDeviceName();
    propertyName_ = request.getPropertyName();
    if (request.getCycleSelector())
        cycleSelectorName_ = request.getCycleSelector();
    cv_.signal();
}

void ProxyReplyHandler::handleError(const rdaRequest&, const rdaException& ex)
{
    LOG_ERROR_IF(logger, ex.getMessage());
}

void ProxyReplyHandler::disconnected(const rdaRequest&)
{
}

void ProxyReplyHandler::reconnected(const rdaRequest&)
{
}

void ProxyReplyHandler::cancelled(const rdaRequest&)
{
}

void ProxyReplyHandler::waitReply(std::string& deviceName, std::string& propertyName,
                                  std::string& cycleSelectorName, rdaData& data)
{
    cv_.wait(mtx_);
    deviceName = deviceName_;
    propertyName = propertyName_;
    cycleSelectorName = cycleSelectorName_;
    data = value_;
}
} // fesa