QDaqServer.hh

Go to the documentation of this file.

#ifndef __QDAQSERVER_HH_
#define __QDAQSERVER_HH_

#include <map>
#include <vector>
#include <string>

#include "QCuore.hh"
#include "QCommand.hh"
#include "QDaqCommonDefs.hh"
#include "QDaqDefs.hh"
#include "QError.hh"

class QDaqServer
{
public:
   static QDaqServer& GetInstance();

   virtual ~QDaqServer();
   
   inline const QDaqState GetState() const {return fDaqState;}

   int GetCurrentRun() const { return fRun; }
   
   bool SetTriggerFlag(const unsigned int crateId, const bool flag);

   // state commands
   bool StartProcesses(int settingsBasket, int run, int shifterSet);
   bool Pause();
   bool Resume();
   bool Stop(int shifterSet);

   void ResetError() { fError.Set(QERR_SUCCESS); }
   bool HasError() const { return fError != QERR_SUCCESS; }
   const QError& GetError() const { return fError; }

private:
   QDaqServer();
   
   QDaqState fDaqState;   
   int fSettingsBasket;   
   int fRun;                  
   std::string fDaqUser;      
   std::string fPathBin;      
   std::string fPathLog;      
   std::string fReceiverAddr; 
   std::string fPulserAddr; 
   std::string fLoggerAddr;   
   std::string fLoggerPort;   
   std::string fDianaCfg;     
   std::string fEnvFile;      
   int  ReceiverBasePort;     
   bool fUseMuonReader;       
   bool fUsePulser;           
   bool fUseBuilder;          
   bool fReleaseReceiver;     
   bool fSaveChannels;     
   int  fSimulaHardware;   
   const float fTimeOut;      
   bool fBuilderIsRunning;   
   bool fPulserControllerIsRunning; 
   bool fMuonReaderIsRunning; 
   QError fError; 
   std::map<std::string,std::string> fReaders;
   std::map<std::string,std::string> fSenders;
   std::vector<std::string> fReceivers;


   bool StartRun();

   bool Abort();

   inline void SetState(const QDaqState& s) {fDaqState=s;}
   
   bool StartMuonReader(const std::string& address);

   bool StartPulserController(const std::string& address);

   bool StartReader(int crateId, const std::string& address, int extClock);

   bool StartSender(int crateId, const std::string& address);

   bool StartReceiver(int crateId);

   bool StartBuilder();
   
   bool StartProcess(const std::string& process,
                     const std::string& address,
                     const std::string& options,
                     ProcessStatus_t    status);

   bool KillProcess(const std::string& process,
                    const std::string& host,
                    const std::string& signal);

   bool KillProcess(const std::string& process,
                    const std::string& host,
                    const std::string& signal,
                    const std::string& killOpts);

   ProcessStatus_t AskStatus(const std::string& process);

   bool CheckStatus(const std::string& process,
                    ProcessStatus_t    status,
                    float              timeout);

   bool Unregistered(const std::string& process, float timeout);


   ProcessStatus_t GetStatusCode(const std::string& message);

   // clear all internal variables
   void Clear();

   // get formatted date string
   const char* GetDateString() const;
};

#endif

---