daqCmdsImpl.hpp

Go to the documentation of this file.

 
#ifndef SUP_SYSSUP_COMMON_APP_METADAQ_IMPL_HPP_
#define SUP_SYSSUP_COMMON_APP_METADAQ_IMPL_HPP_
 
#include "ifw/sup/syssup/common/events.rad.hpp"
 
#include <ifw/core/utils/bat/logger.hpp>
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
 
namespace ifw::sup::syssup::common {
 
class MetaDaqImpl : public metadaqif::AsyncMetaDaq {
public:
    MetaDaqImpl(rad::SMAdapter& sm) : mSM(sm), m_logger(ifw::core::utils::bat::GetAppLogger()) {
        LOG4CPLUS_TRACE_METHOD(m_logger,__PRETTY_FUNCTION__);
    }
 
    virtual ~MetaDaqImpl() {
        LOG4CPLUS_TRACE_METHOD(m_logger,__PRETTY_FUNCTION__);
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqReply>> StartDaq(const std::string& id) override {
        LOG4CPLUS_TRACE_METHOD(m_logger,__PRETTY_FUNCTION__);
        Events::StartDaq* ev = new Events::StartDaq(id); 
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqStopReply>> StopDaq(const std::string& id) override {
        LOG4CPLUS_TRACE_METHOD(m_logger,__PRETTY_FUNCTION__);
        Events::StopDaq* ev = new Events::StopDaq(id);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqReply>> AbortDaq(const std::string& id) override {
        LOG4CPLUS_TRACE_METHOD(m_logger,__PRETTY_FUNCTION__);
        Events::AbortDaq* ev = new Events::AbortDaq(id);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
 
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqStatus>> GetDaqStatus(const std::string& id) override {
        LOG4CPLUS_TRACE_METHOD(m_logger,__PRETTY_FUNCTION__);
        Events::GetDaqStatus* ev = new Events::GetDaqStatus(id);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
 
private:
    rad::SMAdapter& mSM;
    log4cplus::Logger m_logger;
};
 
}  // namespace server
 
#endif  // SUP_SYSSUP_COMMON_APP_METADAQ_IMPL_HPP_