chewbacca/PamOffLineSW/PacketUser.h_30

//============================================================================
// $Id: PacketUser.h_30,v 1.1 2008/09/23 07:20:13 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

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;
        //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];

        //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 remove 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, const PacketType* type);
        //set real_time_init and real_time_last
        void setReal_Time();
        //retrieve the timeOffset
        unsigned long int retrieveTimeOffset();

        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 time_offset, 
                        int bad_pkt, int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved,
                        char* nome_input);
        
        ///new part merging

        //tipi di relazioni che il ROOT file puo' avere con un ROOT gia salvatto in DB
                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                                            
                };
        
        /*      
                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      
        */


        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, 
                        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,
                                double bad_perc,
                        unsigned int ID_record, type_Rel_ROOT type_rel);
        
        //unsigned int Return_IDN_merging(char* table_name, unsigned long int mtime_init, unsigned long int mtime_last, type_Rel_ROOT type_rel);
        TSQLResult* Select_merging(char* table_name, unsigned long int mtime_init, unsigned long int mtime_last, type_Rel_ROOT type_rel);


//lock unlock tables:
        int LockTables(char* table);
        int UnLockTables(); 

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