PREAN/TFndPreanScalers.h

// @(#)fROOT/PREAN:$Name:  $:$Id: TFndPreanScalers.h,v 1.4 2007/09/05 10:15:21 Diego_Faso Exp $
// Author: H. So , 2006/05/29

#ifndef FROOT_TFndPreanScalers
#define FROOT_TFndPreanScalers

#include <string>
#include <fstream>
#include <TObject.h>
#include <TDatime.h>

#include "FROOT.h"

class TFndPreanScalers : public TObject {
public:
  enum EDaqStatus {
    kStopped = 0,
    kCrashed = 1,
    kActive  = 5
  };

  enum {
    kScalerInterval  = 15,      // raw files are written in every 15 seconds
    kSecondsPerDay   = 86400,
    kEvhLen          = 16,      // length of the Global Event Header
    kGtsLen          = 36,      // length of the GTS buffer
    kScbLen          = 82,      // length of the VME scaler buffers in total
  };

  struct Data {
    UInt_t evh[kEvhLen];        // copy of the Global Event Header
    UInt_t gts[kGtsLen];        // copy of the GTS buffer
    UInt_t scb[kScbLen];        // copy of the VME scaler buffer
    Data(const UInt_t rawEvent[]);
  };

public:
  static TFndPreanScalers *Instance(); // Get the singleton instance
  Int_t Write(const Data &data);

protected:
  TFndPreanScalers();
  ~TFndPreanScalers();

private:
  TFndPreanScalers(const TFndPreanScalers &); // Noncopiable; not implemented,
  TFndPreanScalers &operator = (const TFndPreanScalers &); // Noncopiable; not implemented,

private:
  Int_t RecreateFastFiles();
  Int_t CloseFastFiles();
  Int_t WriteFastFiles(const std::string &readScalerText, const std::string &runInfoText);

  Int_t OpenRawFiles();
  Int_t CloseRawFiles();
  Int_t WriteRawFiles(const std::string &scalerText, const std::string &scalerInfoText);

  void        CalculateRate(const UInt_t v[], const UInt_t v0[], Float_t vr[]);
  std::string GenerateReadScalerText(const UInt_t evh[], const Float_t vr[], UInt_t daqStatus);
  std::string GenerateRunInfoText(const UInt_t evh[], const UInt_t gts[], const Float_t vr[], UInt_t daqStatus);

private:
  // time
  TDatime fDatime;
  UInt_t  fCurTime;
  UInt_t  fSavedTime;           // in seconds
  UInt_t  fSavedDay;
  UInt_t  fSavedFif;            // 15 seconds interval

  // data
  UInt_t fV0[kScbLen];          // holds counts at time n-1
  UInt_t fBhaInt;               // holds the integral counts of Bhabha collected in 15 sec at time n
  UInt_t fBhaInt0;              // holds the integral counts of Bhabha at time n-15sec
  UInt_t fHypInt;               // holds the integral counts of Hyp collected in 15 sec at time n
  UInt_t fHypInt0;              // holds the integral counts of Hyp at time n-15sec
  UInt_t fSavedEvNum;           // holds the hardware event number at time n-1

  // files:
  //   0: selected for DAFNE
  //   1: all scalers
  TString       fPath[2];       // path to the data files
  int           fFastFd[2];     // fast raw-file descriptors (written via low-level system calls)
  std::ofstream fRawFile[2];    // (slow) raw-file streams

private:
  ClassDef(TFndPreanScalers, 0) // preanalyzer for scaler data
};

#endif // FROOT_TFndPreanScalers

---