DbuDaqMonitorModule.h

Go to the documentation of this file.

#ifndef DBUDAQMONITORMODULE_H
#define DBUDAQMONITORMODULE_H

#ifndef __CINT__

// $Id: DbuDaqMonitorModule.h,v 1.11 2007/04/26 14:21:39 west Exp $
//
#ifndef JOBCMODULE_H
#include "JobControl/JobCModule.h"
#endif

class JobCommand;
class MomNavigator;
class RawRecord;
#include "Validity/VldTimeStamp.h"
#include <string>

class DbiStatement;

class DbuSubRunSummary;
class RawPedestalTableBlock;
class RawSparsifierTableBlock;

class DbuDaqMonitorModule : public JobCModule 
{

public:
   DbuDaqMonitorModule();
   ~DbuDaqMonitorModule();
  
   JobCResult      Ana(const MomNavigator *mom);
   void            BeginJob();
   void            EndJob();

   void            Config(const Registry& r);
   const Registry& DefaultConfig() const;
   void            Help();
   
   void HandleCommand(JobCommand* cmd);

private:

   void         Update_ENV_TSQL();
   void         GetCommentFieldName();
   void         CheckForRowCounterColumn();
   JobCResult   ProcessRawRecord(const RawRecord* rawrec);
   Bool_t       WriteSubRunSummaryEntry(Bool_t remove);

   Bool_t       WriteVaChipPedsEntry(const RawPedestalTableBlock* pedblk);
   Bool_t       WriteVaChipSparsEntry(const RawSparsifierTableBlock* sparsblk);

   void         InitTSQLConnection();
   Bool_t       ClearOldSubRun(Int_t aggrno);
   Bool_t       ResequenceSubRun(Int_t aggrno);

   std::string        fURL;
   Int_t              fDbNo;
   DbiStatement*      fDbiStatement;
   Int_t              fHeartbeatIntervalSec; 

   DbuSubRunSummary*  fCurrentSubRun;
   Int_t              fCurrentModified;
   Int_t              fWrittenNTimes;
   Bool_t             fRecSubRunSummary;
   Bool_t             fRecAtStart;
   std::string        fCommentFieldName;
   Bool_t             fHasRowCounter;
                                     
   Bool_t             fRecVaChipPeds;
   Bool_t             fRecVaChipSpars;
   Int_t              fVaChipVldSec;

};

#endif // __CINT__
#endif // DBUDAQMONITORMODULE_H

---