chewbacca/PamOffLineSW/PacketUser.h

//============================================================================
// $Id: PacketUser.h,v 1.3 2008/12/18 12:58:37 mocchiut Exp $ 
// Description : 
//============================================================================
#ifndef PACKETUSER_H_
#define PACKETUSER_H_
#include "PamInclude.h"
#include <TTimeStamp.h>
#include "../event/PacketType.h"
#include "EventReader.h"

#include "TROOT.h" //ROOT version > 5.14
#include "TSystem.h" // EMI

using namespace pamela;
using namespace pamela::techmodel;

namespace PamOffLineSW
{

class PacketUser
{

public: 
        //destructor
        virtual ~PacketUser();
        //the interface called by the external module: saves packets in ROOT files using the YODA part 
        void usePKT(char*& headerPkt, char*& pamPkt, long int length, bool isCons, bool isPKTGood, const PacketType* type,
                        unsigned long int counter, unsigned long int obt);

        //return the instance of the singleton
        static PacketUser& getInstance();       
        //to be called at the end of the game
        void FinishLastGroup();

private:
        //the Event Reader handler
        pamela::techmodel::EventReader* reader; 
        //the Pamela Run handler,  one for ech ROOT file created
        pamela::PamelaRun* pRun;
        //Constructor
        PacketUser();
        //The istance
        static PacketUser instance;
        //How many times I found a discontinuity
        static int numDiscontinity;
        //How many packets arrived here,        
        static int numPKT; 
        //How many packetS saved in each ROOT files
        static int numPKTSaved; 
        //Name of the final ROOT file
        char rootfilename[80];  
        //pkt counter of the first packet of the group
        unsigned long int pkt_number_init;
        //pkt OBT of the first packet of the group
        unsigned long int obt_init;
        //pkt counter of the last packet of the group
        unsigned long int pkt_number_last;
        //pkt OBT of the last packet of the group
        unsigned long int obt_last;
        //the first packet's absolute time
        unsigned long int real_time_init;
        //the last packet's absolute time
        unsigned long int real_time_last;
        //tymesync and OBT informations 
        unsigned long int obt_time_sync;
        unsigned long int last_time_sync_info;
        // (tassa) keep previous value of time_sync
        unsigned long int obt_time_sync_prevvalue;
        unsigned long int last_time_sync_info_prevvalue;
        bool time_is_estimated;
        //TimeOffset used to obtain absolute time 
        unsigned long int timeOffset;
        //part of the ROOT filename used to retrieve timeOffset for special files
        char nnnn_mmm_ppp[80];
        //boot number 
        unsigned long int boot_number;
        unsigned long int boot_number_prevvalue; 
        //(tassa)
        unsigned int id_to_recover[1000];
        int id_to_recover_index;   
        //number of packets with problems( in general CRC problems) detected in EventReader: 
        int bad_pkt_EventReader;
        //num  ber of Calibration packets with problems( in general CRC problems) detected in EventReader:
        int bad_pkt_CalibReader;
        //number of good packets that comes from one or more corrupted cadres
        int bad_pkt;
        
        //marco_new: 
   //the ID of the current ROOT file in table Table_ROOT_Good
         unsigned int my_id;

//number of good Calibration packets in the ROOT files 
//      int good_pkt_Calib;//maybe I will use this in future

        //the table name in our DB for the ROOT files 
        char* Table_ROOT_Good;
        //the table name in our DB where I put the ROOT files that have not Real time associated
        char* Table_ROOT_Bad;
        //table used to retrieve TimeOffset
        char* Table_GL_RESURS_OFFSET;   
        //the table name in our DB for MERGING
        char* Table_ROOT_Merging; 
        
        //starts a new root file
        void StartGroup();      
        //set the value of the counter and obt of the first packet of the group
        void setInit(unsigned long int counter, unsigned long int obt);
        //finish the old ROOT file
        void FinishGroup(char * filename);
        //set the value of the counter and obt of the last packet of the group 
        void setLast(unsigned long int counter, unsigned long int obt);         
        //retrieve OBT_TIME_SYNC and LAST_TIME_SYNC_INFO from packet
        void setTimeSync(char* packet, long int pktLenght, const PacketType* type);
        //retrieve boot number
        void setBootNumber(char* packet, long int pktLenght, const PacketType* type);
        //set real_time_init and real_time_last
        void setReal_Time();
        //
        void recover_boot_number();

