RunControl.hh

#ifndef EUDAQ_INCLUDED_RunControl
#define EUDAQ_INCLUDED_RunControl

#include "eudaq/TransportServer.hh"
#include "eudaq/Logger.hh"
#include "eudaq/ConnectionState.hh"
#include "eudaq/Configuration.hh"
#include "eudaq/Platform.hh"
#include "eudaq/MachineState.hh"

#include <string>
#include <memory>
#include <thread>

namespace eudaq {

  class DLLEXPORT RunControl {
  public:
    explicit RunControl(const std::string &listenaddress = "");

    void StartServer(const std::string &listenaddress);
    void StopServer();

    void Init(const std::string &settings);
    void Configure(const Configuration &
                       settings); 
    void Configure(const std::string &settings,
                   int geoid = 0); 
    void Reset();                  
    void GetConnectionState();              
    virtual void StartRun(const std::string &msg = ""); 
    virtual void StopRun(bool listen = true); 
    void Terminate();                         


    void TestCommand();     //Test Command
    virtual void OnConnect(const ConnectionInfo & /*id*/) {}
    virtual void OnDisconnect(const ConnectionInfo & /*id*/) {}
    virtual void OnReceive(const ConnectionInfo & /*id*/,
                           std::shared_ptr<ConnectionState>) {}

    virtual void SendState(int state){}
    
    virtual ~RunControl();

    void CommandThread();
    size_t NumConnections() const { return m_cmdserver->NumConnections(); }
    const ConnectionInfo &GetConnection(size_t i) const {
      return m_cmdserver->GetConnection(i);
    }

    int GetFSMState(){return current_State.GetState();}

  private:
    void InitLog(const ConnectionInfo &id);
    void InitData(const ConnectionInfo &id);
    void InitOther(const ConnectionInfo &id);
    void SendCommand(const std::string &cmd, const std::string &param = "",
                     const ConnectionInfo &id = ConnectionInfo::ALL);
    std::string
    SendReceiveCommand(const std::string &cmd, const std::string &param = "",
                       const ConnectionInfo &id = ConnectionInfo::ALL);
    void CommandHandler(TransportEvent &ev);
    bool m_done;
    bool m_listening;

    MachineState current_State;



  protected:
    int32_t m_runnumber;          
    TransportServer *m_cmdserver; 
    std::unique_ptr<std::thread> m_thread;
    size_t m_idata, m_ilog;
    std::string m_logaddr;                    // address of log collector
    std::map<size_t, std::string> m_dataaddr; // map of data collector addresses
    int64_t m_runsizelimit;
    int64_t m_runeventlimit;
    bool m_nextconfigonrunchange;
    bool m_stopping, m_busy, m_producerbusy;
  };
}

#endif // EUDAQ_INCLUDED_RunControl