YodaProfiler/inc/PamelaDBOperations.h

#ifndef PAMELA_DB_OPERATIONS_H
#define PAMELA_DB_OPERATIONS_H

#include <iostream>
#include <list>

#include <TSQLServer.h>
#include <EventHeader.h>
#include <PscuHeader.h>
#include <mcmd/McmdEvent.h>
#include <mcmd/McmdRecord.h>
#include <RunHeaderEvent.h>
#include <RunTrailerEvent.h>
#include <CalibCalPedEvent.h>
#include <CalibS4Event.h>
#include <CalibTrk1Event.h>
#include <CalibTrk2Event.h>
#include <varDump/VarDumpEvent.h>
#include <varDump/VarDumpRecord.h>
#include <physics/S4/S4Event.h>

#include <GLTables.h>

#include <sgp4.h>

using namespace pamela;

/**
 * Collections of Pamela specific operations over a database
 */
class PamelaDBOperations {

 private:
    TSQLServer *conn;
    TFile *file;
    //
    RunHeaderEvent *runh;
    EventHeader *ehh;
    PscuHeader *phh;
    RunTrailerEvent *runt;
    EventHeader *eht;
    PscuHeader *pht;
    //
    GL_RUN *glrun;
    //
    TString filerawname;
    TString filerootname;
    //
    UInt_t tsync;
    UInt_t toffset;
    //
    //    Long64_t olderthan;
    UInt_t dworbit;
    //
    UInt_t BOOTNO;
    UInt_t obt0;
    UInt_t id;
    UInt_t idroot;
    UInt_t pktfirst;
    ULong64_t obtfirst;
    ULong64_t upperobt;
    UInt_t upperpkt;
    UInt_t upperentry;
    Int_t rtev;
    Int_t rhev;
    //
    // calibration variables
    //
    Int_t t1;
    Int_t t2;
    UInt_t fromtime;
    UInt_t obt1;
    UInt_t pkt1;
    UInt_t obt2;
    UInt_t pkt2;
    UInt_t valid;
    //
    //
    Bool_t NOBOOT;
    Bool_t debug;

    // Path to tle file
    TString tlefilename;
        
    // flag to control profiler actions
    Bool_t INSERT_RAW;
    Bool_t INSERT_ROOT;
    Bool_t VALIDATE;
    Bool_t NOFRAG;
    
    TDatime *clean_time;
    
    //
    typedef std::list<const char*> pcksList;
    static void getPacketsNames(pcksList &pcksNames){
        pcksNames.push_back("PhysEndRun");
        pcksNames.push_back("CalibCalPulse1");
        pcksNames.push_back("CalibCalPulse2");
        pcksNames.push_back("Physics");
        pcksNames.push_back("CalibTrkBoth");
        pcksNames.push_back("CalibTrk1");
        pcksNames.push_back("CalibTrk2");
        pcksNames.push_back("CalibTof");
        pcksNames.push_back("CalibS4");
        pcksNames.push_back("CalibCalPed");
        pcksNames.push_back("Calib1_Ac1");
        pcksNames.push_back("Calib2_Ac1");
        pcksNames.push_back("Calib1_Ac2");
        pcksNames.push_back("Calib2_Ac2");
        pcksNames.push_back("CalibCal");
        pcksNames.push_back("RunHeader");
        pcksNames.push_back("RunTrailer");
        pcksNames.push_back("CalibHeader");
        pcksNames.push_back("CalibTrailer");
        pcksNames.push_back("InitHeader");
        pcksNames.push_back("InitTrailer");
        pcksNames.push_back("EventTrk");
        pcksNames.push_back("Log");
        pcksNames.push_back("VarDump");
        pcksNames.push_back("ArrDump");
        pcksNames.push_back("TabDump");
        pcksNames.push_back("Tmtc");
        pcksNames.push_back("Mcmd");
        pcksNames.push_back("ForcedFECmd");
        pcksNames.push_back("Ac1Init");
        pcksNames.push_back("CalInit");
        pcksNames.push_back("TrkInit");
        pcksNames.push_back("TofInit");
        pcksNames.push_back("TrgInit");
        pcksNames.push_back("NdInit");
        pcksNames.push_back("S4Init");
        pcksNames.push_back("Ac2Init");
        pcksNames.push_back("CalAlarm");
        pcksNames.push_back("Ac1Alarm");
        pcksNames.push_back("TrkAlarm");
        pcksNames.push_back("TrgAlarm");
        pcksNames.push_back("TofAlarm");
        pcksNames.push_back("S4Alarm");
        pcksNames.push_back("Ac2Alarm");                
        pcksNames.push_back("TsbT");
        pcksNames.push_back("TsbB");
    };
    //
    // Functions
    //
    void HandleRun();
    void HandleRunFragments(Bool_t mishead, Bool_t mistrail, UInt_t firstev, UInt_t lastev);
    void HandleMissingHoT(Bool_t mishead, Bool_t mistrail, UInt_t firstev, UInt_t lastev);
    void HandleSuspiciousRun();
    void FillClass();
    void FillClass(Bool_t mishead, Bool_t mistrail, UInt_t firstev, UInt_t lastev);
    void HandleTRK_CALIB(Bool_t pk1, Bool_t pk2);
    //
    void RemoveCALIBS();
    void ValidationOFF();
    void ReArrangeRUNS();
    void RemoveRUNS();
    void RemoveFILES();
    //
    Bool_t IsDebug(){return(debug);};
    Bool_t IsRunAlreadyInserted();
    Bool_t IsRunConsistent(Bool_t mishead, Bool_t mistrail, UInt_t &firstev, UInt_t &lastev);
    //
    Bool_t MissingTRK_CALIB(UInt_t t1,UInt_t t2);
    //
    UInt_t PKT(UInt_t pkt_num);
    //
    ULong64_t OBT(UInt_t obt);
    //
    UInt_t AssignRunID();