        //retrieve the timeOffset from table=Table_GL_RESURS_OFFSET
        unsigned long int retrieveTimeOffset(char * table);

        unsigned  int select_maxIDN_DB(char* table_name);

        //function that saves informations in our DB    
        bool saveROOT_DB(char* table_name, char* folder_name, char* file_name, 
                        unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
                        unsigned long int obt_in, unsigned long int obt_fin,
                        unsigned long int  oT_sync, unsigned long int lT_sync_info,        
                        unsigned long int mtime_init,   unsigned long int mtime_last,
                        unsigned long int mboot_num,
                        unsigned long int time_offset, 
                        int bad_pkt, int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved,
                        char* nome_input,bool _time_is_estimated);
        
        ///new part merging

                //tipi di relazioni che il ROOT file puo' avere con un ROOT gia salvatto in DB          
                //0 =AFTER  se c'e' una sovrapposizione temporale parziale, inizia dopo l'inizio di quello associato e finisce dopo la sua fine
                //1 =BEFORE se c'e' una sovrapposizione temporale parziale, ossia finisce prima della fine di quello associato ma inizia prima
                //2 =SMALLER se c'e' una sovrapposizione temporale parziale: e' contenuto nel ROOT file associato
                //3 =BIGGER  se c'e' una sovrapposizione temporale parziale: contiene il ROOT file associato    
                enum type_Rel_ROOT{
                AFTER,     //se inizia dentro e finisce fuori
                        BEFORE,    //inizia prima ma finisce dentro
                        SMALLER,    //se inizia e finisce dentro 
                        BIGGER      //se inizia prima e finisce dopo                                            
                };
        
        
        bool merge_ROOTfiles(); 


        bool saveMergeROOT_DB(char* table_name, 
                           unsigned  int root_id,
                                unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
                                unsigned long int obt_in, unsigned long int obt_fin,
                        unsigned long int mtime_init,   unsigned long int mtime_last, 
                        unsigned long int mboot_num,
                                double percentage);

        
        bool updateMergeROOT_DB(char* table_name,
                        unsigned  int root_id,
                        unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
                        unsigned long int obt_in, unsigned long int obt_fin,
                unsigned long int mtime_init,   unsigned long int mtime_last,
                        unsigned long int mboot_num,
                        double bad_perc,
                        unsigned int ID_record, type_Rel_ROOT type_rel);
        
        //search in DB if there are ROOT files in the temporal range of interest and with the given relation
        TSQLResult* Select_merging(char* table_name, unsigned long int mtime_init, unsigned long int mtime_last, type_Rel_ROOT type_rel);

        //Lock the tableTobeLocked table or all the tables I know if par=NULL
        int LockTables(char* tableTobeLocked);
        //Unlock all the lockedtables
        int UnLockTables(); 
        //Open DB connection and lock table
        void OpenDBConnection(char* tableTobeLocked);
        //Close DB connection and UNlock tables
        void CloseDBConnection(); 

/***************************************************************************************/
        //UNUSED: return the system time in ms
        unsigned long long Record_Time();
        //DBG functions that saves pkt
        void saveALL_PKT(char* headerPkt, char* pamPkt, long int length, bool append);
        //function used to save in a file the packet
        void savePKT_file(char* headerPkt, 
                        char* pamPkt, 
                        long int length, 
                        bool append,
                        char* nomefile);

};

}

