QProcessStatus.hh

Go to the documentation of this file.

 
#ifndef _QPROCESS_STATUS_HH_
#define _QPROCESS_STATUS_HH_
 
#include <string>
#include <deque>
#include <map>
#include <signal.h>
 
#include "QDiana.hh"
#include "QNamed.hh"
#include "QDaqCommonDefs.hh"
#include "QId.hh"
 
class QProcessStatus : public QNamed, QId 
{
public:
   
   static QProcessStatus& GetInstance();
   virtual ~QProcessStatus() {}
 
   void Associate(int signalId, ProcessStatus_t pStatus);
   void Disable(int signalId);
   bool Ignore(int signalId);
 
   bool HasChanged() const { return !fStatusQueue.empty(); }
   ProcessStatus_t GetState() const { return fState; }
   ProcessStatus_t GetPreviousState() const { return fPreviousState; }
 
   ProcessStatus_t GetNextState() const
   { if(HasChanged()) return fStatusQueue.front(); else return fState; }
   void SetState(ProcessStatus_t state);
   void Notify();
 
   bool isRunning() const { return (QRunning_s == fState);}
   bool isPaused() const { return (QPaused_s  == fState);}
   bool isIdle() const { return (QIdle_s == fState);}
   bool isReady() const { return (QReady_s   == fState);}
   bool isExiting() const { return (QExiting_s   == fState);}
   bool isWaiting() const { return (QWaiting_s   == fState);}
 
   const std::string& GetError() const {return fError;}   
   void SetError(const std::string& errMsg) {fError=errMsg;}
   bool isError() const {return (fError != "");}
   
   bool TrgCtrlEnabled() const { return fTrgCtrl; }
   void SetTrgCtrlEnabled(bool enabled) {fTrgCtrl = enabled; }
   
   void InformServer();
   
   void SetName(const std::string& name) { QNamed::SetName(name); }
 
   void EnableInformServer(bool enabled) { fInformEnabled = enabled; }
private:
   QProcessStatus();
 
   ProcessStatus_t fState;
   ProcessStatus_t fPreviousState;
   bool fTrgCtrl;
   bool fInformEnabled;
   const size_t kMaxQueued;
   std::deque<ProcessStatus_t> fStatusQueue;
   std::string fError;
   std::map<int,ProcessStatus_t> fSigMap;
 
 
   void HandleSignal(int signalId);
 
   void AddToQueue(ProcessStatus_t state);
   
   ProcessStatus_t GetLastStatus() const;
 
   friend void SigHandler(int);
};
 
void SigHandler(int signalId);
 
#endif // _QPROCESS_STATUS_HH_