    // GL_TLE related functions
    int insertTle(cTle*);
    bool isTlePresent(cTle*);

 public: 
    //
    PamelaDBOperations(TString host, TString user, TString password, TString filerawname, TString filerootname, UInt_t boot, UInt_t tsync, UInt_t obt0, Bool_t debug, TString tlefilename); // constructor
    //
    void Close(); // destructor
    //
    //
    // Setters
    //
    void SetConnection(TString host, TString user, TString password);
    void SetBOOTnumber(UInt_t boot);
    void SetRawName(TString str);
    void SetRootName(TString str);
    void SetDebugFlag(Bool_t debug);
    void SetID_RAW(UInt_t idr);
    void SetID_ROOT(UInt_t idr);
    void SetTsync(UInt_t ts);
    void SetObt0(UInt_t ts); 
    void SetCommonGLRUN(UInt_t absth, UInt_t abstt);
    void SetNOBOOT(Bool_t noboot);
    void SetOlderThan(Long64_t oldthan);
    void SetTLEPath(TString str);
    void SetOrbitNo();
    void SetNoFrag(Bool_t nf);
    //
    Bool_t SetID_RAW();
    //
    Int_t SetUpperLimits();
    //
    // Getters
    //
    Bool_t GetNOBOOT(){return(NOBOOT);};
    //
    UInt_t GetID_RAW(){return(id);};     
    UInt_t GetID_ROOT(){return(idroot);};
    UInt_t GetBOOTnumber(){return(BOOTNO);};
    //
    UInt_t GetAbsTime(UInt_t obt);
    UInt_t GetTsync(){return(tsync);};
    //
    const PacketType* GetPacketType(const char* type);
    //
    TString GetRawFile(){return((TString)gSystem->BaseName(filerawname.Data()));};
    TString GetRawPath(){return((TString)gSystem->DirName(filerawname.Data())+'/');};
    TString GetRootFile(){return((TString)gSystem->BaseName(filerootname.Data()));};
    TString GetRootPath(){return((TString)gSystem->DirName(filerootname.Data())+'/');};
    TString GetRootName(){return(filerootname);};
    TString GetRawName(){return(filerawname);};
        
