/[PAMELA software]/chewbacca/PamOffLineSW/PacketUser.cpp

Diff of /chewbacca/PamOffLineSW/PacketUser.cpp

Parent Directory | Revision Log | View Patch Patch

-revision 1.1 by mocchiut,
Tue Sep 23 07:20:12 2008 UTC
+revision 1.9 by mocchiut,
Thu Oct  1 08:55:42 2009 UTC
 Line 1
  //============================================================================
- // $Id: PacketUser.cpp,v 1.67 2008-09-05 14:33:48 messineo Exp $
+ // $Id: PacketUser.cpp,v 1.8 2009/08/05 18:48:42 pam-fi Exp $
  // Description :
  //============================================================================
  #include "PacketUser.h"
  #include <sys/time.h>
- namespace PamOffLineSW
+ namespace PamOffLineSW {
- {
  extern LogUtil* mainLogUtil;
- extern short compression ;
+ extern short compression;
- extern  char *outDir;
+ extern char *outDir;
  extern TSQLServer *sqlServer;
  extern bool multiFile;
  extern char* fni;
-Line 17 
 extern char * nome_output;
+Line 16 
 extern char * nome_output;
  extern bool is_new_route;
  extern unsigned int download;
- extern unsigned int  mmm_number;
+ extern unsigned int mmm_number;
  extern unsigned int orbit_number;
  extern unsigned long int time_Offset;
  extern bool tryMerge;
  //marco_new_01
-Line 28 
 extern bool single_connection;
+Line 27 
 extern bool single_connection;
  extern bool do_cont_check;
  //marco_new_31:
- extern char*  db_user;
+ extern char* db_user;
- extern char*  db_pwd;
+ extern char* db_pwd;
  extern char* connection;
+ //per tenere conto reset obt
+ extern unsigned long int max_pkt_obt;
+ #define TAGVALUELEN 4
+ extern char tag_value[TAGVALUELEN];
  PacketUser PacketUser::instance;
- int PacketUser::numDiscontinity=1;
- int PacketUser::numPKT=0;
- int PacketUser::numPKTSaved=0;
- PacketUser& PacketUser::getInstance()
- {
-         return instance;
- }
- PacketUser::PacketUser()
- {
-         gROOT->SetBatch(kTRUE);
-         numDiscontinity=1;
-         numPKTSaved=0;
-         numPKT=0;
-         pkt_number_init=0;
-         obt_init=0;
-         pkt_number_last=0;
-         obt_last=0;
-         obt_time_sync=0;
-         last_time_sync_info=0;
-         real_time_init=0;
-         real_time_last=0;
-         bad_pkt=0;
-         bad_pkt_EventReader=0;
-         bad_pkt_CalibReader=0;
-         reader= NULL;
-         pRun=NULL;
-         reader=new pamela::techmodel::EventReader();
-         Table_ROOT_Good="ROOT_TABLE";
-         Table_ROOT_Bad="ROOT_TABLE_BAD";
-         Table_GL_RESURS_OFFSET="GL_RESURS_OFFSET";
-         Table_ROOT_Merging="ROOT_TABLE_MERGING";
- //      good_pkt_Calib=0;
-         my_id=0;
-         boot_number=0;
- }
- PacketUser::~PacketUser()
- {
-         if(reader){delete reader; reader = NULL;}
-         numDiscontinity=1;
-         numPKTSaved=0;
-         numPKT=0;
-         pkt_number_init=0;
-         obt_init=0;
-         pkt_number_last=0;
-         obt_last=0;
-         obt_time_sync = 0;
-         last_time_sync_info = 0;
-         real_time_init=0;
-         real_time_last=0;
-         bad_pkt=0;
-         bad_pkt_EventReader=0;
-         bad_pkt_CalibReader=0;
- //      good_pkt_Calib=0;
-         my_id=0;
-         boot_number=0;
- }
- //Put the packet in a root file. Create a new ROOT file for each group of packets
- void PacketUser::usePKT(char*& headerPkt, char*& pamPkt, long int length, bool isCons, bool isPKTGood, const PacketType* type,
-                 unsigned long int counter, unsigned long int obt)
- {
-         //If the packet type was not recognised before
-         if(!type){return;}
- /*      //zzzzzz marco per debug mi salvo il pacchetto vardump
-         if(type==PacketType::VarDump)
-         {
-                 long int  dataLength = length - 2; //the block of data
-                 int b_offset = 4;
-                 while (b_offset < dataLength){
-                  boot_number  = (((UINT32)pamPkt[1+b_offset]<<24)&0xFF000000) + (((UINT32)pamPkt[2+b_offset]<<16)&0x00FF0000) +  (((UINT32)pamPkt[3+b_offset]<<8)&0x0000FF00) + (((UINT32)pamPkt[4+b_offset])&0x000000FF);
-                  cout<<"IN "<<numPKTSaved<<" boot_number "<<boot_number<<" al b_offset "<<b_offset<<" di "<<dataLength<<endl;
-                  b_offset = b_offset + 5;
-                 }
-                  cout<<"IN "<<numPKTSaved<<" FINAL boot_number "<<boot_number<<endl;
-                 savePKT_file(headerPkt,pamPkt,length,false,"vardump");
-                 numPKTSaved++;
-         }
-         return;
- */
-         //in order to start ...
-         if(numPKT==0)
-         {
-                 //marco_new_31: metto qui se voglio avere come in origine apertura Connessione all'inizio e chiusura alla fine
-                 //marco_new_01
-                 if(single_connection){
-                         OpenDBConnection(NULL);
-                 }
-                 setInit(counter,obt);
-                 StartGroup();
-         }
-         //here we know if the incoming packet can be considered consecutive to the previuos     one
-         if((!isCons)&&(numPKT!=0))
-         {
-                 setReal_Time();
-                 //closing the  group in file rootfilename
-                 FinishGroup(rootfilename);
-                 //numDiscontinity++;
-                 //se gia' e' cambiato download nn cambio numdisco
-                 if(!is_new_route) numDiscontinity++;
-                 //the current pkt will be placed in a new group: rootfilename
-                 setInit(counter,obt);
-                 StartGroup();
-         }
-         //add current packet to the group and calculate bad_pkt_EventReader and bad_pkt_CalibReader
-         int ret=
-         reader->PKT_RunEvent(headerPkt, pamPkt, length, type);
-         /*
-           ret
-   packet good
-   exception but used    //never happen
-   CRC exception but used
-   CALIBRATION PACKET with error but used
-            -1    CRC exception  packet DISCARDED
-            -2    FATAL exception packet DISCARDED //never happen
-            -3    No way to read events of this type. packet DISCARDED( es OLD CalibCal)
-         ret = 10 if the packet is good but comes from a cadre with VRL problems
-         */
-         //here we know if the packet comes from one or more corrupted cadres
-         //if(!isPKTGood){bad_pkt++;}
-         if((!isPKTGood)&&(!ret)){ret=10;}
-         switch (ret)
-         {
-                 case 0: {numPKTSaved++; break;}
-                 case 1: {bad_pkt_EventReader++; numPKTSaved++; break;}
-                 case 2: {bad_pkt_EventReader++;numPKTSaved++;  break;}
-                 case 3: {bad_pkt_CalibReader++; numPKTSaved++; break;}
-                 case 10: {bad_pkt++; numPKTSaved++; break;}
-                 default:{
-                         stringstream oss;
-                         oss.str()="";
-                         oss<<"Packet DISCARDED, reason = "<<ret;
-                         string msg = oss.str();
-                         mainLogUtil->logAll(msg);
-                         break;
-                 }
-         }
- /*
-         if ((ret==0)&&((type==PacketType::CalibTrk1)||(type==PacketType::CalibTrk2)|| (type==PacketType::CalibCalPed)))
-         {
-                 good_pkt_Calib++;//maybe I will remove this in future
-         }
- */
-         if(ret>=0)// only the packet not discarded of course
-                 setLast(counter,obt);
- //TODO: decide what kind of packet I can use here
- //      if((ret==0)||(ret==10))//I want to use only good packet
-         if(ret>=0)//I want to use only accepted packet
-         {
-                 setTimeSync(pamPkt, length, type);//marco_new: here I retrieve also the boot_number if packet type is vardump
-         }
-         //just to be sure ...
-         if(pamPkt){delete[] pamPkt; pamPkt = NULL;}
-         //just to be sure ...
-         if(headerPkt){delete[] headerPkt; headerPkt = NULL;}
-         numPKT++;
+ int PacketUser::numDiscontinity = 1;
+ int PacketUser::numPKT = 0;
+ int PacketUser::numPKTSaved = 0;
+ PacketUser& PacketUser::getInstance() {
+   return instance;
+ }
+ PacketUser::PacketUser() {
+   gROOT->SetBatch(kTRUE);
+   numDiscontinity = 1;
+   numPKTSaved = 0;
+   numPKT = 0;
+   pkt_number_init = 0;
+   obt_init = 0;
+   pkt_number_last = 0;
+   obt_last = 0;
+   obt_time_sync = 0;
+   last_time_sync_info = 0;
+   //(tassa)
+   obt_time_sync_prevvalue = 0;
+   last_time_sync_info_prevvalue = 0;
+   time_is_estimated = false;
+   real_time_init = 0;
+   real_time_last = 0;
+   bad_pkt = 0;
+   bad_pkt_EventReader = 0;
+   bad_pkt_CalibReader = 0;
+   reader = NULL;
+   pRun = NULL;
+   reader = new pamela::techmodel::EventReader();
+   Table_ROOT_Good = "ROOT_TABLE";
+   Table_ROOT_Bad = "ROOT_TABLE_BAD";
+   Table_GL_RESURS_OFFSET = "GL_RESURS_OFFSET";
+   Table_ROOT_Merging = "ROOT_TABLE_MERGING";
+   //    good_pkt_Calib=0;
+   my_id = 0;
+   boot_number = 0;
+   //(tassa)
+   boot_number_prevvalue = 0;
+   //(tassa)
+   //        id_to_recover[1000]; // Emiliano: che si vuole fare con questa riga? cosi` non fa nulla...
+   id_to_recover_index = 0;
+ }
+ PacketUser::~PacketUser() {
+   if (reader) {
+     delete reader;
+     reader = NULL;
+   }
+   numDiscontinity = 1;
+   numPKTSaved = 0;
+   numPKT = 0;
+   pkt_number_init = 0;
+   obt_init = 0;
+   pkt_number_last = 0;
+   obt_last = 0;
+   obt_time_sync = 0;
+   last_time_sync_info = 0;
+   obt_time_sync_prevvalue = 0;
+   last_time_sync_info_prevvalue = 0;
+   time_is_estimated = false;
+   real_time_init = 0;
+   real_time_last = 0;
+   bad_pkt = 0;
+   bad_pkt_EventReader = 0;
+   bad_pkt_CalibReader = 0;
+   //    good_pkt_Calib=0;
+   my_id = 0;
+   boot_number = 0;
+   boot_number_prevvalue = 0;
+ }
+ //Put the packet in a root file. Create a new ROOT file for each group of packets
+ void PacketUser::usePKT(char*& headerPkt, char*& pamPkt, long int length, bool isCons, bool isPKTGood,
+     const PacketType* type, unsigned long int counter, unsigned long int obt) {
+   //If the packet type was not recognised before
+   if (!type) {
+     return;
+   }
+   //in order to start ...
+   if (numPKT == 0) {
+     if (single_connection) {
+       OpenDBConnection(NULL);
+     }
+     setInit(counter, obt);
+     StartGroup();
+   }
+   //here we know if the incoming packet can be considered consecutive to the previuos   one
+   if ((!isCons) && (numPKT != 0)) {
+     setReal_Time();
+     //closing the group in file rootfilename
+     FinishGroup(rootfilename);
+     //se gia' e' cambiato download non cambio numdisco
+     if (!is_new_route) {
+       numDiscontinity++;
+     }
+     //the current pkt will be placed in a new group: rootfilename
+     setInit(counter, obt);
+     StartGroup();
+   }
+   //add current packet to the group and calculate bad_pkt_EventReader and bad_pkt_CalibReader
+   int ret = reader->PKT_RunEvent(headerPkt, pamPkt, length, type);
+   /*
+    ret
+   packet good
+   exception but used    //never happen
+   CRC exception but used
+   CALIBRATION PACKET with error but used
+    -1    CRC exception  packet DISCARDED
+    -2    FATAL exception packet DISCARDED //never happen
+    -3    No way to read events of this type. packet DISCARDED( es OLD CalibCal)
+    ret = 10 if the packet is good but comes from a cadre with VRL problems
+    */
+   //here we also know if the packet comes from one or more corrupted cadres
+   if ((!isPKTGood) && (!ret)) {
+     ret = 10;
+   }
+   switch (ret) {
+   case 0: {
+     numPKTSaved++;
+     break;
+   }
+   case 1: {
+     bad_pkt_EventReader++;
+     numPKTSaved++;
+     break;
+   }
+   case 2: {
+     bad_pkt_EventReader++;
+     numPKTSaved++;
+     break;
+   }
+   case 3: {
+     bad_pkt_CalibReader++;
+     numPKTSaved++;
+     break;
+   }
+   case 10: {
+     bad_pkt++;
+     numPKTSaved++;
+     break;
+   }
+   default: {
+     stringstream oss;
+     oss.str() = "";
+     oss << "Packet DISCARDED, reason = " << ret;
+     string msg = oss.str();
+     mainLogUtil->logAll(msg);
+     break;
+   }
+   }
+   /*
+    if ((ret==0)&&((type==PacketType::CalibTrk1)||(type==PacketType::CalibTrk2)|| (type==PacketType::CalibCalPed)))
+    {
+    good_pkt_Calib++;//maybe I will remove this in future
+    }
+    */
+   if (ret >= 0)// only the packet not discarded of course
+     setLast(counter, obt);
+   //TODO: decide what kind of packet I can use here
+   //    if((ret==0)||(ret==10))//I want to use only good packet
+   if (ret >= 0)//I want to use only accepted packet
+   {
+     setTimeSync(pamPkt, length, type);//here I retrieve also the boot_number if packet type is vardump
+   }
+   //just to be sure ...
+   if (pamPkt) {
+     delete[] pamPkt;
+     pamPkt = NULL;
+   }
+   if (headerPkt) {
+     delete[] headerPkt;
+     headerPkt = NULL;
+   }
+   numPKT++;
  }
  //set the value of the counter and obt of the first packet of the group
- void PacketUser::setInit(unsigned long int counter, unsigned long int obt)
+ void PacketUser::setInit(unsigned long int counter, unsigned long int obt) {
- {
+   sprintf(nnnn_mmm_ppp, "%05d_%03d_%03d", orbit_number, mmm_number, download);
-         sprintf(nnnn_mmm_ppp,"%05d_%03d_%03d", orbit_number, mmm_number, download);
+   sprintf(rootfilename, "%s_%s_%d", nome_output, nnnn_mmm_ppp, numDiscontinity);
-         sprintf(rootfilename,"%s_%s_%d", nome_output, nnnn_mmm_ppp, numDiscontinity);
+   pkt_number_init = counter;
-         pkt_number_init=counter;
+   obt_init = obt;
-         obt_init=obt;
+   pkt_number_last = 0;
-         pkt_number_last=0;
+   obt_last = 0;
-         obt_last=0;
+   real_time_init = 0;
-         real_time_init=0;
+   real_time_last = 0;
-         real_time_last=0;
+   bad_pkt = 0;
-         bad_pkt=0;
+   numPKTSaved = 0;
-         numPKTSaved=0;
+   bad_pkt_EventReader = 0;
-         bad_pkt_EventReader=0; bad_pkt_CalibReader=0;
+   bad_pkt_CalibReader = 0;
-         //good_pkt_Calib=0;
+   //good_pkt_Calib=0;
-         //marco_NB:
+   //marco_NB:
-         //ogni volta che trovo una discontinuit� resetto come se mi trovassi in un nuovo download oppure uso i vecchi valori se esistono?
+   //ogni volta che trovo una discontinuit� resetto come se mi trovassi in un nuovo download oppure uso i vecchi valori se esistono?
-         obt_time_sync=0; last_time_sync_info=0; boot_number=0;
- //      NB: se ho discontinuita in genere non so a che download appartiene potrebbe proprio essere sbagliato tenere i vecchi valori
+   obt_time_sync_prevvalue = obt_time_sync;
+   last_time_sync_info_prevvalue = last_time_sync_info;
+   time_is_estimated = false;
+   obt_time_sync = 0;
+   last_time_sync_info = 0;
+   boot_number_prevvalue = boot_number;
+   boot_number = 0;
+   //    NB: se ho discontinuita in genere non so a che download appartiene potrebbe proprio essere sbagliato tenere i vecchi valori
  }
  //starts a new root file
- void PacketUser::StartGroup()
+ void PacketUser::StartGroup() {
- {
+   pRun = new PamelaRun(rootfilename, gSystem->ExpandPathName(outDir), multiFile, compression); // EMI
-         pRun = new PamelaRun(rootfilename, outDir , multiFile, compression);
+   strcat(rootfilename, ".root");
-         //marco_new: aggiunta estensione .root
+   reader->Init(pRun);
-         strcat(rootfilename,".root");
+   stringstream oss;
-         reader->Init(pRun);
+   oss.str() = "";
-         stringstream oss;
+   oss << "######################### Start a new group in file: " << rootfilename << " ############################";
-         oss.str()="";
+   string msg = oss.str();
-         oss<<"######################### Start a new group in file: "<< rootfilename <<" ############################";
+   mainLogUtil->logInfo(msg);
-         string msg = oss.str();
-         mainLogUtil->logInfo(msg);
  }
  //set the value of the counter and obt of the last packet of the group
- void PacketUser::setLast(unsigned long int counter, unsigned long int obt)
+ void PacketUser::setLast(unsigned long int counter, unsigned long int obt) {
- {
+   pkt_number_last = counter;
-         pkt_number_last=counter;
+   obt_last = obt;
-         obt_last=obt;
+ }
- }
+ //retrieve obt_time_sync and last_time_sync_info from packet if type has special values and BOOT_NUMBER
+ void PacketUser::setTimeSync(char* packet, long int pktLength, const PacketType* type) {
+   //do nothing
- //retrieve obt_time_sync and last_time_sync_info from packet if type has special values
+   if (!do_cont_check) {
- void PacketUser::setTimeSync(char* packet, long int pktLength, const PacketType* type)
+     if (is_new_route)
- {
+       is_new_route = false;
-     //do nothing
+     return;
-         if(!do_cont_check) {
+   }
-                 if(is_new_route)
-                         is_new_route=false;
+   //TODO: usare anche MCMD ... NOTA: questo da sempre errore ret != 0
-                 return;
+   //In RunHeader e RunTrailer sono in secondi(?), controllare se aggiungo altri tipi di paccheti se invece sono in secondi
-         }
+   // devo ricalcolare tutto non per ogni gruppetto (ROOT file) ma solo se cambia download
+   //When I found a new download I need to reset all values
- //TODO: usare anche MCMD ... NOTA: questo da sempre errore ret != 0
+   if (is_new_route) {
- //In RunHeader e RunTrailer sono in secondi(?), controllare se aggiungo altri tipi di paccheti se invece sono in secondi
+     //reset
+     is_new_route = false;
+     //(tassa) ci ho ripensato se stiamo in un secondo download non prendiamo i bootnumber e timesync del precedente!
-         // devo ricalcolare tutto non per ogni gruppetto (ROOT file) ma solo se cambia download
+     obt_time_sync_prevvalue = 0;//obt_time_sync;
+     last_time_sync_info_prevvalue = 0;//last_time_sync_info;
-         //When I found a new download I need to reset all values
-         if(is_new_route)
+     obt_time_sync = 0;
-         {
+     last_time_sync_info = 0;
-           //reset
+     boot_number_prevvalue = 0;//boot_number;
-                 is_new_route=false;
+     boot_number = 0;
-                 obt_time_sync=0; last_time_sync_info=0;
+     time_is_estimated = false;
-                 boot_number=0;
+     if (time_Offset)
-                 if(time_Offset)
+       timeOffset = time_Offset;
-                         timeOffset=time_Offset;
+     else
-                 else
+       timeOffset = retrieveTimeOffset(Table_GL_RESURS_OFFSET);
-                         timeOffset=retrieveTimeOffset(Table_GL_RESURS_OFFSET);
+   }
-         }
+   //retrieve boot number if possible
-         //retrieve boot number if possible
+   setBootNumber(packet, pktLength, type);
-         setBootNumber(packet,pktLength,type);
+   //Retrieve if possible obt_time_sync and last_time_sync_info
-         //Retrieve if possible obt_time_sync and last_time_sync_info
+   int offset = 0;
-         int offset=0;
+   if (type == PacketType::RunHeader) {
-         if(type==PacketType::RunHeader)
+     offset = 0;
-         {
+   }
-                 offset=0;
+   else if (type == PacketType::RunTrailer) {
-         }
+     offset = 3;
-         else if(type==PacketType::RunTrailer)
+   }
-         {
+   else if (type == PacketType::Mcmd) {
-                 offset=3;
+     //          mainLogUtil->logAll("TODO: Packet Mcmd now is not used to retrieve Absolute time. This may cause problems somewhere.");
-         }
+     return;
-         else if(type==PacketType::Mcmd)
+   }
-         {
+   else {
- //              mainLogUtil->logAll("TODO: Packet Mcmd now is not used to retrieve Absolute time. This may cause problems somewhere.");
+     return;
-                 return;
+   }
-         }
-         else
+   //I don't need to retrieve them again if they are good
-         {
+   if ((obt_time_sync) || (last_time_sync_info))
-                 return;
+     return;
-         }
+   obt_time_sync = (((UINT32) packet[5 + offset] << 24) & 0xFF000000) + (((UINT32) packet[6 + offset] << 16)
-         //I don't need to retrieve them again if they are good
+       & 0x00FF0000) + (((UINT32) packet[7 + offset] << 8) & 0x0000FF00) + (((UINT32) packet[8 + offset]) & 0x000000FF);
-         if((obt_time_sync)||(last_time_sync_info)) return;
+   last_time_sync_info = (((UINT32) packet[9 + offset] << 24) & 0xFF000000) + (((UINT32) packet[10 + offset] << 16)
+       & 0x00FF0000) + (((UINT32) packet[11 + offset] << 8) & 0x0000FF00)
-         obt_time_sync = (((UINT32)packet[5+offset]<<24)&0xFF000000) + (((UINT32)packet[6+offset]<<16)&0x00FF0000) + (((UINT32)packet[7+offset]<<8)&0x0000FF00) + (((UINT32)packet[8+offset])&0x000000FF);
+       + (((UINT32) packet[12 + offset]) & 0x000000FF);
-         last_time_sync_info = (((UINT32)packet[9+offset]<<24)&0xFF000000) + (((UINT32)packet[10+offset]<<16)&0x00FF0000) + (((UINT32)packet[11+offset]<<8)&0x0000FF00) + (((UINT32)packet[12+offset])&0x000000FF);
+   stringstream oss;
-         stringstream oss;
+   oss.str() = "";
-         oss.str()="";
+   oss << "In download: " << download << " timeOffset: " << timeOffset << " obt_time_sync: " << obt_time_sync
-         oss<<"In download: "<<download<<" timeOffset: "<<timeOffset<<" obt_time_sync: "<<obt_time_sync<<" last_time_sync_info: "<<last_time_sync_info<<" using Packet Type: "<<type->GetName().c_str();
+       << " last_time_sync_info: " << last_time_sync_info << " using Packet Type: " << type->GetName();
-         string msg = oss.str();
+   //    oss<<"In download: "<<download<<" timeOffset: "<<timeOffset<<" obt_time_sync: "<<obt_time_sync<<" last_time_sync_info: "<<last_time_sync_info<<" using Packet Type: "<<type->GetName().c_str();
-         mainLogUtil->logAll(msg);
+   string msg = oss.str();
+   mainLogUtil->logAll(msg);
  }
  //Boot Number
- void PacketUser::setBootNumber(char* packet, long int pktLength, const PacketType* type)
+ void PacketUser::setBootNumber(char* packet, long int pktLength, const PacketType* type) {
- {
+   //se gia calcolato esco: lo calcolo una volta per download e per continuita'
-         //se gia calcolato esco: lo calcolo una volta per download e per continuit�
+   if (boot_number)
-         if(boot_number) return;
+     return;
- //todo: controlla se algo giusto: preso da VarDumpReader.cpp
- //mmm e' sbagliatissimo cambiare !!!
+   if (type == PacketType::VarDump) {
-         if(type==PacketType::VarDump)
+     int b_offset = 34;//4+5*6
-         {
+     boot_number = (((UINT32) packet[1 + b_offset] << 24) & 0xFF000000) + (((UINT32) packet[2 + b_offset] << 16)
-                 long int  dataLength = pktLength - 2; //the block of data
+         & 0x00FF0000) + (((UINT32) packet[3 + b_offset] << 8) & 0x0000FF00) + (((UINT32) packet[4 + b_offset])
-                 int b_offset = 4;
+         & 0x000000FF);
-                 while (b_offset < dataLength){
-                  boot_number  = (((UINT32)packet[1+b_offset]<<24)&0xFF000000) + (((UINT32)packet[2+b_offset]<<16)&0x00FF0000) +  (((UINT32)packet[3+b_offset]<<8)&0x0000FF00) + (((UINT32)packet[4+b_offset])&0x000000FF);
+     /*
-                  b_offset = b_offset + 5;
+      long int  dataLength = pktLength - 2; //the block of data
-                 }
+      int b_offset = 4;
-                 stringstream oss;
+      while (b_offset < dataLength){
-                 oss.str()="";
+      boot_number  = (((UINT32)packet[1+b_offset]<<24)&0xFF000000) + (((UINT32)packet[2+b_offset]<<16)&0x00FF0000) +  (((UINT32)packet[3+b_offset]<<8)&0x0000FF00) + (((UINT32)packet[4+b_offset])&0x000000FF);
-                 oss<<"In download: "<<download<<" boot_number: "<<boot_number<<" using Packet Type: "<<type->GetName().c_str();
+      b_offset = b_offset + 5;
-                 string msg = oss.str();
+      }
-                 mainLogUtil->logAll(msg);
+      */
-                 return;
+     stringstream oss;
-         }
+     oss.str() = "";
-         else
+     //          oss<<"In download: "<<download<<" boot_number: "<<boot_number<<" using Packet Type: "<<type->GetName().c_str();
-         {
+     oss << "In download: " << download << " boot_number: " << boot_number << " using Packet Type: " << type->GetName();
-                 return;
+     string msg = oss.str();
-         }
+     mainLogUtil->logAll(msg);
+     return;
+   }
+   else {
+     return;
+   }
  }
  //set the real time of the first packet and the last packet oif a group of packet if possible
- void PacketUser::setReal_Time()
+ void PacketUser::setReal_Time() {
- {
-         if((obt_time_sync)||(last_time_sync_info))
+   if (!obt_time_sync && !last_time_sync_info && numPKTSaved > 1000) {
-         {
+     time_is_estimated = true;
-                 real_time_init=(obt_init/1000-obt_time_sync)+last_time_sync_info;
+     obt_time_sync = obt_time_sync_prevvalue;
-                 real_time_last=(obt_last/1000-obt_time_sync)+last_time_sync_info;
+     last_time_sync_info = last_time_sync_info_prevvalue;
-                 real_time_init+=timeOffset;
+   }
-                 real_time_last+=timeOffset;
+   if (obt_time_sync || last_time_sync_info) {
-         }
+     real_time_init = (obt_init / 1000 - obt_time_sync) + last_time_sync_info;
+     //se obt si e' resettato
+     if (obt_last < obt_init) {
+       real_time_last = (max_pkt_obt / 1000 + obt_last / 1000 - obt_time_sync) + last_time_sync_info;
+       stringstream oss;
+       oss.str() = "";
+       oss << "obt_last(" << obt_last << ") < obt_init(" << obt_init
+           << "). It is due to Pamela Reset. Adding max_pkt_obt(" << max_pkt_obt
+           << ") to obt_last in order to compute real_time_last";
+       string msg = oss.str();
+       mainLogUtil->logWarning(msg);
+     }
+     else
+       real_time_last = (obt_last / 1000 - obt_time_sync) + last_time_sync_info;
+     real_time_init += timeOffset;
+     real_time_last += timeOffset;
+   }
  }
  //timeOffset
  //retrieve from table Table_GL_RESURS_OFFSET timeOffset
- unsigned long int PacketUser::retrieveTimeOffset(char * table)
+ unsigned long int PacketUser::retrieveTimeOffset(const char * table) {
- {
+   if (!do_cont_check)
-         if(!do_cont_check) return 0;
+     return 0;
-         //if(!table){table=Table_GL_RESURS_OFFSET}
+   //if(!table){table=Table_GL_RESURS_OFFSET}
-         //marco_new_31:metto qui se voglio aprire e chiudere Connessione solo quando serve
+   if (!single_connection) {
-         //marco_new_01
+     OpenDBConnection(table);//Nota qui ho deciso di lockare solo questa tabella e non tutte
-         if(!single_connection){
+   }
-                 OpenDBConnection(table);//Nota qui ho deciso di lockare solo questa tabella e non tutte
-         }
+   UInt_t t0 = 0;//toffset
+   stringstream oss;
-         UInt_t t0 = 0;  //toffset
+   oss.str("");
+   oss
-         stringstream oss;
+       << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM "
-         oss.str("");
+       << table << " WHERE SPECIAL_FILE='" << nnnn_mmm_ppp << "';";
-         oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM "<<      table <<" WHERE SPECIAL_FILE='"
-               << nnnn_mmm_ppp << "';";
+   string msg = oss.str();
+   mainLogUtil->logAll(msg);
-         string msg = oss.str();
-         mainLogUtil->logAll(msg);
+   TSQLResult* res = NULL;
+   TSQLRow* row = NULL;
-         TSQLResult* res=NULL;
+   res = sqlServer->Query(oss.str().c_str());
-         TSQLRow* row=NULL;
+   if (!res) {
-         res= sqlServer->Query(oss.str().c_str());
+     mainLogUtil->logError("DBError retrieveTimeOffset 1");
-         if(!res)
+     return 0;
-         {
+   }
-                 mainLogUtil->logError("DBError retrieveTimeOffset 1");
-                 return 0;
+   row = res->Next();
-         }
+   if (!row) {
+     if (res) {
-     row=res->Next();
+       delete res;
-     if (!row )
+       res = NULL;
-     {
+     }
-         if(res){delete res; res = NULL;}
+     oss.str("");
-         oss.str("");
+     oss
-         oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM "<<      table <<" WHERE FROM_ORBIT < "
+         << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM "
-         << orbit_number << " order by FROM_ORBIT desc limit 1;";
+         << table << " WHERE FROM_ORBIT < " << orbit_number << " AND SPECIAL_FILE='' order by FROM_ORBIT desc limit 1;";
-                 string msg2 = oss.str();
+     string msg2 = oss.str();
-                 mainLogUtil->logAll(msg2);
+     mainLogUtil->logAll(msg2);
-                 res= sqlServer->Query(oss.str().c_str());
+     res = sqlServer->Query(oss.str().c_str());
-         if(!res)
+     if (!res) {
-         {
+       mainLogUtil->logError("DBError retrieveTimeOffset 2");
-                 mainLogUtil->logError("DBError retrieveTimeOffset 2");
+       return 0;
-                 return 0;
+     }
-         }
+     row = res->Next();
-         row=res->Next();
+     if (!row) {
-         if (!row)
+       mainLogUtil->logError("DBError retrieveTimeOffset 3");
-         {
+       return 0;
-                 mainLogUtil->logError("DBError retrieveTimeOffset 3");
+     }
-                 return 0;
-         }
+   }
-      }
+   TTimeStamp tu = TTimeStamp((UInt_t) atoi(row->GetField(0)), (UInt_t) atoi(row->GetField(1)), (UInt_t) atoi(
+       row->GetField(2)), (UInt_t) atoi(row->GetField(3)), (UInt_t) atoi(row->GetField(4)), (UInt_t) atoi(row->GetField(
-       TTimeStamp tu = TTimeStamp((UInt_t)atoi(row->GetField(0)),(UInt_t)atoi(row->GetField(1)),(UInt_t)atoi(row->GetField(2)),(UInt_t)atoi(row->GetField(3)),(UInt_t)atoi(row->GetField(4)),(UInt_t)atoi(row->GetField(5)),0,true,0);
+)), 0, true, 0);
-       t0 = (UInt_t)tu.GetSec();
+   t0 = (UInt_t) tu.GetSec();
-         if(res){delete res; res = NULL;}
+   if (res) {
-         if(row){delete row; row = NULL;}
+     delete res;
+     res = NULL;
-         //marco_new_31:metto qui se voglio aprire e chiudere Connessione solo quando serve
+   }
-         //marco_new_01
+   if (row) {
-         if(!single_connection){
+     delete row;
-                 CloseDBConnection();
+     row = NULL;
-         }
+   }
-  return t0;
+   if (!single_connection) {
+     CloseDBConnection();
+   }
+   return t0;
  }
  //this is public and can be called from the main at the end of the game
- void PacketUser::FinishLastGroup()
+ void PacketUser::FinishLastGroup() {
- {
+   mainLogUtil->logAll("######################### Closing the last group ############################");
-         mainLogUtil->logAll("######################### Closing the last group ############################");
+   setReal_Time();
-         setReal_Time();
+   FinishGroup(rootfilename);
-         FinishGroup(rootfilename);
+   mainLogUtil->logAll("######################### Closed the last group ############################");
-         mainLogUtil->logAll("######################### Closed the last group ############################");
+   if (single_connection) {
+     CloseDBConnection();
-         //marco_new_31:metto qui se voglio avere come in origine apertura Connessione all'inizio e chiusura alla fine
+   }
-         //marco_new_01
-         if(single_connection){
-                 CloseDBConnection();
-         }
  }
  //Finish the old root file
- void PacketUser::FinishGroup(char * filename)
+ void PacketUser::FinishGroup(char * filename) {
- {
+   if (pRun) {
-         if(pRun)
+     pRun->WriteFiles();
-         {
+     delete pRun;
-                 pRun->WriteFiles();
+     pRun = NULL;
-                 delete pRun; pRun = NULL;
+     stringstream close;
-                 stringstream close;
+     close.str() = "";
-                 close.str()="";
+     string msg;
-                 string msg;
+     close << "######################### Close group in file: " << rootfilename << " ############################";
-                 close<<"######################### Close group in file: "<< rootfilename <<" ############################";
+     msg = close.str();
-                 msg = close.str();
+     mainLogUtil->logInfo(msg);
-                 mainLogUtil->logInfo(msg);
+     // se non faccio proprio controlli su continuita' neanche salvo su DB
-                 // se non faccio proprio controlli su continuita' neanche salvo su DB
+     if (!do_cont_check)
-                 if(!do_cont_check) return;
+       return;
-                 stringstream oss;
+     stringstream oss;
-                 oss.str()="";
+     oss.str() = "";
-                 //TODO: check when I don't want to log in DB informations
+     //TODO: check when I don't want to log in DB informations
+     // se non ho salvato nessun pacchetto
-                 // se non ho salvato nessun pacchetto
+     if (numPKTSaved == 0) {
-                 if(numPKTSaved==0){
+       stringstream err;
-                         stringstream err;
+       err.str() = "";
-                         err.str()="";
+       err << "NO PACKET SAVED in file: " << rootfilename << " The group is empty: you can remove this file.";
-                         err<<"NO PACKET SAVED in file: "<< rootfilename <<" The group is empty: you can remove this file.";
+       msg = err.str();
-                         msg = err.str();
+       mainLogUtil->logError(msg);
-                         mainLogUtil->logError(msg);
+       return;
-                         return;
+     }
-                 }
+     //se non ho salvato nessun pacchetto buono
-                 //se non ho salvato nessun pacchetto buono
+     if ((numPKTSaved - bad_pkt_EventReader - bad_pkt_CalibReader - bad_pkt) == 0) {
-                 if((numPKTSaved-bad_pkt_EventReader-bad_pkt_CalibReader-bad_pkt)==0){
+       stringstream err;
-                         stringstream err;
+       err.str() = "";
-                         err.str()="";
+       err << "NO GOOD PACKET SAVED in file: " << rootfilename << " The group is BAD: you may want to remove this file.";
-                         err<<"NO GOOD PACKET SAVED in file: "<< rootfilename <<" The group is BAD: you may want to remove this file.";
+       msg = err.str();
-                         msg = err.str();
+       mainLogUtil->logInfo(msg);
-                         mainLogUtil->logInfo(msg);
+       //                        mainLogUtil->logError(msg);
- //                      mainLogUtil->logError(msg);
+       //                        return; //TODO: decidi se nn vuoi affatto usarlo o addirittura salvarlo tra i BAD???
- //                      return; //TODO: decidi se nn vuoi affatto usarlo o addirittura salvarlo tra i BAD???
+     }
-                 }
+     if (!single_connection) {
-                 //marco_new_31:metto qui se voglio aprire e chiudere Connessione solo quando serve
+       OpenDBConnection(NULL);//Nota qui ho deciso di lockare tutte le tabelle
-                 //marco_new_01
+     }
-                 if(!single_connection){
-                         OpenDBConnection(NULL);//Nota qui ho deciso di lockare tutte le tabelle
+     //don't save in Table_ROOT_Good and don't search for ROOT files in the same temporal range
-                 }
+     if ((!real_time_init) && (!real_time_last)) {
+       //saved in another table for future study
-                 //don't save in Table_ROOT_Good and don't search for ROOT files in the same temporal range
+       if (saveROOT_DB(
-                 if((!real_time_init)&&(!real_time_last))
+           Table_ROOT_Bad,
-                 {
+           outDir,// here outDir is good, no expand EMI
-                         //saved in another table for future study
+           filename, pkt_number_init, pkt_number_last, obt_init, obt_last, obt_time_sync, last_time_sync_info,
-                         if(saveROOT_DB(Table_ROOT_Bad, outDir,
+           real_time_init, real_time_last, boot_number, timeOffset, bad_pkt, bad_pkt_EventReader, bad_pkt_CalibReader,
-                                                                 filename,
+           numPKTSaved, fni, time_is_estimated) == true) {
-                                                            pkt_number_init, pkt_number_last,
+         oss.str() = "";
-                                                            obt_init, obt_last,
+         oss << "Saved information regarding file: " << filename << " in table " << Table_ROOT_Bad;
-                                                            obt_time_sync, last_time_sync_info,
+         msg = oss.str();
-                                                            real_time_init, real_time_last,
+         mainLogUtil->logInfo(msg);
-                                                            boot_number,
+       }
-                                                            timeOffset,
+       else {
-                                                            bad_pkt, bad_pkt_EventReader, bad_pkt_CalibReader, numPKTSaved,
+         oss.str() = "";
-                                                            fni)==true)
+         oss << "Problem storing information in DB regarding file: " << filename;
-                                 {
+         msg = oss.str();
-                                         oss.str()="";
+         mainLogUtil->logError(msg);
-                                         oss<<"Saved information regarding file: "<<filename<<" in table "<<Table_ROOT_Bad;
+       }
-                                         msg = oss.str();
-                                         mainLogUtil->logInfo(msg);
+       if (!single_connection) {
-                                 }
+         CloseDBConnection();
-                                 else
+       }
-                                 {
-                                         oss.str()="";
+       return;
-                                         oss<<"Problem storing information in DB regarding file: "<<filename;
+     }
-                                         msg = oss.str();
-                                         mainLogUtil->logError(msg);
+     //saves info in DB in table Table_ROOT_Good
-                                 }
+     if (boot_number == 0)
+       boot_number = boot_number_prevvalue;
-                         //marco_new_31:metto qui se voglio aprire e chiudere Connessione solo quando serve
-                                 //marco_new_01
+     if (saveROOT_DB(
-                         if(!single_connection){
+         Table_ROOT_Good,
-                                 CloseDBConnection();
+         outDir, // here outDir is good, no expand EMI
-                         }
+         filename, pkt_number_init, pkt_number_last, obt_init, obt_last, obt_time_sync, last_time_sync_info,
+         real_time_init, real_time_last, boot_number, timeOffset, bad_pkt, bad_pkt_EventReader, bad_pkt_CalibReader,
-                 return;
+         numPKTSaved, fni, time_is_estimated) == true) {
-                 }
+       oss << "Saved information regarding file: " << filename << " in table " << Table_ROOT_Good << " id= " << my_id;
+       msg = oss.str();
-                 //saves info in DB in table Table_ROOT_Good
+       mainLogUtil->logInfo(msg);
-                 if(saveROOT_DB(Table_ROOT_Good, outDir,
-                                         filename,
+       if (tryMerge) {
-                                    pkt_number_init, pkt_number_last,
+         merge_ROOTfiles();
-                                    obt_init, obt_last,
+       }
-                                    obt_time_sync, last_time_sync_info,
+     }
-                                    real_time_init, real_time_last,
+     else {
-                                    boot_number,
+       oss << "Problem storing information in DB regarding file: " << filename;
-                                    timeOffset,
+       msg = oss.str();
-                                    bad_pkt, bad_pkt_EventReader, bad_pkt_CalibReader, numPKTSaved,
+       mainLogUtil->logError(msg);
-                                    fni)==true)
+     }
-                 {
-                         oss<<"Saved information regarding file: "<<filename<<" in table "<<Table_ROOT_Good<< " id= "<<my_id;
+     if (!single_connection) {
-                         msg = oss.str();
+       CloseDBConnection();
-                         mainLogUtil->logInfo(msg);
+     }
-                         //TODO : work on this ....
-                         if(tryMerge){
-                             merge_ROOTfiles();
-                         }
-                 }
-                 else
-                 {
-                         oss<<"Problem storing information in DB regarding file: "<<filename;
-                         msg = oss.str();
-                         mainLogUtil->logError(msg);
-                 }
-                 //marco_new_31:metto qui se voglio apriree chiudere Connessione solo quando serve
-                         //marco_new_01
-                 if(!single_connection){
-                         CloseDBConnection();
-                 }
-         }//pRun
+   }//pRun
  }
  //save in Table_ROOT_Good or in Table_ROOT_Bad
- bool PacketUser::saveROOT_DB(char* table_name, char* folder_name, char* file_name,
+ bool PacketUser::saveROOT_DB(const char* table_name, char* folder_name, char* file_name,
-                 unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
+     unsigned long int pkt_number_in, unsigned long int pkt_number_fin, unsigned long int obt_in,
-                 unsigned long int obt_in, unsigned long int obt_fin,
+     unsigned long int obt_fin, unsigned long int oT_sync, unsigned long int lT_sync_info, unsigned long int mtime_init,
-                 unsigned long int  oT_sync, unsigned long int lT_sync_info,
+     unsigned long int mtime_last, unsigned long int mboot_num, unsigned long int time_offset, int bad_pkt,
-                 unsigned long int mtime_init,   unsigned long int mtime_last,
+     int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved, char* nome_input, bool _time_is_estimated) {
-                 unsigned long int mboot_num,
+   //TODO: forse far ritornare ID della cosa appena inserita se e' andatato tutto ok invece che true false?
-                 unsigned long int time_offset,
+   stringstream oss;
-                 int bad_pkt, int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved,
+   oss.str("");
-                 char* nome_input){
+   oss << "INSERT INTO " << table_name
-         //TODO: forse far ritornare ID della cosa appena inserita se e' andatato tutto ok invece che true false?
+       << " (ID_N, FOLDER_NAME, FILE_NAME, PKT_NUMBER_INIT, PKT_NUMBER_FINAL, PKT_OBT_INIT, PKT_OBT_FINAL, OBT_TIME_SYNC, LAST_TIME_SYNC_INFO, REAL_TIME_INIT, REAL_TIME_LAST, BOOT_NUMBER, TIME_OFFSET,BAD_PKT,BAD_PKT_READ,BAD_PKT_CALREAD,NUM_PKT_SAVED,INPUT_NAME,INSERT_TIME,TIME_IS_ESTIMATED)"
-         stringstream oss;
+       << " VALUES ('" << 0 << "','" << folder_name << "','" << file_name << "','" << pkt_number_in << "','"
-         oss.str("");
+       << pkt_number_fin << "','" << obt_in << "','" << obt_fin << "','" << oT_sync << "','" << lT_sync_info << "','"
-         oss << "INSERT INTO "<< table_name <<" (ID_N, FOLDER_NAME, FILE_NAME, PKT_NUMBER_INIT, PKT_NUMBER_FINAL, PKT_OBT_INIT, PKT_OBT_FINAL, OBT_TIME_SYNC, LAST_TIME_SYNC_INFO, REAL_TIME_INIT, REAL_TIME_LAST, BOOT_NUMBER, TIME_OFFSET,BAD_PKT,BAD_PKT_READ,BAD_PKT_CALREAD,NUM_PKT_SAVED,INPUT_NAME,INSERT_TIME)"
+       << mtime_init << "','" << mtime_last << "','" << mboot_num << "','" << time_offset << "','" << bad_pkt << "','"
-     << " VALUES ('"<<0<< "','" <<folder_name<<"','" <<file_name<< "','" << pkt_number_in <<"','"<< pkt_number_fin << "','"<< obt_in <<"','"<< obt_fin<< "','"
+       << bad_pkt_read << "','" << bad_pkt_CalRead << "','" << num_PKT_Saved << "','" << nome_input << "'," << "NULL,"
-     << oT_sync << "','" << lT_sync_info << "','"
+       << _time_is_estimated << ");";
-     << mtime_init << "','" << mtime_last << "','"
+   string msg = oss.str();
-         << mboot_num << "','"
+   mainLogUtil->logAll(msg);
-     << time_offset << "','"
-     << bad_pkt <<"','" << bad_pkt_read <<"','"<< bad_pkt_CalRead <<"','"<< numPKTSaved<<"','"
+   stringstream oss1;
-     << nome_input <<"',"
+   oss1.str() = "";
-     <<"NULL"<<
+   string msg1;
-     ")";
+   string query;
-         string msg = oss.str();
-         mainLogUtil->logAll(msg);
+   TSQLResult* res = NULL;
-         stringstream oss1;
+   query = oss.str();
-         oss1.str()="";
+   msg1 = "SaveROOT_DB query: ";
-         string msg1;
+   msg1 += query;
+   mainLogUtil->logInfo(msg1);
-    TSQLResult* res=NULL;
-    res= sqlServer->Query(oss.str().c_str());
+   res = sqlServer->Query(query.c_str());
-    if(!res)
+   if (!res) {
-    {
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
+     msg1 = oss1.str();
-            msg1=oss1.str();
+     mainLogUtil->logError(msg1);
-            mainLogUtil->logError(msg1);
+     return false;
-            return false;
+   }
-    }
+   //the ID of the current ROOT file in table Table_ROOT_Good
+   my_id = select_maxIDN_DB(table_name);
+   if (!boot_number) {
+     if (id_to_recover_index < 1000)
+       id_to_recover[id_to_recover_index++] = my_id;
+   }
+   else if (boot_number && id_to_recover_index && !is_new_route) {
+     recover_boot_number();
+   }
+   //    cout<<"DBG: my_id = "<<my_id<<endl;
+   if (res) {
+     delete res;
+     res = NULL;
+   }
+   return true;
+ }
+ void PacketUser::recover_boot_number() {
+   string msg1;
+   stringstream oss1;
+   stringstream oss;
+   oss.str("");
+   string query = "";
+   TSQLResult* res = NULL;
+   if (!boot_number || !id_to_recover_index)
+     return;
+   for (int i = 0; i < id_to_recover_index; i++) {
+     oss.str("");
+     oss << "UPDATE " << Table_ROOT_Good << " SET BOOT_NUMBER=" << boot_number << " WHERE ID_N=" << id_to_recover[i]
+         << ";";
+     query = oss.str();
+     res = sqlServer->Query(query.c_str());
+     if (!res) {
+       oss1 << "DBError UNABLE to: " << query.c_str() << endl;
+       msg1 = oss1.str();
+       mainLogUtil->logError(msg1);
+       return;
+     }
+   }
+   for (int i = 0; i < id_to_recover_index; i++) {
+     oss.str("");
+     oss << "UPDATE " << Table_ROOT_Merging << " SET BOOT_NUMBER=" << boot_number << " WHERE ROOT_ID_N="
+         << id_to_recover[i] << ";";
+     query = oss.str();
+     res = sqlServer->Query(query.c_str());
+     if (!res) {
+       oss1 << "DBError UNABLE to: " << query.c_str() << endl;
+       msg1 = oss1.str();
+       mainLogUtil->logError(msg1);
+       return;
+     }
+   }
-    //marco_new: si pu� ottimizzare ...
+   id_to_recover_index = 0;
-    //the ID of the current ROOT file in table Table_ROOT_Good
-          my_id = select_maxIDN_DB(table_name);
- //      cout<<"DBG: my_id = "<<my_id<<endl;
-    if(res){delete res; res = NULL;}
-    return true;
  }
  /**********************************************************************************************/
  /*###########################################################################################################*/
  /**********************************         MERGING          *************************************************/
  /*###########################################################################################################*/
- //      Merge ROOT files: found other ROOT files in the same temporal ranges
+ //      Merge ROT files: find other ROOT files in the same temporal ranges
  //    it finds ROOT files that covers particular temporal range of interest and save this info in DB
  /**********************************************************************************************/
  //try to merge current ROOT file with files in DB
- bool PacketUser::merge_ROOTfiles()
+ bool PacketUser::merge_ROOTfiles() {
- {
+   stringstream log;
-         mainLogUtil->logInfo("Trying merging ROOT files");
+   log.str("");
+   string slog;
+   mainLogUtil->logInfo("Trying merging ROOT files");
+   double percentage = (double) (bad_pkt + bad_pkt_EventReader + bad_pkt_CalibReader) / numPKTSaved;
+   TSQLResult* res = NULL;
+   TSQLRow* row = NULL;
+   //numero di ROOT files trovati sul DB che hanno relaz di tipo dato
+   unsigned int num_rows = 0;
+   //Record su DB:
+   unsigned int idN = 0;
+   unsigned int root_id_db = 0;
+   unsigned long int pkt_num_in_db = 0;
+   unsigned long int pkt_num_fin_db = 0;
+   unsigned long int pkt_obt_in_db = 0;
+   unsigned long int pkt_obt_fin_db = 0;
+   unsigned long int time_in_db = 0;
+   unsigned long int time_fin_db = 0;
+   unsigned int boot_num_db = 0;
+   double perc = 0;
-   //marco_new: controlla
+   //marco_new: non considero mai caso di continuita'(mio finale=DB iniz o viceversa), non mi interessa
-   double percentage=(double)(bad_pkt+bad_pkt_EventReader+bad_pkt_CalibReader)/numPKTSaved;
-   TSQLResult* res=NULL;
-   TSQLRow* row =NULL;
-   //marco_new: non considero mai caso di continuit�(mio finale=DB iniz o viceversa), non mi interessa
    //marco_new: after e before contengono anche smaller ma con un bordo comune
-   for(int relaz=AFTER; relaz<=BIGGER; relaz++)
+   for (int relaz = AFTER; relaz <= BIGGER; relaz++) {
-   {
+     //marco_new: esci se sono arrivato a zero
-         //marco_new: controlla tutto
+     if (real_time_last == real_time_init) {
-         //marco_new: esci se sono arrivato a zero
+       log.str("");
-         if(real_time_last==real_time_init){
+       log << "Current File Lenght=0; real_time_last=real_time_init= " << real_time_last;
-                 mainLogUtil->logInfo("Finish merging ROOT files");
+       slog = log.str();
-                 if(res){delete res; res = NULL;}
+       mainLogUtil->logAll(slog);
-                 if(row){delete row; row = NULL;}
+       mainLogUtil->logInfo("Finish merging ROOT files");
-                 return true;
+       if (res) {
-         }
+         delete res;
+         res = NULL;
-         res = Select_merging(Table_ROOT_Merging, real_time_init, real_time_last, (type_Rel_ROOT)relaz);
+       }
+       if (row) {
-         unsigned int num_rows=0;
+         delete row;
-          if (!res)
+         row = NULL;
-          {
+       }
-                 mainLogUtil->logError("DB_ERROR: Unable to find ROOT files to be merged RES=null");
+       return true;
-                  return false;
+     }
-          }
+     num_rows = 0;
-          num_rows=res->GetRowCount();
+     res = Select_merging(Table_ROOT_Merging, real_time_init, real_time_last, (type_Rel_ROOT) relaz);
- //       cout<<"MMMMM trovati num_rows "<< num_rows<< " per relaz= "<<relaz;
+     if (!res) {
-          if(num_rows>0)
+       mainLogUtil->logError("DB_ERROR: Unable to find ROOT files to be merged RES=null");
-          {
+       return false;
-                  for(unsigned int i=0; i<num_rows; i++)
+     }
-                  {
-                          row=res->Next();
+     num_rows = res->GetRowCount();
-                          if (!row)
+     log.str("");
-                          {
+     log << "Found " << num_rows << " ROOT file in DB with relation of kind = " << relaz;
-                                  mainLogUtil->logError("DB_ERROR: Unable to find ROOT files to be merged. ROW=null");
+     slog = log.str();
-                                 if(res){delete res; res = NULL;}
+     mainLogUtil->logAll(slog);
-                                 return false;
-                          }
+     if (num_rows > 0) {
+       for (unsigned int i = 0; i < num_rows; i++) {
+         row = res->Next();
-                         //TODO ricavare tutte le info che servono
+         if (!row) {
-                         unsigned int idN = 0;
+           mainLogUtil->logError("DB_ERROR: Unable to find ROOT files to be merged. ROW=null");
-                         idN=atoi(row->GetField(0));
+           if (res) {
+             delete res;
-                         double perc =0;
+             res = NULL;
-                         //marco_new:
+           }
-                         perc=atof(row->GetField(9));
+           return false;
-                         //unsigned long int M_pkt_number_in, M_pkt_number_fin, M_obt_in, M_obt_fin, M_mtime_init, M_mtime_last;
+         }
-                         if(perc>percentage){
-                                 mainLogUtil->logInfo("Current ROOT file is better than the one in DB");
+         //Leggi Record dal DB:
-                                 //modifica DB
+         idN = atoll(row->GetField(0));
-                                 updateMergeROOT_DB(Table_ROOT_Merging,
+         root_id_db = atoll(row->GetField(1));
-                                         atoi(row->GetField(1)), atoi(row->GetField(2)),
+         pkt_num_in_db = atoll(row->GetField(2));
-                                         atoi(row->GetField(3)), atoi(row->GetField(4)),
+         pkt_num_fin_db = atoll(row->GetField(3));
-                                         atoi(row->GetField(5)), atoi(row->GetField(6)),
+         pkt_obt_in_db = atoll(row->GetField(4));
-                                         atoi(row->GetField(7)), atoi(row->GetField(8)),
+         pkt_obt_fin_db = atoll(row->GetField(5));
-                                         perc,
+         time_in_db = atoll(row->GetField(6));
-                                         idN,(type_Rel_ROOT)relaz);
+         time_fin_db = atoll(row->GetField(7));
-                         }
+         boot_num_db = atoll(row->GetField(8));
-                         else{
+         perc = atof(row->GetField(9));
-                                 mainLogUtil->logInfo("Found ROOT files in DB better than current ROOT file");
+         log.str("");
-                                 if(relaz == AFTER){
+         log << "*** ROOT file found in DB has idN= " << idN << "  root_id_db= " << root_id_db;
-                                         mainLogUtil->logInfo("Relaz:AFTER = Changing Init values of the Current ROOT file");
+         log << " pkt_num_in_db= " << pkt_num_in_db << "  pkt_num_fin_db= " << pkt_num_fin_db << "  pkt_obt_in_db= "
-                                         pkt_number_init= atoi(row->GetField(3));
+             << pkt_obt_in_db << "  pkt_obt_fin_db= " << pkt_obt_fin_db;
-                                         obt_init= atoi(row->GetField(5));
+         log << "  time_in_db= " << time_in_db << "  time_fin_db= " << time_fin_db << " boot_num_db= " << boot_num_db
-                                         real_time_init= atoi(row->GetField(7));
+             << "  perc= " << perc << "  ***";
-                                 }
+         log << "\n*** Current ROOT file has pkt_number_init= " << pkt_number_init << "  obt_init= " << obt_init
-                                 else if(relaz == BEFORE){
+             << "  real_time_init= " << real_time_init;
-                                         mainLogUtil->logInfo("Relaz:BEFORE = Changing Last values of the Current ROOT file");
+         log << " pkt_number_last= " << pkt_number_last << "  obt_last= " << obt_last << "  real_time_last= "
-                                         pkt_number_last= atoi(row->GetField(2));
+             << real_time_last << " ***";
-                                         obt_last= atoi(row->GetField(4));
+         slog = log.str();
-                                         real_time_last= atoi(row->GetField(6));
+         mainLogUtil->logAll(slog);
-                                 }
+         if (perc > percentage) {
-                                 else if(relaz == SMALLER)
+           mainLogUtil->logInfo("Current ROOT file is better than the one in DB");
-                                 {
+           //modifica DB
-                                         //non devo proprio salvarlo ed esco ...
+           updateMergeROOT_DB(Table_ROOT_Merging, root_id_db, pkt_num_in_db, pkt_num_fin_db, pkt_obt_in_db,
-                                         mainLogUtil->logInfo("Relaz:SMALLER = Nothing to save");
+               pkt_obt_fin_db, time_in_db, time_fin_db, boot_num_db, perc, idN, (type_Rel_ROOT) relaz);
-                                         mainLogUtil->logInfo("Finish merging ROOT files");
+         }
-                                         if(res){delete res; res = NULL;}
+         else {
-                                         if(row){delete row; row = NULL;}
+           mainLogUtil->logInfo("Found ROOT file in DB is better than current ROOT file");
-                                         return true;
+           if (relaz == AFTER) {
-                                 }
+             mainLogUtil->logInfo("Relaz:AFTER = Changing Init values of the Current ROOT file");
-                                 else if(relaz == BIGGER)//spezzettamento
+             pkt_number_init = (pkt_num_fin_db + 1);
-                                 {
+             obt_init = pkt_obt_fin_db;
-                                         mainLogUtil->logInfo("Relaz:BIGGER = (1st part) Saving the first part of the Current ROOT file");
+             real_time_init = time_fin_db;
-                                         saveMergeROOT_DB(Table_ROOT_Merging, my_id,
+             log.str("");
-                                                 pkt_number_init, atoi(row->GetField(2)),
+             log << "\n*** Current ROOT file becomes: pkt_number_init= " << pkt_number_init << "  obt_init= "
-                                                 obt_init, atoi(row->GetField(4)),
+                 << obt_init << "  real_time_init= " << real_time_init;
-                                                 real_time_init, atoi(row->GetField(6)),
+             log << " pkt_number_last= " << pkt_number_last << "  obt_last= " << obt_last << "  real_time_last= "
-                                                 boot_number,
+                 << real_time_last << " ***";
-                                                 percentage);
+             slog = log.str();
+             mainLogUtil->logAll(slog);
-                                         mainLogUtil->logInfo("Relaz:BIGGER = (2nd part)Changing Init values of the Current ROOT file");
+           }
-                                         pkt_number_init= atoi(row->GetField(3));
+           else if (relaz == BEFORE) {
-                                         obt_init= atoi(row->GetField(5));
+             mainLogUtil->logInfo("Relaz:BEFORE = Changing Last values of the Current ROOT file");
-                                         real_time_init= atoi(row->GetField(7));
+             pkt_number_last = (pkt_num_in_db - 1);
-                                 }
+             obt_last = pkt_obt_in_db;
-                         }
+             real_time_last = time_in_db;
-                 }//for num_rows
-           }
+             log.str("");
-         else{
+             log << "\n*** Current ROOT file becomes: pkt_number_init= " << pkt_number_init << "  obt_init= "
-                 //marco_new:
+                 << obt_init << "  real_time_init= " << real_time_init;
-                 mainLogUtil->logInfo("Found 0 ROOT files in DB that can be merged with current ROOT file");
+             log << " pkt_number_last= " << pkt_number_last << "  obt_last= " << obt_last << "  real_time_last= "
+                 << real_time_last << " ***";
-         }
+             slog = log.str();
+             mainLogUtil->logAll(slog);
-         //marco_new:???
+           }
-         if(res){delete res; res = NULL;}
+           else if (relaz == SMALLER) {
-         if(row){delete row; row = NULL;}
+             //non devo proprio salvarlo ed esco ...
- }//for
+             mainLogUtil->logInfo("Relaz:SMALLER = Nothing to save");
+             mainLogUtil->logInfo("\nFinish merging ROOT files");
-         mainLogUtil->logInfo("Saving Current ROOT file");
+             if (res) {
-         saveMergeROOT_DB(Table_ROOT_Merging, my_id,
+               delete res;
-                          pkt_number_init, pkt_number_last,
+               res = NULL;
-                          obt_init, obt_last,
+             }
-                          real_time_init, real_time_last,
+             if (row) {
-                          boot_number,
+               delete row;
-                          percentage);
+               row = NULL;
+             }
+             return true;
+           }
+           else if (relaz == BIGGER)//spezzettamento
+           {
+             mainLogUtil->logInfo("Relaz:BIGGER = (1st part) Saving the first part of the Current ROOT file");
+             saveMergeROOT_DB(Table_ROOT_Merging, my_id, pkt_number_init, (pkt_num_in_db - 1), obt_init, pkt_obt_in_db,
+                 real_time_init, time_in_db, boot_number, percentage);
+             mainLogUtil->logInfo("Relaz:BIGGER = (2nd part)Changing Init values of the Current ROOT file");
+             pkt_number_init = (pkt_num_fin_db + 1);
+             obt_init = pkt_obt_fin_db;
+             real_time_init = time_fin_db;
+             log.str("");
+             log << "\n*** Current ROOT file becomes: pkt_number_init= " << pkt_number_init << "  obt_init= "
+                 << obt_init << "  real_time_init= " << real_time_init;
+             log << " pkt_number_last= " << pkt_number_last << "  obt_last= " << obt_last << "  real_time_last= "
+                 << real_time_last << " ***";
+             slog = log.str();
+             mainLogUtil->logAll(slog);
+           }//if relaz
+         }//if perc
+       }//for num_rows
+     }//if num_rows
+     if (res) {
+       delete res;
+       res = NULL;
+     }
+     if (row) {
+       delete row;
+       row = NULL;
+     }
+   }//for relaz
+   mainLogUtil->logInfo("Saving Current ROOT file");
+   saveMergeROOT_DB(Table_ROOT_Merging, my_id, pkt_number_init, pkt_number_last, obt_init, obt_last, real_time_init,
+       real_time_last, boot_number, percentage);
-         mainLogUtil->logInfo("Finish merging ROOT files");
+   mainLogUtil->logInfo("Finish merging ROOT files");
    return true;
  }
  //unsigned int root_id,  percentage non le devo modificare
- bool PacketUser::updateMergeROOT_DB(char* table_name,
+ bool PacketUser::updateMergeROOT_DB(const char* table_name, unsigned int root_id, unsigned long int pkt_number_in,
-                         unsigned  int root_id,
+     unsigned long int pkt_number_fin, unsigned long int obt_in, unsigned long int obt_fin,
-                         unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
+     unsigned long int mtime_init, unsigned long int mtime_last, unsigned long int mboot_num, double bad_perc,
-                         unsigned long int obt_in, unsigned long int obt_fin,
+     unsigned int ID_record, type_Rel_ROOT type_rel) {
-                 unsigned long int mtime_init,   unsigned long int mtime_last,
-                         unsigned long int mboot_num,
+   stringstream oss;
-                         double bad_perc,
+   oss.str("");
-                         unsigned int ID_record, type_Rel_ROOT type_rel){
-         stringstream oss;
+   if (type_rel == AFTER) {
-         oss.str("");
+     mainLogUtil->logInfo("Relaz:AFTER = Updating Last values of the DB ROOT file");
+     //marco_new:tolti tutti gli apici che qui non devono essere
-         if(type_rel == AFTER){
+     oss << "UPDATE " << table_name << " SET PKT_NUMBER_FINAL =" << (pkt_number_init - 1) << ", PKT_OBT_FINAL ="
-                 mainLogUtil->logInfo("Relaz:AFTER = Updating Last values of the DB ROOT file");
+         << obt_init << ", REAL_TIME_LAST =" << real_time_init << " WHERE ID_N =" << ID_record << ";";
-                 //marco_new:tolti tutti gli apici che qui non devono essere
-                 oss << "UPDATE "<< table_name
+   }
-                 << " SET PKT_NUMBER_FINAL ="<< pkt_number_init
+   else if (type_rel == BEFORE) {
-                         <<", PKT_OBT_FINAL ="<< obt_init
+     mainLogUtil->logInfo("Relaz:BEFORE = Updating Init values of the DB ROOT file");
-                     <<", REAL_TIME_LAST ="<< real_time_init<<" WHERE ID_N ="<< ID_record <<";";
+     oss << "UPDATE " << table_name << " SET PKT_NUMBER_INIT =" << (pkt_number_last + 1) << ", PKT_OBT_INIT ="
-         }
+         << obt_last << ", REAL_TIME_INIT =" << real_time_last << " WHERE ID_N =" << ID_record << ";";
-         else if(type_rel == BEFORE){
+   }
-                         mainLogUtil->logInfo("Relaz:BEFORE = Updating Init values of the DB ROOT file");
+   else if (type_rel == SMALLER) {
-                 oss << "UPDATE "<< table_name
+     //spezzettamentento
-                 << " SET PKT_NUMBER_INIT ="<< pkt_number_last
+     mainLogUtil->logInfo("Relaz:SMALLER = (1st part) Updating Last values of the DB ROOT file");
-                         <<", PKT_OBT_INIT ="<< obt_last
-                     <<", REAL_TIME_INIT ="<< real_time_last<<" WHERE ID_N ="<< ID_record<<";";
+     oss << "UPDATE " << table_name << " SET PKT_NUMBER_FINAL=" << (pkt_number_init - 1) << ", PKT_OBT_FINAL ="
-         }
+         << obt_init << ", REAL_TIME_LAST =" << real_time_init << " WHERE ID_N =" << ID_record << ";";
-         else if(type_rel == SMALLER){
-                 //spezzettamentento
+     mainLogUtil->logInfo("Relaz:SMALLER = (2nd part) Saving the second part of the DB ROOT file");
-                 mainLogUtil->logInfo("Relaz:SMALLER = (1st part) Updating Last values of the DB ROOT file");
+     saveMergeROOT_DB(table_name, root_id, (pkt_number_last + 1), pkt_number_fin, obt_last, obt_fin, real_time_last,
-                 oss << "UPDATE "<< table_name
+         mtime_last, mboot_num, bad_perc);
-                         << " SET PKT_NUMBER_FINAL="<< pkt_number_init
+   }
-                         <<", PKT_OBT_FINAL ="<< obt_init
+   else if (type_rel == BIGGER) {
-                             <<", REAL_TIME_LAST ="<< real_time_init<<" WHERE ID_N ="<< ID_record<<";";
+     //marco_new: ok anche se coincidenti etc
+     //    oss << "DELETE FROM "<< table_name <<" WHERE ID_N ="<< ID_record<<";"; // EMILIANO
-                         mainLogUtil->logInfo("Relaz:SMALLER = (2nd part) Saving the second part of the DB ROOT file");
+     oss << "UPDATE " << table_name << " SET GOOD=0 WHERE ID_N =" << ID_record << ";"; // EMILIANO DO NOT DELETE FROM ROOT_TABLE_MERGING JUST SET GOOD FLAG TO ZERO
+     mainLogUtil->logInfo("Record deleted from merging table");
-                         saveMergeROOT_DB(table_name, root_id,
+   }
-                          pkt_number_last, pkt_number_fin,
+   else
-                          obt_last, obt_fin,
+     return false;
-                          real_time_last, mtime_last,
-                          mboot_num,
+   string msg = oss.str();
-                          bad_perc);
+   mainLogUtil->logInfo(msg);
-         }
-         else if(type_rel == BIGGER){
+   stringstream oss1;
-         //marco_new: ok anche se coincidenti etc
+   oss1.str() = "";
-           oss << "DELETE FROM "<< table_name <<" WHERE ID_N ="<< ID_record<<";";
+   string msg1;
-           mainLogUtil->logInfo("Rimosso record in Tabella merging");
-         }
+   TSQLResult* res = NULL;
-         else
+   res = sqlServer->Query(oss.str().c_str());
-                 return false;
+   if (!res) {
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
+     msg1 = oss1.str();
+     mainLogUtil->logError(msg1);
-         string msg = oss.str();
+     return false;
-         mainLogUtil->logInfo(msg);
+   }
+   if (res) {
-         stringstream oss1;
+     delete res;
-         oss1.str()="";
+     res = NULL;
-         string msg1;
+   }
+   return true;
-    TSQLResult* res=NULL;
-    res= sqlServer->Query(oss.str().c_str());
-    if(!res)
-    {
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
-            msg1=oss1.str();
-            mainLogUtil->logError(msg1);
-            return false;
-    }
-    if(res){delete res; res = NULL;}
-    return true;
  }
- //marco_new: check here
+ //cerca eventuali ROOT files in DB che possono venire mergiati
- TSQLResult* PacketUser::Select_merging(char* table_name, unsigned long int mtime_init, unsigned long int mtime_last, type_Rel_ROOT type_rel)
+ //marco_new bordi: messo in after a before casi in cui smaller con un bordo in comune
- {
+ //marco_new bordi: messo in bigger casi con bordi in comune; tra questi anche caso particolare di coincidente
+ //marco_new bordi: smaller resta solo caso in cui DB e' piu largo sia a dx che a sx
- //      unsigned  int idN=0;
+ TSQLResult* PacketUser::Select_merging(const char* table_name, unsigned long int mtime_init, unsigned long int mtime_last,
-         TSQLResult* res=NULL;
+     type_Rel_ROOT type_rel) {
-         stringstream query;
+   TSQLResult* res = NULL;
-         query.str("");
+   stringstream query;
+   query.str("");
-         //marco_new bordi: messo in after a before casi in cui smaller con un bordo in comune
-         //marco_new bordi: messo in bigger casi con bordi in comune; tra questi anche caso particolare di coincidente
+   if (type_rel == AFTER)
-         //marco_new bordi: smaller resta solo caso in cui DB � piu largo sia a dx che a sx
+     query << "select * from " << table_name << " where GOOD=1 and REAL_TIME_LAST > " << mtime_init
-         if(type_rel == AFTER)
+         << " and REAL_TIME_LAST <= " << mtime_last << " and REAL_TIME_INIT < " << mtime_init; // EMI
-           query<<"select * from "<<table_name<<" where REAL_TIME_LAST > "<< mtime_init <<" and REAL_TIME_LAST <= "<< mtime_last <<" and REAL_TIME_INIT < "<< mtime_init;
+   else if (type_rel == BEFORE)
-         else if(type_rel == BEFORE)
+     query << "select * from " << table_name << " where GOOD=1 and REAL_TIME_INIT >= " << mtime_init
-           query<<"select * from "<<table_name<<" where REAL_TIME_INIT >= "<< mtime_init <<" and REAL_TIME_INIT < "<< mtime_last <<" and REAL_TIME_LAST > "<< mtime_last;
+         << " and REAL_TIME_INIT < " << mtime_last << " and REAL_TIME_LAST > " << mtime_last; // EMI
-         else if(type_rel == SMALLER)
+   else if (type_rel == SMALLER)
-           query<<"select * from "<<table_name<<" where REAL_TIME_INIT < "<< mtime_init <<" and REAL_TIME_LAST > "<< mtime_last;
+     query << "select * from " << table_name << " where GOOD=1 and REAL_TIME_INIT < " << mtime_init
-         else if(type_rel == BIGGER)
+         << " and REAL_TIME_LAST > " << mtime_last; // EMI
-                 query<<"select * from "<<table_name<<" where REAL_TIME_INIT >= "<< mtime_init <<" and REAL_TIME_LAST <= "<< mtime_last;
+   else if (type_rel == BIGGER)
-         else
+     query << "select * from " << table_name << " where GOOD=1 and REAL_TIME_INIT >= " << mtime_init
-                 return 0;
+         << " and REAL_TIME_LAST <= " << mtime_last; // EMI
+   else
-         query<< " order by REAL_TIME_INIT ASC";//marco_new: inutile
+     return 0;
-         //      query<<" and NUM_PKT_SAVED - BAD_PKT_CALREAD - BAD_PKT_READ - BAD_PKT >= 2" ;
+   query << " order by REAL_TIME_INIT ASC";//marco_new: inutile
+   //se volessi mettere un filtro sulla qualita'
-         string msg = query.str();
+   //    query<<" and NUM_PKT_SAVED - BAD_PKT_CALREAD - BAD_PKT_READ - BAD_PKT >= 2" ;
-         mainLogUtil->logAll(msg);
+   string msg = query.str();
+   mainLogUtil->logAll(msg);
-         res= sqlServer->Query(query.str().c_str());
+   res = sqlServer->Query(query.str().c_str());
+   stringstream oss1;
-         stringstream oss1;
+   oss1.str() = "";
-          oss1.str()="";
+   string msg1;
-          string msg1;
+   if (!res) {
-          if (!res)
+     oss1 << "DBError UNABLE to: " << query.str().c_str() << endl;
-          {
+     msg1 = oss1.str();
-                  oss1<<"DBError UNABLE to: "<<query.str().c_str()<<endl;
+     mainLogUtil->logError(msg1);
-                  msg1=oss1.str();
+   }
-                  mainLogUtil->logError(msg1);
-          }
+   return res;
+ }
-         return res;
- }
+ bool PacketUser::saveMergeROOT_DB(const 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,
- bool PacketUser::saveMergeROOT_DB(char* table_name,  unsigned int root_id,
+     unsigned long int mtime_init, unsigned long int mtime_last, unsigned long int mboot_num, double percentage) {
-                         unsigned long int pkt_number_in, unsigned long int pkt_number_fin,
-                         unsigned long int obt_in, unsigned long int obt_fin,
+   stringstream oss;
-                 unsigned long int mtime_init,   unsigned long int mtime_last,
+   oss.str("");
-                         unsigned long int mboot_num,
+   oss << "INSERT INTO " << table_name
-                         double percentage)
+       << " (ID_N, ROOT_ID_N, PKT_NUMBER_INIT, PKT_NUMBER_FINAL, PKT_OBT_INIT, PKT_OBT_FINAL, REAL_TIME_INIT, REAL_TIME_LAST, BOOT_NUMBER, BAD_PKT_PERCENTAGE, INSERT_TIME, INSERTED_BY)"
- {
+       << " VALUES ('" << 0 << "','" << root_id << "','" << pkt_number_in << "','" << pkt_number_fin << "','" << obt_in
+       << "','" << obt_fin << "','" << mtime_init << "','" << mtime_last << "','" << mboot_num << "','" << percentage
-         stringstream oss;
+       << "'," << "NULL" << ",'" << tag_value << "'" << ")";
-         oss.str("");
-         oss << "INSERT INTO "<< table_name <<" (ID_N, ROOT_ID_N, PKT_NUMBER_INIT, PKT_NUMBER_FINAL, PKT_OBT_INIT, PKT_OBT_FINAL, REAL_TIME_INIT, REAL_TIME_LAST, BOOT_NUMBER, BAD_PKT_PERCENTAGE, INSERT_TIME)"
+   string msg = oss.str();
-     << " VALUES ('"<<0<< "','" <<root_id<<"','"<< pkt_number_in <<"','"<< pkt_number_fin << "','"<< obt_in <<"','"<< obt_fin<< "','"
+   mainLogUtil->logAll(msg);
-     << mtime_init << "','" << mtime_last << "','"
-         << mboot_num <<"','"
+   //marco_new: controlla
-         << percentage <<"',"
+   //marco_new: esci se sono arrivato a zero
-     <<"NULL"<<
+   //    if(real_time_last==real_time_init){
-     ")";
+   if (mtime_init == mtime_last) {
+     mainLogUtil->logAll("Nothing to be saved");
-         string msg = oss.str();
-         mainLogUtil->logAll(msg);
+     //          if(res){delete res; res = NULL;}
+     //          if(row){delete row; row = NULL;}
-         //marco_new: controlla
+     return true;
-         //marco_new: esci se sono arrivato a zero
+   }
- //      if(real_time_last==real_time_init){
-         if(mtime_init==mtime_last){
+   stringstream oss1;
-                 mainLogUtil->logAll("Nothing to be saved");
+   oss1.str() = "";
+   string msg1;
- //              if(res){delete res; res = NULL;}
- //              if(row){delete row; row = NULL;}
+   TSQLResult* res = NULL;
-                 return true;
+   res = sqlServer->Query(oss.str().c_str());
-         }
+   if (!res) {
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
+     msg1 = oss1.str();
-         stringstream oss1;
+     mainLogUtil->logError(msg1);
-         oss1.str()="";
+     return false;
-         string msg1;
+   }
+   if (res) {
-    TSQLResult* res=NULL;
+     delete res;
-    res= sqlServer->Query(oss.str().c_str());
+     res = NULL;
-    if(!res)
+   }
-    {
+   return true;
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
-            msg1=oss1.str();
-            mainLogUtil->logError(msg1);
-            return false;
-    }
-    if(res){delete res; res = NULL;}
-    return true;
  }
  //Utility: return max(IDN)
- unsigned  int PacketUser::select_maxIDN_DB(char* table_name)
+ unsigned int PacketUser::select_maxIDN_DB(const char* table_name) {
- {
- if (!strcmp(table_name,Table_ROOT_Bad))
+   if (!strcmp(table_name, Table_ROOT_Bad)) {
- {
+     return 0;
-         return 0;
+   }
- }
+   unsigned int idN = 0;
-         unsigned  int idN=0;
+   TSQLResult* res = NULL;
-         TSQLResult* res=NULL;
+   stringstream oss;
-         stringstream oss;
+   oss.str("");
-     oss.str("");
+   oss << "select max(ID_N) from " << table_name;
-     oss<<"select max(ID_N) from "<<table_name;
+   //    string msg = oss.str();
-         string msg = oss.str();
+   //    mainLogUtil->logAll(msg);
-         mainLogUtil->logAll(msg);
+   res = sqlServer->Query(oss.str().c_str());
-     res= sqlServer->Query(oss.str().c_str());
+   stringstream oss1;
-         stringstream oss1;
+   oss1.str() = "";
-         oss1.str()="";
+   string msg1;
-         string msg1;
+   if (!res) {
-         if(!res)
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
-         {
+     msg1 = oss1.str();
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
+     mainLogUtil->logError(msg1);
-                 msg1=oss1.str();
+     return 0;
-                 mainLogUtil->logError(msg1);
+   }
-                 return 0;
-         }
+   TSQLRow* row = NULL;
+   row = res->Next();
-         TSQLRow* row=NULL;
+   if (!row) {
-         row=res->Next();
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
-     if (!row )
+     msg1 = oss1.str();
-     {
+     mainLogUtil->logError(msg1);
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
+     return 0;
-                 msg1=oss1.str();
+   }
-                 mainLogUtil->logError(msg1);
-                 return 0;
+   idN = atoi(row->GetField(0));
-         }
+   if (row) {
+     delete row;
-         idN=atoi(row->GetField(0));
+     row = NULL;
-         if(row){delete row; row = NULL;}
+   }
-         if(res){delete res; res = NULL;}
+   if (res) {
-         return idN;
+     delete res;
+     res = NULL;
+   }
+   oss << ". idN = " << idN;
+   string msg = oss.str();
+   mainLogUtil->logAll(msg);
+   return idN;
  }
  /**
   * Lock par=table, if par=null lock all tables
   */
- int PacketUser::LockTables(char* tableTobeLocked)
+ int PacketUser::LockTables(const char* tableTobeLocked) {
- {
+   //se non ho il DB  :)
-         //se non ho il DB  :)
+   if (!do_cont_check)
-         if(!do_cont_check) return 999;
+     return 999;
-         TSQLResult* res=NULL;
+   TSQLResult* res = NULL;
-         stringstream oss;
+   stringstream oss;
-     oss.str("");
+   oss.str("");
-         if(!tableTobeLocked)
+   if (!tableTobeLocked)
-                 oss << "lock table "<<Table_ROOT_Good<<" write, "<<Table_ROOT_Bad<<" write, "<<Table_GL_RESURS_OFFSET<<" write, "<<Table_ROOT_Merging<<" write;";
+     oss << "lock table " << Table_ROOT_Good << " write, " << Table_ROOT_Bad << " write, " << Table_GL_RESURS_OFFSET
-         else
+         << " write, " << Table_ROOT_Merging << " write;";
-                 oss << "lock table "<<tableTobeLocked<<" write; ";
+   else
+     oss << "lock table " << tableTobeLocked << " write; ";
-         string msg = oss.str();
-         mainLogUtil->logAll(msg);
+   string msg = oss.str();
+   mainLogUtil->logAll(msg);
-         res= sqlServer->Query(oss.str().c_str());
+   res = sqlServer->Query(oss.str().c_str());
-         stringstream oss1;
-         oss1.str()="";
+   stringstream oss1;
-         string msg1;
+   oss1.str() = "";
+   string msg1;
-         if(!res)
-         {
+   if (!res) {
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
-                 msg1=oss1.str();
+     msg1 = oss1.str();
-                 mainLogUtil->logError(msg1);
+     mainLogUtil->logError(msg1);
-                 return 1;
+     return 1;
-         }
+   }
-         if(res){delete res; res = NULL;}
+   if (res) {
-         mainLogUtil->logAll("######################### TABLES LOCKED ############################");
+     delete res;
-         return 0;
+     res = NULL;
+   }
+   mainLogUtil->logAll("TABLES LOCKED");
+   return 0;
  }
  /**
   * UNLock tables
   */
- int PacketUser::UnLockTables(){
+ int PacketUser::UnLockTables() {
-         //se non ho il DB  :)
+   //se non ho il DB  :)
-         if(!do_cont_check) return 999;
+   if (!do_cont_check)
+     return 999;
-         TSQLResult* res=NULL;
-         stringstream oss;
+   TSQLResult* res = NULL;
-     oss.str("");
+   stringstream oss;
-         oss << "unlock tables;";
+   oss.str("");
+   oss << "unlock tables;";
+   string msg = oss.str();
+   mainLogUtil->logAll(msg);
+   res = sqlServer->Query(oss.str().c_str());
+   stringstream oss1;
+   oss1.str() = "";
+   string msg1;
+   if (!res) {
+     oss1 << "DBError UNABLE to: " << oss.str().c_str() << endl;
+     msg1 = oss1.str();
+     mainLogUtil->logError(msg1);
+     return 1;
+   }
+   if (res) {
+     delete res;
+     res = NULL;
+   }
+   mainLogUtil->logAll("TABLES UNLOCKED");
-     string msg = oss.str();
+   return 0;
-         mainLogUtil->logAll(msg);
-         res= sqlServer->Query(oss.str().c_str());
-         stringstream oss1;
-         oss1.str()="";
-         string msg1;
-         if(!res)
-         {
-            oss1<<"DBError UNABLE to: "<<oss.str().c_str()<<endl;
-                 msg1=oss1.str();
-                 mainLogUtil->logError(msg1);
-                 return 1;
-         }
-         if(res){delete res; res = NULL;}
-         mainLogUtil->logAll("######################### TABLES UNLOCKED ############################");
-         return 0;
  }
  /*********************************************************/
  //marco_new_31
- void PacketUser::OpenDBConnection(char* tableTobeLocked){
+ void PacketUser::OpenDBConnection(const char* tableTobeLocked) {
-         mainLogUtil->logAll("######################### OpenDBConnection ############################");
+   if (do_cont_check) {
-         if(do_cont_check){
+     //controllo che non sia gia' aperta
-                 //controllo che non sia gi� aperta
+     if (!sqlServer) {
-                 if(!sqlServer){
+       sqlServer = TSQLServer::Connect(connection, db_user, db_pwd);
-                         sqlServer = TSQLServer::Connect(connection,db_user,db_pwd);
+       if ((!sqlServer) || (!(sqlServer->IsConnected()))) {
-                         if ((!sqlServer)||(!(sqlServer->IsConnected()))){cout<<"Can not connect with MYSQL sever"<<endl;}
+         cout << "Can not connect with MYSQL sever" << endl;
+       }
-                         //marco_new: blocca tutte le tabelle
+       mainLogUtil->logAll("Connected to DB");
-                         LockTables(tableTobeLocked);
+       stringstream myquery;
-                         mainLogUtil->logAll("######################### OpenDBConnection OK ############################");
+       myquery.str("");
-                 }
+       myquery << "SET time_zone='+0:00'";
-         }
+       sqlServer->Query(myquery.str().c_str());
+       //blocca le tabelle
+       LockTables(tableTobeLocked);
+     }
+   }
  }
  //marco_new_31
- void PacketUser::CloseDBConnection(){
+ void PacketUser::CloseDBConnection() {
-         mainLogUtil->logAll("######################### CloseDBConnection ############################");
+   if (do_cont_check) {
-         if(do_cont_check){
+     //controllo che ce ne sia una aperta
-                 //controllo che ce ne sia una aperta
+     if (sqlServer && sqlServer->IsConnected()) {
-                 if(sqlServer && sqlServer->IsConnected()){
+       //marco_new: sblocca tutte le tabelle
-                         //marco_new: sblocca tutte le tabelle
+       UnLockTables();
-                         UnLockTables();
+       sqlServer->Close();
-                         sqlServer->Close();
+       delete sqlServer;
+       sqlServer = NULL;
-                         //marco_new_01: ??
+       mainLogUtil->logAll("Closed Connection to DB");
-                         delete sqlServer;
+     }
+   }
-                         sqlServer=NULL;
-                         mainLogUtil->logAll("######################### CloseDBConnection OK ############################");
-                 }
-         }
  }
  /***********************************************************************************************************************/
  /*#################################################### HIC SUNT LEONES ################################################*/
  /***********************************************************************************************************************/
  //UNUSED: dbg functions...
  //Return the system time in ms
- unsigned long long PacketUser::Record_Time(){
+ unsigned long long PacketUser::Record_Time() {
-         timeval tv;
+   timeval tv;
-         gettimeofday(&tv,NULL);
+   gettimeofday(&tv, NULL);
-         unsigned long long timems =  (unsigned long long)tv.tv_sec * (unsigned long long)1000 + tv.tv_usec / 1000;
+   unsigned long long timems = (unsigned long long) tv.tv_sec * (unsigned long long) 1000 + tv.tv_usec / 1000;
-         return timems;
+   return timems;
  }
  //dbg_functions:
  //UNUSED. save a packet in a file
- void PacketUser::savePKT_file(char* headerPkt,
+ void PacketUser::savePKT_file(char* headerPkt, char* pamPkt, long int length, bool append, char* nomefile) {
-                                                          char* pamPkt,
+   char fno[80] = "";
-                                                          long int length,
+   ofstream fout;
-                                                          bool append,
+   sprintf(fno, "%s/pkt%d_of_%s.pkt", gSystem->ExpandPathName(outDir), numPKTSaved, nomefile); // EMI
-                                                          char* nomefile)
- {
+   if (append == true)
-         char fno[80]="";
+     fout.open(fno, ios::binary | ios::app);
-         ofstream fout;
+   else
-         sprintf(fno,"%s/pkt%d_of_%s.pkt", outDir, numPKTSaved, nomefile);
+     fout.open(fno, ios::binary);
-         if(append==true)
+   if (!fout) {
-                 fout.open(fno, ios::binary | ios::app);
+     cout << "can not open output file " << fno << endl;
-         else
+     return;
-                 fout.open(fno, ios::binary);
+   }
+   fout.write(headerPkt, LENGTH_HEADER_PKT);
-         if (!fout) {cout<<"can not open output file "<<fno<<endl; return;}
+   fout.write(pamPkt, length);
-         fout.write(headerPkt,LENGTH_HEADER_PKT);
+   fout.close();
-         fout.write(pamPkt,length);
-         fout.close();
  }
  //UNUSED
- void PacketUser::saveALL_PKT(char* headerPkt, char* pamPkt, long int length, bool append)
+ void PacketUser::saveALL_PKT(char* headerPkt, char* pamPkt, long int length, bool append) {
- {
+   char fno[80] = "";
-         char fno[80]="";
+   ofstream fout;
-         ofstream fout;
+   if (append == true) {
-         if(append==true)
+     sprintf(fno, "%s/packets.pkt", gSystem->ExpandPathName(outDir)); // EMI
-         {
+     fout.open(fno, ios::binary | ios::app);
-                 sprintf(fno,"%s/packets.pkt", outDir);
+   }
-                 fout.open(fno, ios::binary | ios::app);
+   else {
-         }
+     sprintf(fno, "%s/packet%d.pkt", gSystem->ExpandPathName(outDir), numPKT); // EMI
-         else{
+     fout.open(fno, ios::binary);
-                 sprintf(fno,"%s/packet%d.pkt", outDir, numPKT );
+   }
-                 fout.open(fno, ios::binary);
-         }
+   if (!fout) {
+     cout << "can not open output file " << fno << endl;
-         if (!fout) {cout<<"can not open output file "<<fno<<endl; return;}
+     return;
-         fout.write(headerPkt,LENGTH_HEADER_PKT);
+   }
-         fout.write(pamPkt,length);
+   fout.write(headerPkt, LENGTH_HEADER_PKT);
-         fout.close();
+   fout.write(pamPkt, length);
+   fout.close();
  }
  }

 Legend:



Removed from v.1.1
 


changed lines


 
Added in v.1.9
 Legend:



Removed from v.1.1
 


changed lines


 
Added in v.1.9
-Removed from v.1.1
+Added in v.1.9

	ViewVC Help
Powered by ViewVC 1.1.23