DDTRC.h

Go to the documentation of this file.

#ifndef _NGT_RC_H
#define _NGT_RC_H

#include <NovaRunControlClient/RunControlReceiver.h>
#include <DAQMessages/ccpp_RunControlMessages.h>
#include <boost/shared_ptr.hpp>
#include <boost/thread/mutex.hpp>

#include <messagefacility/MessageLogger/MessageLogger.h>

namespace rcm=runcontrolmessages;

namespace novaddt{

class Lockable{
    protected:
      mutable boost::mutex _callbackMutex;
};

//Helper functions to make code somewhat cleaner

template <class response_t> 
boost::shared_ptr<response_t> Response(int code=0, std::string message="Success"){
    boost::shared_ptr<response_t> response;
    response.reset(new response_t());

    rmscore::RequestStatus reqStatus;
    reqStatus.code = code;
    reqStatus.message = DDS::string_dup(message.data());

    response->status = reqStatus;
    return response;
}


template<class request_t, class response_t>
class Responder: public Lockable{
    public:
        virtual ~Responder(){};

        boost::shared_ptr<response_t> 
        handleMessage( boost::shared_ptr<request_t> message ){
            boost::mutex::scoped_lock sl(_callbackMutex);
            // create the reply
            try{ 
                handle(*message);
            }
            catch(std::exception e){
                return Response<response_t>(1,std::string("Reques failed: ")+e.what());
            }

            return Response<response_t>(0,"Success");
        }

        virtual void handle(const request_t& request) = 0;
};

class DDTRC: 
    public Responder<rcm::StatusRequest,rcm::StatusResponse>,
    public Responder<rcm::RolloverRunRequest,rcm::RolloverRunResponse>,
    public Responder<rcm::BeginRunRequest,rcm::BeginRunResponse>
{
public:

  DDTRC(std::string applicationName, int partNumber);
  ~DDTRC();

  /**
   * Handle run control messages
   */
 virtual void handle(const rcm::StatusRequest& message) override;
 virtual void handle(const rcm::RolloverRunRequest& message) override;
 virtual void handle(const rcm::BeginRunRequest& message) override;

private:
  // variables
  std::string _applicationName;
  boost::shared_ptr<novadaq::rcclient::RunControlReceiver> _rcReceiver;
  boost::shared_ptr<mf::Presence> _mfPresence;
  int _partNumber;

protected:
  //current state
   int _runNumber;
   int _subrunNumber;
};



}//namespace novaddt
#endif