    const char*  GetCleanTime(){return clean_time->AsSQLString();};
    //
    // Functions
    //
    Int_t assignBOOT_NUMBER();
    Int_t insertPamelaRootFile();
    Int_t insertPamelaRawFile();
    Int_t insertPamelaGL_TIMESYNC(); 
    Int_t insertPamelaRUN(); 
    Int_t insertCALO_CALIB(); 
    Int_t insertTRK_CALIB(); 
    Int_t insertS4_CALIB(); 
    Int_t CleanGL_RUN_FRAGMENTS();
    Int_t CleanGL_RUN_FRAGMENTS(TString fcleanfile);
    Int_t ValidateRuns();
    Int_t ValidateRuns(TString valfile);
    Int_t assignVALIDATION(UInt_t ,Bool_t );
    Int_t removeFile(TString rootfilename);
    //
    //    void OpenFile();
    void CheckValidate(Long64_t olderthan);
    void CheckConnection();
    void CheckFile();
    //
        
    Bool_t NoFrag(){return(NOFRAG);};
    Bool_t InsertRoot(){return(INSERT_ROOT);};
    Bool_t InsertRaw(){return(INSERT_RAW);};
    Bool_t Validate(){return(VALIDATE);};

    // Functions for TLE
    Int_t populateTLE();
        
};
#endif /* PAMELA_DB_OPERATIONS_H */
1	mocchiut	1.1	#ifndef PAMELA_DB_OPERATIONS_H
2			#define PAMELA_DB_OPERATIONS_H
3
4			#include <iostream>
5			#include <list>
6	mocchiut	1.6
7	mocchiut	1.1	#include <TSQLServer.h>
8			#include <EventHeader.h>
9			#include <PscuHeader.h>
10			#include <mcmd/McmdEvent.h>
11			#include <mcmd/McmdRecord.h>
12			#include <RunHeaderEvent.h>
13			#include <RunTrailerEvent.h>
14			#include <CalibCalPedEvent.h>
15			#include <CalibS4Event.h>
16			#include <CalibTrk1Event.h>
17			#include <CalibTrk2Event.h>
18			#include <varDump/VarDumpEvent.h>
19			#include <varDump/VarDumpRecord.h>
20			#include <physics/S4/S4Event.h>
21	mocchiut	1.6
22	mocchiut	1.1	#include <GLTables.h>
23
24	mocchiut	1.8	#include <sgp4.h>
25	mocchiut	1.6
26	mocchiut	1.1	using namespace pamela;
27
28			/**
29			* Collections of Pamela specific operations over a database
30			*/
31			class PamelaDBOperations {
32
33			private:
34			TSQLServer *conn;
35			TFile *file;
36			//
37			RunHeaderEvent *runh;
38			EventHeader *ehh;
39			PscuHeader *phh;
40			RunTrailerEvent *runt;
41			EventHeader *eht;
42			PscuHeader *pht;
43			//
44			GL_RUN *glrun;
45			//
46			TString filerawname;
47			TString filerootname;
48			//
49			UInt_t tsync;
50			UInt_t toffset;
51			//
52	mocchiut	1.7	// Long64_t olderthan;
53			UInt_t dworbit;
54	mocchiut	1.2	//
55	mocchiut	1.1	UInt_t BOOTNO;
56			UInt_t obt0;
57			UInt_t id;
58			UInt_t idroot;
59			UInt_t pktfirst;
60			ULong64_t obtfirst;
61			ULong64_t upperobt;
62			UInt_t upperpkt;
63			UInt_t upperentry;
64			Int_t rtev;
65			Int_t rhev;
66			//
67			// calibration variables
68			//
69			Int_t t1;
70			Int_t t2;
71			UInt_t fromtime;
72			UInt_t obt1;
73			UInt_t pkt1;
74			UInt_t obt2;
75			UInt_t pkt2;
76			UInt_t valid;
77			//
78			//
79			Bool_t NOBOOT;
80			Bool_t debug;
81	mocchiut	1.6
82			// Path to tle file
83			TString tlefilename;
84	pam-fi	1.4
85	mocchiut	1.7	// flag to control profiler actions
86			Bool_t INSERT_RAW;
87			Bool_t INSERT_ROOT;
88			Bool_t VALIDATE;
89	mocchiut	1.9	Bool_t NOFRAG;
90	mocchiut	1.7
91			TDatime *clean_time;
92
93	mocchiut	1.1	//
94			typedef std::list<const char*> pcksList;
95			static void getPacketsNames(pcksList &pcksNames){
96			pcksNames.push_back("PhysEndRun");
97			pcksNames.push_back("CalibCalPulse1");
98			pcksNames.push_back("CalibCalPulse2");
99			pcksNames.push_back("Physics");
100			pcksNames.push_back("CalibTrkBoth");
101			pcksNames.push_back("CalibTrk1");
102			pcksNames.push_back("CalibTrk2");
103			pcksNames.push_back("CalibTof");
104			pcksNames.push_back("CalibS4");
105			pcksNames.push_back("CalibCalPed");
106			pcksNames.push_back("Calib1_Ac1");
107			pcksNames.push_back("Calib2_Ac1");
108			pcksNames.push_back("Calib1_Ac2");
109			pcksNames.push_back("Calib2_Ac2");
110			pcksNames.push_back("CalibCal");
111			pcksNames.push_back("RunHeader");
112			pcksNames.push_back("RunTrailer");
113			pcksNames.push_back("CalibHeader");
114			pcksNames.push_back("CalibTrailer");
115			pcksNames.push_back("InitHeader");
116			pcksNames.push_back("InitTrailer");
117			pcksNames.push_back("EventTrk");
118			pcksNames.push_back("Log");
119			pcksNames.push_back("VarDump");
120			pcksNames.push_back("ArrDump");
121			pcksNames.push_back("TabDump");
122			pcksNames.push_back("Tmtc");
123			pcksNames.push_back("Mcmd");
124			pcksNames.push_back("ForcedFECmd");
125			pcksNames.push_back("Ac1Init");
126			pcksNames.push_back("CalInit");
127			pcksNames.push_back("TrkInit");
128			pcksNames.push_back("TofInit");
129			pcksNames.push_back("TrgInit");
130			pcksNames.push_back("NdInit");
131			pcksNames.push_back("S4Init");
132			pcksNames.push_back("Ac2Init");
133			pcksNames.push_back("CalAlarm");
134			pcksNames.push_back("Ac1Alarm");
135			pcksNames.push_back("TrkAlarm");
136			pcksNames.push_back("TrgAlarm");
137			pcksNames.push_back("TofAlarm");
138			pcksNames.push_back("S4Alarm");
139			pcksNames.push_back("Ac2Alarm");
140			pcksNames.push_back("TsbT");
141			pcksNames.push_back("TsbB");
142			};
143			//
144			// Functions
145			//
146			void HandleRun();
147			void HandleRunFragments(Bool_t mishead, Bool_t mistrail, UInt_t firstev, UInt_t lastev);
148			void HandleMissingHoT(Bool_t mishead, Bool_t mistrail, UInt_t firstev, UInt_t lastev);
149			void HandleSuspiciousRun();
150			void FillClass();
151			void FillClass(Bool_t mishead, Bool_t mistrail, UInt_t firstev, UInt_t lastev);
152			void HandleTRK_CALIB(Bool_t pk1, Bool_t pk2);
153			//
154	mocchiut	1.9	void RemoveCALIBS();
155			void ValidationOFF();
156			void ReArrangeRUNS();
157			void RemoveRUNS();
158			void RemoveFILES();
159			//
160	mocchiut	1.1	Bool_t IsDebug(){return(debug);};
161			Bool_t IsRunAlreadyInserted();
162			Bool_t IsRunConsistent(Bool_t mishead, Bool_t mistrail, UInt_t &firstev, UInt_t &lastev);
163	mocchiut	1.5	//
164			Bool_t MissingTRK_CALIB(UInt_t t1,UInt_t t2);
165			//
166	mocchiut	1.1	UInt_t PKT(UInt_t pkt_num);
167			//
168			ULong64_t OBT(UInt_t obt);
169			//
170	mocchiut	1.7	UInt_t AssignRunID();
171	mocchiut	1.1
172	mocchiut	1.6	// GL_TLE related functions
173			int insertTle(cTle*);
174			bool isTlePresent(cTle*);
175
176	mocchiut	1.1	public:
177			//
178	mocchiut	1.6	PamelaDBOperations(TString host, TString user, TString password, TString filerawname, TString filerootname, UInt_t boot, UInt_t tsync, UInt_t obt0, Bool_t debug, TString tlefilename); // constructor
179	mocchiut	1.1	//
180			void Close(); // destructor
181			//
182			//
183			// Setters
184			//
185			void SetConnection(TString host, TString user, TString password);
186			void SetBOOTnumber(UInt_t boot);
187			void SetRawName(TString str);
188			void SetRootName(TString str);
189			void SetDebugFlag(Bool_t debug);
190			void SetID_RAW(UInt_t idr);
191			void SetID_ROOT(UInt_t idr);
192			void SetTsync(UInt_t ts);
193			void SetObt0(UInt_t ts);
194			void SetCommonGLRUN(UInt_t absth, UInt_t abstt);
195			void SetNOBOOT(Bool_t noboot);
196	mocchiut	1.2	void SetOlderThan(Long64_t oldthan);
197	mocchiut	1.6	void SetTLEPath(TString str);
198	mocchiut	1.7	void SetOrbitNo();
199	mocchiut	1.9	void SetNoFrag(Bool_t nf);
200	mocchiut	1.1	//
201			Bool_t SetID_RAW();
202			//
203			Int_t SetUpperLimits();
204			//
205			// Getters
206			//
207			Bool_t GetNOBOOT(){return(NOBOOT);};
208			//
209			UInt_t GetID_RAW(){return(id);};
210			UInt_t GetID_ROOT(){return(idroot);};
211			UInt_t GetBOOTnumber(){return(BOOTNO);};
212			//
213			UInt_t GetAbsTime(UInt_t obt);
214			UInt_t GetTsync(){return(tsync);};
215			//
216			const PacketType* GetPacketType(const char* type);
217			//
218			TString GetRawFile(){return((TString)gSystem->BaseName(filerawname.Data()));};
219			TString GetRawPath(){return((TString)gSystem->DirName(filerawname.Data())+'/');};
220			TString GetRootFile(){return((TString)gSystem->BaseName(filerootname.Data()));};
221			TString GetRootPath(){return((TString)gSystem->DirName(filerootname.Data())+'/');};
222			TString GetRootName(){return(filerootname);};
223			TString GetRawName(){return(filerawname);};
224	pam-fi	1.4
225	mocchiut	1.9	const char* GetCleanTime(){return clean_time->AsSQLString();};
226	mocchiut	1.1	//
227			// Functions
228			//
229			Int_t assignBOOT_NUMBER();
230			Int_t insertPamelaRootFile();
231			Int_t insertPamelaRawFile();
232			Int_t insertPamelaGL_TIMESYNC();
233			Int_t insertPamelaRUN();
234			Int_t insertCALO_CALIB();
235			Int_t insertTRK_CALIB();
236			Int_t insertS4_CALIB();
237	mocchiut	1.2	Int_t CleanGL_RUN_FRAGMENTS();
238	mocchiut	1.9	Int_t CleanGL_RUN_FRAGMENTS(TString fcleanfile);
239	mocchiut	1.2	Int_t ValidateRuns();
240	mocchiut	1.9	Int_t ValidateRuns(TString valfile);
241	mocchiut	1.5	Int_t assignVALIDATION(UInt_t ,Bool_t );
242	mocchiut	1.9	Int_t removeFile(TString rootfilename);
243	mocchiut	1.5	//
244			// void OpenFile();
245			void CheckValidate(Long64_t olderthan);
246	pam-fi	1.4	void CheckConnection();
247	mocchiut	1.5	void CheckFile();
248	mocchiut	1.1	//
249	pam-fi	1.4
250	mocchiut	1.9	Bool_t NoFrag(){return(NOFRAG);};
251	mocchiut	1.6	Bool_t InsertRoot(){return(INSERT_ROOT);};
252			Bool_t InsertRaw(){return(INSERT_RAW);};
253			Bool_t Validate(){return(VALIDATE);};
254
255			// Functions for TLE
256			Int_t populateTLE();
257	pam-fi	1.4
258	mocchiut	1.1	};
259			#endif /* PAMELA_DB_OPERATIONS_H */