BmnMonitor.h

Go to the documentation of this file.

#ifndef BMNMONITOR_H
#define BMNMONITOR_H 1
// STL
#include <chrono>
#include <exception>
#include <iterator>
#include <regex>
// Auxillary
#include <zmq.h>
// FairSoft
#include <TBufferFile.h>
#include <TChain.h>
#include <TClonesArray.h>
#include <TColor.h>
#include <TFile.h>
#include <TFolder.h>
#include <THttpServer.h>
#include <TList.h>
#include <TNamed.h>
#include <TString.h>
#include <TSystemDirectory.h>
#include <TSystemFile.h>
// BmnRoot
#include <BmnEventHeader.h>
#include <BmnRawDataDecoder.h>
// BmnRoot Monitor
// #include "BmnDataReceiver.h"
#include "BmnOnlineDecoder.h"
 
#include <BmnRunInfo.h>
 
#define TTREE_MAX_SIZE 3e11
 
class BmnMonitor : public TNamed
{
  public:
    BmnMonitor();
    virtual ~BmnMonitor();
    void MonitorStreamZ(TString dir, TString refDir = "", TString decoAddr = "localhost", Int_t webPort = 9000);
    TObjArray* GetAlikeRunsByElog(uint32_t periodID, uint32_t rinID);
    TObjArray* GetAlikeRunsByUniDB(uint32_t periodID, uint32_t rinID);
 
    void SetPeriodID(Int_t v) { this->fPeriodID = v; }
    Int_t GetPeriodID() const { return fPeriodID; }
 
    void SetBmnSetup(BmnSetup v) { fSetup = v; }
    BmnSetup GetBmnSetup() const { return fSetup; }
 
    void SetHistFileNameAdd(TString add) { fHistFileNameAdd = add; }
 
    void SetDetectorSetup(uint64_t setup) { fDetectorSetup = setup; }
 
    void SetNItersToUpdate(uint64_t val) { fNItersToUpdate = val; }
 
    void SetSlowMode(bool val) { fIsSlowMode = val; }
 
  private:
    void InitServer();
    void ProcessDigi(Int_t iEv);
    void RegisterAll();
    void UpdateRuns();
    BmnStatus CreateFile(uint32_t runID = 0);
    BmnStatus OpenStream();
    void FinishRun();
    void InitHistVectors(vector<BmnHist*>& vec, TString refName = "");
    inline void ProcessRequests();
 
    void* _ctx;
    void* _decoSocket;
    TString _curFile;
    TString _curDir;
    TString _refDir;
    TString fRawDecoAddr;
    TTree* fRecoTree;
    TTree* fRecoTree4Show;
    TFile* fHistOut;
    TFile* fHistOutTemp;
    THttpServer* fServer;
    DigiArrays* fDigiArrays;
 
    uint64_t fDetectorSetup;
 
    vector<BmnHist*> bhVec;
    vector<BmnHist*> bhVec4show;
    vector<bool> bhVecIsStat;   // temp crutch to distinguish stat events histogram sets
 
    TCanvas* infoCanvas;
    //    TList *refList;
    TList* refTable;
    TList* runPub;
    BmnRunInfo* CurRun;
 
    Bool_t keepWorking;
    Int_t _webPort;
    Int_t fTest;
    uint32_t fPeriodID;
    BmnSetup fSetup;
    uint32_t fRunID;
    BmnTrigRaw2Digit* fTrigMapper;
    uint64_t fEvents;
    uint64_t fNItersSinceUpdate;
    uint64_t fNItersToUpdate;
    const chrono::milliseconds fTimeToProcessRequests;            
    chrono::time_point<chrono::system_clock> fTicksLastProcess;   
    const chrono::seconds fTimeToUpdate;                          
    chrono::time_point<chrono::system_clock> fTicksLastUpdate;    
    bool fIsSlowMode;   // process requests for each iteration (not good for MSC)
    BmnWorkerState fState;
    Int_t decoTimeout;
 
    TString fHistFileNameAdd;
 
    ClassDef(BmnMonitor, 1)
};
 
#endif