Monitor.h

Go to the documentation of this file.

// $Id: Monitor.h 4768 2021-04-26 09:13:07Z linev $
 
/************************************************************
 * The Data Acquisition Backbone Core (DABC)                *
 ************************************************************
 * Copyright (C) 2009 -                                     *
 * GSI Helmholtzzentrum fuer Schwerionenforschung GmbH      *
 * Planckstr. 1, 64291 Darmstadt, Germany                   *
 * Contact:  http://dabc.gsi.de                             *
 ************************************************************
 * This software can be used under the GPL license          *
 * agreements as stated in LICENSE.txt file                 *
 * which is part of the distribution.                       *
 ************************************************************/
 
#ifndef MBS_Monitor
#define MBS_Monitor
 
#ifndef MBS_MonitorSlowControl
#include "mbs/MonitorSlowControl.h"
#endif
 
#ifndef DABC_SocketThread
#include "dabc/SocketThread.h"
#endif
 
#ifndef MBS_MbsTypeDefs
#include "mbs/MbsTypeDefs.h"
#endif
 
 
namespace mbs {
 
 
   class DaqStatusAddon : public dabc::SocketIOAddon {
 
      protected:
 
         enum IOState {
            ioInit,           // initial state
            ioRecvHeader,     // receiving server info
            ioRecvData,
            ioDone,
            ioError
         };
 
         enum EEvents {
            evDataInput = evntSocketLast,
            evReactivate
         };
 
         IOState              fState;
         mbs::DaqStatus       fStatus;
         bool                 fSwapping;
         uint32_t             fSendCmd;
 
         virtual void OnThreadAssigned();
 
         virtual double ProcessTimeout(double last_diff);
 
         virtual void OnRecvCompleted();
 
      public:
 
         DaqStatusAddon(int fd);
 
         mbs::DaqStatus& GetStatus() { return fStatus; }
   };
 
   // =====================================================================
 
   class DaqLogWorker : public dabc::Worker {
      protected:
 
         struct MbsLogRec {
            int32_t iOrder;
            int32_t iType;
            int32_t iStatus;
            char fBuffer[512];
         };
 
         std::string fMbsNode;
         int         fPort;
         MbsLogRec   fRec;
         bool        fFirstRecv;
 
         bool CreateAddon();
 
         virtual void OnThreadAssigned();
 
         virtual double ProcessTimeout(double last_diff);
 
         virtual void ProcessEvent(const dabc::EventId&);
 
      public:
         DaqLogWorker(const dabc::Reference& parent, const std::string &name, const std::string &mbsnode, int port);
         virtual ~DaqLogWorker();
 
         virtual std::string RequiredThrdClass() const
           {  return dabc::typeSocketThread; }
 
   };
 
   // ======================================================================
 
   class DaqRemCmdWorker : public dabc::Worker {
      protected:
 
         struct MbsRemCmdRec {
            uint32_t  l_order;      /* byte order. Set to 1 by sender */
            uint32_t  l_cmdid;      /* command id, 0xffffffff when dummy command is send */
            uint32_t  l_status;     /* command completion status      */
            char      c_cmd[512];   /* command to execute - or reply info */
 
            bool CheckByteOrder() {
               if (l_order!=1) mbs::SwapData(this, 3*4);
               return l_order==1;
            }
         };
 
 
         enum IOState {
            ioInit,           // initial state
            ioWaitReply,      // waiting for command reply
            ioError
         };
 
         std::string       fMbsNode;
         int               fPort;
 
         dabc::CommandsQueue fCmds;
 
         IOState           fState;
         MbsRemCmdRec      fSendBuf;
         uint32_t          fSendCmdId;  // command identifier, send to the MBS with the command
         MbsRemCmdRec      fRecvBuf;
 
         virtual void ProcessEvent(const dabc::EventId&);
 
         virtual double ProcessTimeout(double last_diff);
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
         void ProcessNextMbsCommand();
 
         virtual void OnThreadAssigned();
 
         bool CreateAddon();
 
 
      public:
         DaqRemCmdWorker(const dabc::Reference& parent, const std::string &name, const std::string &mbsnode, int port);
 
         virtual ~DaqRemCmdWorker();
   };
 
 
   // ======================================================================
 
   class PrompterWorker : public dabc::Worker {
      protected:
 
         enum IOState {
            ioInit,           // initial state
            ioWaitReply,      // waiting for command reply
            ioError
         };
 
         std::string       fMbsNode;    // real mbs node name
         int               fPort;
         std::string       fPrefix;     // prefix used to identify client
 
         dabc::CommandsQueue fCmds;
 
         IOState           fState;
         char              fSendBuf[256];
         uint32_t          fRecvBuf[2];
 
         virtual void ProcessEvent(const dabc::EventId&);
 
         virtual double ProcessTimeout(double last_diff);
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
         void ProcessNextMbsCommand();
 
         virtual void OnThreadAssigned();
 
         bool CreateAddon();
 
      public:
         PrompterWorker(const dabc::Reference& parent, const std::string &name, const std::string &mbsnode, int port);
 
         virtual ~PrompterWorker();
   };
 
   // ======================================================================
 
 
   class Monitor : public mbs::MonitorSlowControl {
      protected:
 
         dabc::Hierarchy   fHierarchy;
         unsigned          fCounter;
 
         std::string       fMbsNode;    
         std::string       fAlias;      // name appeared in hierarchy, node name by default
         double            fPeriod;     
         double            fRateInterval; 
         int               fHistory; 
         int               fStatPort;   
         int               fLoggerPort; 
         int               fCmdPort;    
         bool              fWaitingLogger; 
         dabc::Command     fWaitingCmd;    
         mbs::DaqStatus    fStatus;     
         dabc::TimeStamp   fStatStamp;  
         bool              fPrintf;     
         std::string       fFileStateName;    
         std::string       fAcqStateName;    
         std::string       fSetupStateName;    
         std::string       fRateIntervalName;    
         std::string       fHistoryName;    
 
         void FillStatistic(const std::string &options, const std::string &itemname, mbs::DaqStatus* old_daqst, mbs::DaqStatus* new_daqst, double difftime);
 
         void CreateCommandWorker();
 
         virtual void OnThreadAssigned();
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
         void UpdateFileState(int isopen);
         void UpdateMbsState(int isrunning);
 
         void UpdateSetupState(int isloaded);
 
         void SetRateInterval(double t);
 
         void SetHistoryDepth(int entries);
 
         bool IsPrompter() const { return fCmdPort == 6006; }
 
         virtual void ProcessTimerEvent(unsigned timer);
 
         virtual unsigned WriteRecRawData(void* ptr, unsigned maxsize);
 
      public:
 
         Monitor(const std::string &name, dabc::Command cmd = nullptr);
         virtual ~Monitor();
 
         virtual std::string RequiredThrdClass() const
           {  return dabc::typeSocketThread; }
 
         std::string MbsNodeName() const { return fMbsNode; }
 
         void LoggerAddonCreated();
 
         void NewMessage(const std::string &msg);
 
         void NewSendCommand(const std::string &cmd, int res = -1);
 
         void NewStatus(mbs::DaqStatus& stat);
   };
}
 
 
#endif