#endif /*PACKETUSER_H_*/
1	mocchiut	1.1	//============================================================================
2	mocchiut	1.4	// $Id: PacketUser.h,v 1.3 2008/12/18 12:58:37 mocchiut Exp $
3	mocchiut	1.1	// Description :
4			//============================================================================
5			#ifndef PACKETUSER_H_
6			#define PACKETUSER_H_
7			#include "PamInclude.h"
8			#include <TTimeStamp.h>
9			#include "../event/PacketType.h"
10			#include "EventReader.h"
11
12			#include "TROOT.h" //ROOT version > 5.14
13	mocchiut	1.4	#include "TSystem.h" // EMI
14	mocchiut	1.1
15			using namespace pamela;
16			using namespace pamela::techmodel;
17
18			namespace PamOffLineSW
19			{
20
21			class PacketUser
22			{
23
24			public:
25			//destructor
26			virtual ~PacketUser();
27			//the interface called by the external module: saves packets in ROOT files using the YODA part
28			void usePKT(char& headerPkt, char& pamPkt, long int length, bool isCons, bool isPKTGood, const PacketType* type,
29			unsigned long int counter, unsigned long int obt);
30
31			//return the instance of the singleton
32			static PacketUser& getInstance();
33			//to be called at the end of the game
34			void FinishLastGroup();
35
36			private:
37			//the Event Reader handler
38			pamela::techmodel::EventReader* reader;
39			//the Pamela Run handler, one for ech ROOT file created
40			pamela::PamelaRun* pRun;
41			//Constructor
42			PacketUser();
43			//The istance
44			static PacketUser instance;
45			//How many times I found a discontinuity
46			static int numDiscontinity;
47			//How many packets arrived here,
48			static int numPKT;
49			//How many packetS saved in each ROOT files
50			static int numPKTSaved;
51			//Name of the final ROOT file
52			char rootfilename[80];
53			//pkt counter of the first packet of the group
54			unsigned long int pkt_number_init;
55			//pkt OBT of the first packet of the group
56			unsigned long int obt_init;
57			//pkt counter of the last packet of the group
58			unsigned long int pkt_number_last;
59			//pkt OBT of the last packet of the group
60			unsigned long int obt_last;
61			//the first packet's absolute time
62			unsigned long int real_time_init;
63			//the last packet's absolute time
64			unsigned long int real_time_last;
65			//tymesync and OBT informations
66			unsigned long int obt_time_sync;
67			unsigned long int last_time_sync_info;
68	mocchiut	1.3	// (tassa) keep previous value of time_sync
69			unsigned long int obt_time_sync_prevvalue;
70			unsigned long int last_time_sync_info_prevvalue;
71			bool time_is_estimated;
72	mocchiut	1.1	//TimeOffset used to obtain absolute time
73			unsigned long int timeOffset;
74			//part of the ROOT filename used to retrieve timeOffset for special files
75			char nnnn_mmm_ppp[80];
76	mocchiut	1.2	//boot number
77	mocchiut	1.1	unsigned long int boot_number;
78	mocchiut	1.3	unsigned long int boot_number_prevvalue;
79			//(tassa)
80			unsigned int id_to_recover[1000];
81			int id_to_recover_index;
82	mocchiut	1.1	//number of packets with problems( in general CRC problems) detected in EventReader:
83			int bad_pkt_EventReader;
84			//num ber of Calibration packets with problems( in general CRC problems) detected in EventReader:
85			int bad_pkt_CalibReader;
86			//number of good packets that comes from one or more corrupted cadres
87			int bad_pkt;
88
89			//marco_new:
90			//the ID of the current ROOT file in table Table_ROOT_Good
91			unsigned int my_id;
92
93	mocchiut	1.2	//number of good Calibration packets in the ROOT files
94			// int good_pkt_Calib;//maybe I will use this in future
95	mocchiut	1.1
96			//the table name in our DB for the ROOT files
97			char* Table_ROOT_Good;
98			//the table name in our DB where I put the ROOT files that have not Real time associated
99			char* Table_ROOT_Bad;
100			//table used to retrieve TimeOffset
101			char* Table_GL_RESURS_OFFSET;
102			//the table name in our DB for MERGING
103			char* Table_ROOT_Merging;
104
105			//starts a new root file
106			void StartGroup();
107			//set the value of the counter and obt of the first packet of the group
108			void setInit(unsigned long int counter, unsigned long int obt);
109			//finish the old ROOT file
110			void FinishGroup(char * filename);
111			//set the value of the counter and obt of the last packet of the group
112			void setLast(unsigned long int counter, unsigned long int obt);
113			//retrieve OBT_TIME_SYNC and LAST_TIME_SYNC_INFO from packet
114			void setTimeSync(char* packet, long int pktLenght, const PacketType* type);
115			//retrieve boot number
116			void setBootNumber(char* packet, long int pktLenght, const PacketType* type);
117			//set real_time_init and real_time_last
118			void setReal_Time();
119	mocchiut	1.3	//
120			void recover_boot_number();
121
122	mocchiut	1.1	//retrieve the timeOffset from table=Table_GL_RESURS_OFFSET
123			unsigned long int retrieveTimeOffset(char * table);
124
125			unsigned int select_maxIDN_DB(char* table_name);
126
127			//function that saves informations in our DB
128			bool saveROOT_DB(char* table_name, char* folder_name, char* file_name,
129			unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
130			unsigned long int obt_in, unsigned long int obt_fin,
131			unsigned long int oT_sync, unsigned long int lT_sync_info,
132			unsigned long int mtime_init, unsigned long int mtime_last,
133			unsigned long int mboot_num,
134			unsigned long int time_offset,
135			int bad_pkt, int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved,
136	mocchiut	1.3	char* nome_input,bool _time_is_estimated);
137	mocchiut	1.1
138			///new part merging
139
140	mocchiut	1.2	//tipi di relazioni che il ROOT file puo' avere con un ROOT gia salvatto in DB
141			//0 =AFTER se c'e' una sovrapposizione temporale parziale, inizia dopo l'inizio di quello associato e finisce dopo la sua fine
142			//1 =BEFORE se c'e' una sovrapposizione temporale parziale, ossia finisce prima della fine di quello associato ma inizia prima
143			//2 =SMALLER se c'e' una sovrapposizione temporale parziale: e' contenuto nel ROOT file associato
144			//3 =BIGGER se c'e' una sovrapposizione temporale parziale: contiene il ROOT file associato
145	mocchiut	1.1	enum type_Rel_ROOT{
146			AFTER, //se inizia dentro e finisce fuori
147			BEFORE, //inizia prima ma finisce dentro
148			SMALLER, //se inizia e finisce dentro
149			BIGGER //se inizia prima e finisce dopo
150			};
151
152	mocchiut	1.2
153	mocchiut	1.1
154
155			bool merge_ROOTfiles();
156
157
158			bool saveMergeROOT_DB(char* table_name,
159			unsigned int root_id,
160			unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
161			unsigned long int obt_in, unsigned long int obt_fin,
162			unsigned long int mtime_init, unsigned long int mtime_last,
163			unsigned long int mboot_num,
164			double percentage);
165
166
167			bool updateMergeROOT_DB(char* table_name,
168			unsigned int root_id,
169			unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
170			unsigned long int obt_in, unsigned long int obt_fin,
171			unsigned long int mtime_init, unsigned long int mtime_last,
172			unsigned long int mboot_num,
173			double bad_perc,
174			unsigned int ID_record, type_Rel_ROOT type_rel);
175
176	mocchiut	1.2	//search in DB if there are ROOT files in the temporal range of interest and with the given relation
177			TSQLResult* Select_merging(char* table_name, unsigned long int mtime_init, unsigned long int mtime_last, type_Rel_ROOT type_rel);
178	mocchiut	1.1
179			//Lock the tableTobeLocked table or all the tables I know if par=NULL
180			int LockTables(char* tableTobeLocked);
181			//Unlock all the lockedtables
182			int UnLockTables();
183			//Open DB connection and lock table
184			void OpenDBConnection(char* tableTobeLocked);
185			//Close DB connection and UNlock tables
186			void CloseDBConnection();
187
188			/***************************************************************************************/
189			//UNUSED: return the system time in ms
190			unsigned long long Record_Time();
191			//DBG functions that saves pkt
192			void saveALL_PKT(char* headerPkt, char* pamPkt, long int length, bool append);
193			//function used to save in a file the packet
194			void savePKT_file(char* headerPkt,
195			char* pamPkt,
196			long int length,
197			bool append,
198			char* nomefile);
199
200			};
201
202			}
203
204			#endif /PACKETUSER_H_/