DbuDaqFileModule.h

Go to the documentation of this file.

#ifndef DBUDAQFILEMODULE_H
#define DBUDAQFILEMODULE_H

#ifndef __CINT__

// $Id: DbuDaqFileModule.h,v 1.3 2005/06/15 17:20:51 rhatcher Exp $
//
#ifndef JOBCMODULE_H
#include "JobControl/JobCModule.h"
#endif

#include "Validity/VldContext.h"
class JobCommand;
class MomNavigator;
class RawRecord;
class RawDataBlock;

class DbuRunSummary;
class DbuDaqFileSummary;
class DbuDaqConfigFilesText;

class RawConfigFilesBlock;

class DbiStatement;
#include "DatabaseInterface/DbiSqlContext.h"

class DbuDaqFileModule : public JobCModule 
{

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

   // our own Begin/End Run/File methods
   void            MyOwn_BeginRun();
   void            MyOwn_EndRun();
   void            MyOwn_BeginFile();
   void            MyOwn_EndFile();

   // standard methods called by job control triggers
   void            BeginRun();
   void            EndRun();
   void            BeginFile();
   void            EndFile();

   void            Config(const Registry& r);
   const Registry& DefaultConfig() const;
   void            Help();
   
private:

   JobCResult   ProcessRawRecord(const RawRecord* rawrec);
   void         ProcessRawBlock(const RawDataBlock* rawblk, 
                                const Int_t run, const Short_t subrun, 
                                const std::string& strmname, 
                                const int strmindx);

   void         Update_ENV_TSQL();

   void         ExtractRunAndFile(const MomNavigator* mom);
   void         DoBeginEndRunAndFile();

   void         BuildExtContextAndSelect();

   void         HandleConfigFilesBlock(const RawConfigFilesBlock* rcfb);

   void         CommitDbuRunSummary();
   void         CommitDbuDaqFileSummary();
   void         CommitDbuDaqConfigFilesText(std::string& cft_md5, int& cft_seqno);
   void         WritePythonFile(bool dbWriteSuccess);

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

   Int_t                  fHeartbeatIntervalSec; 
   std::string            fAuxConfigFileList;

   DbuRunSummary*         fCurrentRunSummary;
   DbuDaqFileSummary*     fCurrentDaqFileSummary;
   DbuDaqConfigFilesText* fCurrentConfigFilesText;

   DbiSqlContext          fExtDbiSqlContext;
   std::string            fWhereSelect;

   // so we can fake up Begin/End  Run(int) File(const char*)
   // out of arg'less version
   Int_t                  fCurrentRun;
   Int_t                  fNextRun;
   Int_t                  fCurrentSubRun;
   Int_t                  fNextSubRun;
   Short_t                fCurrentRunType;
   Short_t                fNextRunType;
   Int_t                  fCurrentTimeFrameNum;
   Int_t                  fNextTimeFrameNum;
   VldContext             fCurrentVldContext;
   VldContext             fNextVldContext;
   std::string            fCurrentFile;
   std::string            fNextFile;
   
};

#endif // __CINT__
#endif // DBUDAQFILEMODULE_H

---