QProcessStatus.hh

Go to the documentation of this file.

#ifndef _QPROCESS_STATUS_HH_
#define _QPROCESS_STATUS_HH_

// C/C++ Includes
#include <string>
#include <deque>
#include <map>
#include <signal.h>

// Apollo Includes
#include "QCuore.hh"
#include "QNamed.hh"
#include "QId.hh"
#include "QDaqCommonDefs.hh"

class QProcessStatus : public QNamed, QId 
{
public:
   
   static QProcessStatus& GetInstance();
   
   virtual ~QProcessStatus() {}

   bool Associate(int signalId,ProcessStatus_t pStatus);

   bool Enable(int signalId);

   bool Disable(int signalId);

   bool Ignore(int signalId);

   bool HasChanged() const { return !fStatusQueue.empty(); }

   volatile ProcessStatus_t GetState() const { return fState; }
   
   volatile ProcessStatus_t GetPreviousState() const 
   { return fPreviousState; }

   volatile ProcessStatus_t GetNextState() const
   { if(HasChanged()) return fStatusQueue.front(); else return fState; }

   void SetState(ProcessStatus_t state);
  
   void Notify();

   volatile bool isRunning()      const { return (QRunning_s == fState);}

   volatile bool isPaused()       const { return (QPaused_s  == fState);}

   volatile bool isIdle()         const { return (QIdle_s    == fState);}

   volatile bool isReady()        const { return (QReady_s   == fState);}

   volatile bool TrgCtrlEnabled() const { return fTrgCtrl; }
   
   const std::string& GetError() const {return fError;}

   void SetError(const std::string& errMsg) {fError=errMsg;}

   bool isError() const {return (fError != "");}
   
   void SetTrgCtrlEnabled(bool enabled) {fTrgCtrl = enabled; }
   
   void InformServer();
   
   void SetName(const std::string& name) { QNamed::SetName(name); }


private:

   QProcessStatus();

   mutable ProcessStatus_t fState;
   mutable 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 AssociateDefaults();

   void AddToQueue(ProcessStatus_t state);
   
   ProcessStatus_t GetLastStatus() const;

   bool CanBeHandled(int signalId) const;

   bool CanBeDisabled(int signalId) const;

   friend void SigHandler(int);
};


void SigHandler(int signalId);

#endif // _QPROCESS_STATUS_HH_

---