BnetMasterModule.h

Go to the documentation of this file.

// $Id: BnetMasterModule.h 4707 2021-02-26 11:29:21Z 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 HADAQ_BnetMasterModule
#define HADAQ_BnetMasterModule
 
#ifndef DABC_ModuleAsync
#include "dabc/ModuleAsync.h"
#endif
 
#include <vector>
#include <string>
 
 
namespace hadaq {
 
   class BnetMasterModule : public dabc::ModuleAsync {
      protected:
 
         bool          fControl;  
         unsigned      fMaxRunSize; 
         dabc::Command fCurrentFileCmd; 
         int           fCmdCnt;     
         int           fCmdReplies; 
         double        fCmdQuality;  
         unsigned      fCalibrRunId;  
 
         dabc::Command fCurrentRefreshCmd; 
         int           fRefreshCnt{0};   
         int           fRefreshReplies{0}; 
 
         int           fCtrlId;     
         dabc::TimeStamp fCtrlTm;   
         dabc::TimeStamp fNewRunTm;   
         int           fCtrlCnt;    
         bool          fCtrlError;  
         int           fCtrlErrorCnt; 
         double        fCtrlStateQuality;  
         std::string   fCtrlStateName; 
         int           fCtrlInpNodesCnt; 
         int           fCtrlInpNodesExpect; 
         int           fCtrlBldNodesCnt; 
         int           fCtrlBldNodesExpect; 
         int           fCtrlSzLimit; 
         double        fCtrlData;    
         double        fCtrlEvents;   
         double        fCtrlLost;     
         uint64_t      fCurrentLost;   
         uint64_t      fCurrentEvents; 
         uint64_t      fCurrentData; 
         uint64_t      fTotalLost;    
         uint64_t      fTotalEvents;  
         uint64_t      fTotalData;  
         dabc::TimeStamp fLastRateTm;   
         unsigned      fCtrlRunId;    
         std::string   fCtrlRunPrefix; 
         std::vector<std::string> fLastBuilders; 
         int           fSameBuildersCnt; 
         dabc::Command fInitRunCmd;   
 
         virtual bool ReplyCommand(dabc::Command cmd);
 
         void AddItem(std::vector<std::string> &items, std::vector<std::string> &nodes, const std::string &item, const std::string &node);
 
         void PreserveLastCalibr(bool do_write = false, double quality = 1., unsigned runid = 0);
 
      public:
 
         BnetMasterModule(const std::string &name, dabc::Command cmd = nullptr);
 
         virtual void BeforeModuleStart();
 
         virtual void ProcessTimerEvent(unsigned timer);
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
   };
}
 
 
#endif