daqCmdsImpl.hpp

Go to the documentation of this file.

 
#ifndef FCF_DEVMGR_COMMON_METADAQ_IMPL_HPP_
#define FCF_DEVMGR_COMMON_METADAQ_IMPL_HPP_
 
#include "fcf/devmgr/common/events.rad.hpp"
 
#include <utils/bat/logger.hpp>
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
namespace fcf::devmgr::common {
 
class MetaDaqImpl : public metadaqif::AsyncMetaDaq {
public:
    MetaDaqImpl(rad::SMAdapter& sm) : mSM(sm), m_logger(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  // FCF_DEVMGR_COMMON_METADAQ_IMPL_HPP_