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

Diff of /chewbacca/PamOffLineSW/PacketUser.cpp

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.9 by mocchiut, Thu Oct 1 08:55:42 2009 UTC revision 1.17 by mocchiut, Wed Feb 3 14:11:38 2010 UTC
# Line 1  Line 1 
1  //============================================================================  //============================================================================
2  // $Id: PacketUser.cpp,v 1.8 2009/08/05 18:48:42 pam-fi Exp $  // $Id: PacketUser.cpp,v 1.16 2010/02/02 15:26:09 mocchiut Exp $
3  // Description :  // Description :
4  //============================================================================  //============================================================================
5  #include "PacketUser.h"  #include "PacketUser.h"
6  #include <sys/time.h>  #include <sys/time.h>
7    #include <iostream>
8    
9  namespace PamOffLineSW {  namespace PamOffLineSW {
10  extern LogUtil* mainLogUtil;  extern LogUtil* mainLogUtil;
# Line 20  extern unsigned int mmm_number; Line 21  extern unsigned int mmm_number;
21  extern unsigned int orbit_number;  extern unsigned int orbit_number;
22  extern unsigned long int time_Offset;  extern unsigned long int time_Offset;
23  extern bool tryMerge;  extern bool tryMerge;
24    extern bool candelete; // EM
25  //marco_new_01  //marco_new_01
26  extern bool single_connection;  extern bool single_connection;
27    
# Line 29  extern bool do_cont_check; Line 31  extern bool do_cont_check;
31  //marco_new_31:  //marco_new_31:
32  extern char* db_user;  extern char* db_user;
33  extern char* db_pwd;  extern char* db_pwd;
34  extern char* connection;  extern char* pelosconnection;
35    
36  //per tenere conto reset obt  //per tenere conto reset obt
37  extern unsigned long int max_pkt_obt;  extern unsigned long int max_pkt_obt;
# Line 64  PacketUser::PacketUser() { Line 66  PacketUser::PacketUser() {
66    last_time_sync_info_prevvalue = 0;    last_time_sync_info_prevvalue = 0;
67    time_is_estimated = false;    time_is_estimated = false;
68    
69      //EM
70      recoverlimit = 400;
71      idtorecover = new TArrayI(100);
72      arsize = 0;
73    
74    real_time_init = 0;    real_time_init = 0;
75    real_time_last = 0;    real_time_last = 0;
76    bad_pkt = 0;    bad_pkt = 0;
# Line 250  void PacketUser::setInit(unsigned long i Line 257  void PacketUser::setInit(unsigned long i
257    //good_pkt_Calib=0;    //good_pkt_Calib=0;
258    
259    //marco_NB:    //marco_NB:
260    //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 discontinuita` resetto come se mi trovassi in un nuovo download oppure uso i vecchi valori se esistono?
261    
262    obt_time_sync_prevvalue = obt_time_sync;    if ( obt_time_sync ) obt_time_sync_prevvalue = obt_time_sync; // save the last NOT NULL obt_time_sync! EM
263    last_time_sync_info_prevvalue = last_time_sync_info;    if ( last_time_sync_info ) last_time_sync_info_prevvalue = last_time_sync_info; // save the last NOT NULL last_time_sync
264    time_is_estimated = false;    time_is_estimated = false;
265    obt_time_sync = 0;    obt_time_sync = 0;
266    last_time_sync_info = 0;    last_time_sync_info = 0;
# Line 333  void PacketUser::setTimeSync(char* packe Line 340  void PacketUser::setTimeSync(char* packe
340    }    }
341    
342    //I don't need to retrieve them again if they are good    //I don't need to retrieve them again if they are good
343    if ((obt_time_sync) || (last_time_sync_info))    //  if ((obt_time_sync) || (last_time_sync_info))
344      return;    //    return;
345      // no, do it, since there is a (small indeed) time drift due to different clock of PAMELA CPU and RESURS CPU...
346    
347    obt_time_sync = (((UINT32) packet[5 + offset] << 24) & 0xFF000000) + (((UINT32) packet[6 + offset] << 16)    obt_time_sync = (((UINT32) packet[5 + offset] << 24) & 0xFF000000) + (((UINT32) packet[6 + offset] << 16)
348        & 0x00FF0000) + (((UINT32) packet[7 + offset] << 8) & 0x0000FF00) + (((UINT32) packet[8 + offset]) & 0x000000FF);        & 0x00FF0000) + (((UINT32) packet[7 + offset] << 8) & 0x0000FF00) + (((UINT32) packet[8 + offset]) & 0x000000FF);
# Line 387  void PacketUser::setBootNumber(char* pac Line 395  void PacketUser::setBootNumber(char* pac
395  //set the real time of the first packet and the last packet oif a group of packet if possible  //set the real time of the first packet and the last packet oif a group of packet if possible
396  void PacketUser::setReal_Time() {  void PacketUser::setReal_Time() {
397    
398    if (!obt_time_sync && !last_time_sync_info && numPKTSaved > 1000) {    if (!obt_time_sync && !last_time_sync_info && numPKTSaved > recoverlimit) {
399      time_is_estimated = true;      time_is_estimated = true;
400      obt_time_sync = obt_time_sync_prevvalue;      obt_time_sync = obt_time_sync_prevvalue;
401      last_time_sync_info = last_time_sync_info_prevvalue;      last_time_sync_info = last_time_sync_info_prevvalue;
# Line 412  void PacketUser::setReal_Time() { Line 420  void PacketUser::setReal_Time() {
420    }    }
421  }  }
422    
423    void PacketUser::setReal_TimeRECOVERY(
424    unsigned long int & _real_time_init,
425    unsigned long int & _real_time_last,
426    unsigned long int _obt_init,
427    unsigned long int _obt_last
428    ) {
429      
430      if (obt_time_sync || last_time_sync_info) {
431        _real_time_init = (_obt_init / 1000 - obt_time_sync) + last_time_sync_info;
432        //se obt si e' resettato
433        if (_obt_last < _obt_init) {
434          _real_time_last = (max_pkt_obt / 1000 + _obt_last / 1000 - obt_time_sync) + last_time_sync_info;
435          stringstream oss;
436          oss.str() = "";
437          oss << "obt_last(" << obt_last << ") < obt_init(" << obt_init
438              << "). It is due to Pamela Reset. Adding max_pkt_obt(" << max_pkt_obt
439              << ") to obt_last in order to compute real_time_last";
440          string msg = oss.str();
441          mainLogUtil->logWarning(msg);
442        }
443        else
444          _real_time_last = (_obt_last / 1000 - obt_time_sync) + last_time_sync_info;
445        _real_time_init += timeOffset;
446        _real_time_last += timeOffset;
447      }
448    }
449    
450    
451  //timeOffset  //timeOffset
452  //retrieve from table Table_GL_RESURS_OFFSET timeOffset    //retrieve from table Table_GL_RESURS_OFFSET timeOffset  
453  unsigned long int PacketUser::retrieveTimeOffset(const char * table) {  unsigned long int PacketUser::retrieveTimeOffset(const char * table) {
# Line 421  unsigned long int PacketUser::retrieveTi Line 457  unsigned long int PacketUser::retrieveTi
457    //if(!table){table=Table_GL_RESURS_OFFSET}    //if(!table){table=Table_GL_RESURS_OFFSET}
458    
459    if (!single_connection) {    if (!single_connection) {
460      OpenDBConnection(table);//Nota qui ho deciso di lockare solo questa tabella e non tutte      OpenDBConnection(NULL);// no, locak tutto Nota qui ho deciso di lockare solo questa tabella e non tutte
461    }    }
462    
463    UInt_t t0 = 0;//toffset    UInt_t t0 = 0;//toffset
# Line 496  void PacketUser::FinishLastGroup() { Line 532  void PacketUser::FinishLastGroup() {
532    setReal_Time();    setReal_Time();
533    FinishGroup(rootfilename);    FinishGroup(rootfilename);
534    mainLogUtil->logAll("######################### Closed the last group ############################");    mainLogUtil->logAll("######################### Closed the last group ############################");
535      //
536    if (single_connection) {    if (single_connection) {
537      CloseDBConnection();      CloseDBConnection();
538    }    }
# Line 504  void PacketUser::FinishLastGroup() { Line 541  void PacketUser::FinishLastGroup() {
541  //Finish the old root file  //Finish the old root file
542  void PacketUser::FinishGroup(char * filename) {  void PacketUser::FinishGroup(char * filename) {
543    if (pRun) {    if (pRun) {
544      pRun->WriteFiles();      if ( !( !real_time_init && !real_time_last && numPKTSaved <= recoverlimit ) || !candelete  ) pRun->WriteFiles();
545      delete pRun;      delete pRun;
546      pRun = NULL;      pRun = NULL;
547      stringstream close;      stringstream close;
548      close.str() = "";      close.str() = "";
549      string msg;      string msg;
550    
551      close << "######################### Close group in file: " << rootfilename << " ############################";      close << "TAG XX ######################### Close group in file: " << rootfilename << " ############################";
552      msg = close.str();      msg = close.str();
553      mainLogUtil->logInfo(msg);      mainLogUtil->logInfo(msg);
554    
# Line 530  void PacketUser::FinishGroup(char * file Line 567  void PacketUser::FinishGroup(char * file
567        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.";
568        msg = err.str();        msg = err.str();
569        mainLogUtil->logError(msg);        mainLogUtil->logError(msg);
570        return;        //      return;
571      }      }
572    
573      //se non ho salvato nessun pacchetto buono      //se non ho salvato nessun pacchetto buono
# Line 548  void PacketUser::FinishGroup(char * file Line 585  void PacketUser::FinishGroup(char * file
585        OpenDBConnection(NULL);//Nota qui ho deciso di lockare tutte le tabelle        OpenDBConnection(NULL);//Nota qui ho deciso di lockare tutte le tabelle
586      }      }
587    
588    
589      //don't save in Table_ROOT_Good and don't search for ROOT files in the same temporal range      //don't save in Table_ROOT_Good and don't search for ROOT files in the same temporal range
590      if ((!real_time_init) && (!real_time_last)) {      if ((!real_time_init) && (!real_time_last)) {
591        //saved in another table for future study        //saved in another table for future study
# Line 569  void PacketUser::FinishGroup(char * file Line 607  void PacketUser::FinishGroup(char * file
607          mainLogUtil->logError(msg);          mainLogUtil->logError(msg);
608        }        }
609    
       if (!single_connection) {  
         CloseDBConnection();  
       }  
   
       return;  
     }  
610    
     //saves info in DB in table Table_ROOT_Good  
     if (boot_number == 0)  
       boot_number = boot_number_prevvalue;  
   
     if (saveROOT_DB(  
         Table_ROOT_Good,  
         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,  
         numPKTSaved, fni, time_is_estimated) == true) {  
       oss << "Saved information regarding file: " << filename << " in table " << Table_ROOT_Good << " id= " << my_id;  
       msg = oss.str();  
       mainLogUtil->logInfo(msg);  
611    
612        if (tryMerge) {        if ( numPKTSaved > recoverlimit){ // EM
613          merge_ROOTfiles();          //
614        }          if ( obt_time_sync && last_time_sync_info ){
615      }            stringstream err;
616      else {            err.str() = "";
617              err << "(EM): -- RECOVERING WHEN NUMPACKET > "<< recoverlimit <<"!! -- file=<" << filename << ">. We have a previous time sync, immediate recovery!\n";
618              msg = err.str();
619              mainLogUtil->logInfo(msg);
620              //
621              setReal_TimeRECOVERY(
622                                   real_time_init,
623                                   real_time_last,
624                                   obt_init,
625                                   obt_last
626                                   );
627              //
628            } else {
629              stringstream err;
630              err.str() = "";
631              err << "TAG(tassa): -- RECOVERING WHEN NUMPACKET > "<< recoverlimit <<"!! -- file=<" << filename << ">. Saving in a queue to try alfer to recover it!\n";
632              msg = err.str();
633              mainLogUtil->logInfo(msg);
634              
635              //      TString qu = Form("select ID_N from ROOT_TABLE_BAD order by INSERT_TIME desc limit 1;"); //  <=========================
636              TString qu = Form("select ID_N from ROOT_TABLE_BAD where FILE_NAME='%s' and PKT_NUMBER_INIT=%i and INSERTED_BY='%s';",filename,pkt_number_init,tag_value); //  <=========================
637              TSQLResult *result = sqlServer->Query(qu.Data());
638              TSQLRow    *row = result->Next();
639              Int_t eid = -1;
640              if ( row ) eid = (Int_t)atoi(row->GetField(0));
641              idtorecover->AddAt(eid,arsize);
642              arsize++;
643              if ( arsize > 100 ) idtorecover->Set(arsize);
644              //    dbinfo *app = new dbinfo( outDir,
645              //                              filename, pkt_number_init, pkt_number_last, obt_init, obt_last, boot_number, timeOffset, bad_pkt, bad_pkt_EventReader, bad_pkt_CalibReader,
646              //                              numPKTSaved, fni, time_is_estimated);
647              //    m_dbinfos.push_back(app);
648            }
649            
650            CleanDisk();
651            //      if (!single_connection) {
652            //        CloseDBConnection();
653            //      }
654            //      return; // commented here...
655    
656          };
657        }
658    
659        if ( real_time_init || real_time_last) {
660          //saves info in DB in table Table_ROOT
661          if (boot_number == 0)
662            boot_number = boot_number_prevvalue;
663          
664          if (saveROOT_DB(
665                          Table_ROOT_Good,
666                          outDir, // here outDir is good, no expand EMI
667                          filename, pkt_number_init, pkt_number_last, obt_init, obt_last, obt_time_sync, last_time_sync_info,
668                          real_time_init, real_time_last, boot_number, timeOffset, bad_pkt, bad_pkt_EventReader, bad_pkt_CalibReader,
669                          numPKTSaved, fni, time_is_estimated) == true) {
670            oss.str() = "";
671            oss << "Saved information regarding file: " << filename << " in table " << Table_ROOT_Good << " id= " << my_id;
672            msg = oss.str();
673            mainLogUtil->logInfo(msg);
674            
675            if (tryMerge) {
676              merge_ROOTfiles();
677            }
678          } else {
679          oss.str() = "";
680        oss << "Problem storing information in DB regarding file: " << filename;        oss << "Problem storing information in DB regarding file: " << filename;
681        msg = oss.str();        msg = oss.str();
682        mainLogUtil->logError(msg);        mainLogUtil->logError(msg);
683      }        }
684        };
685    
686        // if dbinfo is not empty than
687        if ( arsize > 0 ){
688    
689          if ( !obt_time_sync || !last_time_sync_info ){
690            TString *nomino=new TString(rootfilename);
691            nomino->Remove(15);
692            TString qu = Form("select OBT_TIME_SYNC,LAST_TIME_SYNC_INFO from ROOT_TABLE where FILE_NAME like '%s_%%' and (abs(PKT_NUMBER_INIT-%lu)<50000 or abs(PKT_OBT_INIT-%lu)<3000000) limit 1;",nomino->Data(),pkt_number_init,obt_init);
693            //
694            oss.str() = "";
695            oss << "(EM) Trying to find obt_time_sync and last_time_sync_info from DB, query is: " << qu.Data();
696            msg = oss.str();
697            mainLogUtil->logInfo(msg);
698            //
699            TSQLResult *result = sqlServer->Query(qu.Data());
700            TSQLRow    *row = result->Next();
701            if ( row && result->GetRowCount() == 1 ){
702              obt_time_sync = (unsigned long int)atoll(row->GetField(0));
703              last_time_sync_info = (unsigned long int)atoll(row->GetField(1));
704              oss.str() = "";
705              oss << "(EM) found obt_time_sync and last_time_sync_info from DB! obt_time_sync =  " <<obt_time_sync <<" last_time_sync_info = " << last_time_sync_info;
706              msg = oss.str();
707              mainLogUtil->logInfo(msg);
708            };      
709            delete nomino;
710          };      
711    
712          if ( obt_time_sync && last_time_sync_info ){
713            //    if(!m_dbinfos.empty()){
714            //       while(!m_dbinfos.empty()){
715            //      dbinfo *app = m_dbinfos.back();
716            //      m_dbinfos.pop_back();
717            Int_t ez=0;
718            while ( ez < arsize ){
719              Int_t eid = idtorecover->At(ez);
720              if ( eid > -1 ){
721              
722                TString qu = Form("select FOLDER_NAME,FILE_NAME,PKT_NUMBER_INIT,PKT_NUMBER_FINAL,PKT_OBT_INIT,PKT_OBT_FINAL,BOOT_NUMBER,TIME_OFFSET,BAD_PKT,BAD_PKT_READ,BAD_PKT_CALREAD,NUM_PKT_SAVED,INPUT_NAME,TIME_IS_ESTIMATED from ROOT_TABLE_BAD where ID_N=%i;",eid);
723                TSQLResult *result = sqlServer->Query(qu.Data());
724                TSQLRow    *row = result->Next();
725                      
726                TString efolder_name="";
727                TString efile_name="";
728                unsigned long int epkt_number_in=0ULL;
729                unsigned long int epkt_number_fin=0ULL;
730                unsigned long int eobt_in=0ULL;
731                unsigned long int eobt_fin=0ULL;
732                unsigned long int emboot_num=0ULL;
733                unsigned long int etime_offset=0ULL;
734                int ebad_pkt=0;
735                int ebad_pkt_read=0;
736                int ebad_pkt_CalRead=0;
737                int enum_PKT_Saved=0;
738                TString enome_input="";
739                bool e_time_is_estimated=false;
740    
741                if ( row ){
742                  efolder_name =                      (TString)row->GetField(0);
743                  efile_name =                        (TString)row->GetField(1);
744                  epkt_number_in =    (unsigned long int)atoll(row->GetField(2));
745                  epkt_number_fin =   (unsigned long int)atoll(row->GetField(3));
746                  eobt_in =           (unsigned long int)atoll(row->GetField(4));
747                  eobt_fin =          (unsigned long int)atoll(row->GetField(5));
748                  emboot_num =        (unsigned long int)atoll(row->GetField(6));
749                  etime_offset =      (unsigned long int)atoll(row->GetField(7));
750                  ebad_pkt =                         (int)atoi(row->GetField(8));
751                  ebad_pkt_read =                    (int)atoi(row->GetField(9));
752                  ebad_pkt_CalRead =                (int)atoi(row->GetField(10));
753                  enum_PKT_Saved =                  (int)atoi(row->GetField(11));
754                  enome_input =                      (TString)row->GetField(12);
755                  e_time_is_estimated =            (bool)atoi(row->GetField(13));
756                };
757                delete result;
758    
759                setReal_TimeRECOVERY(
760                                     real_time_init,
761                                     real_time_last,
762                                     eobt_in,
763                                     eobt_fin
764                                     );
765                //
766              
767                if (saveROOT_DB(
768                                Table_ROOT_Good,
769                                efolder_name.Data(),
770                                efile_name.Data(),
771                                epkt_number_in,
772                                epkt_number_fin, eobt_in, eobt_fin, obt_time_sync, last_time_sync_info,
773                                real_time_init, real_time_last, emboot_num, etime_offset, ebad_pkt, ebad_pkt_read, ebad_pkt_CalRead,
774                                enum_PKT_Saved, enome_input.Data(), e_time_is_estimated) == true) {
775                  oss.str() = "";
776                  oss << "\nTAG(tassa): RECOVERED!!!! Saved information regarding file: " << efile_name << " in table " << Table_ROOT_Good << " id= " << my_id;
777                  msg = oss.str();
778                  mainLogUtil->logInfo(msg);
779                  /*merging we use global variable. we haveto set with current value*/
780                
781                  strcpy(outDir,efolder_name.Data() );
782                  //            outDir=efolder_name.Data();
783                  strcpy(filename,efile_name.Data() );
784                  //            filename=efile_name.Data();
785                  pkt_number_init=epkt_number_in;
786                  pkt_number_last=epkt_number_fin;
787                  obt_init=eobt_in;
788                  obt_last=eobt_fin;
789                  boot_number=emboot_num;
790                  timeOffset=etime_offset;
791                  bad_pkt=ebad_pkt;
792                  bad_pkt_EventReader=ebad_pkt_read;
793                  bad_pkt_CalibReader=ebad_pkt_CalRead;
794                  numPKTSaved=enum_PKT_Saved;
795                  strcpy(fni,enome_input.Data() );
796                  //            fni=enome_input.Data();
797                  time_is_estimated=e_time_is_estimated;
798                
799                  if (tryMerge) {
800                    merge_ROOTfiles();
801                  }
802                
803                  TString qu2 = Form("update ROOT_TABLE_BAD set ON_DISK='MVD' where ID_N=%i;",eid);
804                  sqlServer->Query(qu2.Data());
805    
806                
807                }
808                else {
809                  oss.str() = "";
810                  oss << "Problem storing information in DB regarding file: " << filename;
811                  msg = oss.str();
812                  mainLogUtil->logError(msg);
813                }
814              
815              
816              };
817              ez++;
818            }
819            //
820            idtorecover->Reset();
821            delete idtorecover;
822            idtorecover = new TArrayI(100);
823            arsize =  0;
824            //      delete app;
825          };
826        };
827        
828        CleanDisk();
829      if (!single_connection) {      if (!single_connection) {
830        CloseDBConnection();        CloseDBConnection();
831      }      }
832    
833    }//pRun    }//pRun
834  }  }
835      
836      
837      void PacketUser::CleanDisk(){
838        if ( !candelete ) return;
839        //
840        // delete small files present in root_table_bad from disk:
841        //
842        TString qu = Form("select FOLDER_NAME,FILE_NAME from ROOT_TABLE_BAD where NUM_PKT_SAVED<=%i and INSERTED_BY='%s' and ON_DISK='YES';",recoverlimit,tag_value);
843        TSQLResult *result = sqlServer->Query(qu.Data());
844        TSQLRow    *row = result->Next();
845        while ( row ){
846          TString tbdel = (TString)gSystem->ExpandPathName(row->GetField(0))+"/"+ (TString)row->GetField(1);
847          stringstream err;
848          string msg;
849          err.str() = "";      
850          err << " Deleting file " << tbdel.Data() << " from disk! ";
851          msg = err.str();
852          mainLogUtil->logInfo(msg);
853          gSystem->Unlink(tbdel.Data());
854          //      printf("ciccio %s  \n",tbdel.Data());
855          TString q2u = Form("UPDATE ROOT_TABLE_BAD set ON_DISK='NO' where FOLDER_NAME='%s' and FILE_NAME='%s' and NUM_PKT_SAVED<=%i and INSERTED_BY='%s';",row->GetField(0),row->GetField(1),recoverlimit,tag_value);
856          //      printf("pluto %s \n",q2u.Data());
857          sqlServer->Query(q2u.Data());
858          //      printf("paperoga \n");
859          row=result->Next();
860          //
861        };
862        
863      }
864    
865  //save in Table_ROOT_Good or in Table_ROOT_Bad  //save in Table_ROOT_Good or in Table_ROOT_Bad
866  bool PacketUser::saveROOT_DB(const char* table_name, char* folder_name, char* file_name,  bool PacketUser::saveROOT_DB(const char* table_name, const char* folder_name, const char* file_name,
867      unsigned long int pkt_number_in, unsigned long int pkt_number_fin, unsigned long int obt_in,      unsigned long int pkt_number_in, unsigned long int pkt_number_fin, unsigned long int obt_in,
868      unsigned long int obt_fin, unsigned long int oT_sync, unsigned long int lT_sync_info, unsigned long int mtime_init,      unsigned long int obt_fin, unsigned long int oT_sync, unsigned long int lT_sync_info, unsigned long int mtime_init,
869      unsigned long int mtime_last, unsigned long int mboot_num, unsigned long int time_offset, int bad_pkt,      unsigned long int mtime_last, unsigned long int mboot_num, unsigned long int time_offset, int bad_pkt,
870      int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved, char* nome_input, bool _time_is_estimated) {      int bad_pkt_read, int bad_pkt_CalRead, int num_PKT_Saved, const char* nome_input, bool _time_is_estimated) {
871    //TODO: forse far ritornare ID della cosa appena inserita se e' andatato tutto ok invece che true false?    //TODO: forse far ritornare ID della cosa appena inserita se e' andatato tutto ok invece che true false?
872    stringstream oss;    stringstream oss;
873    oss.str("");    oss.str("");
874    oss << "INSERT INTO " << table_name    oss << "INSERT INTO " << table_name
875        << " (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)"        << " (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,INSERTED_BY)"
876        << " VALUES ('" << 0 << "','" << folder_name << "','" << file_name << "','" << pkt_number_in << "','"        << " VALUES ('" << 0 << "','" << folder_name << "','" << file_name << "','" << pkt_number_in << "','"
877        << pkt_number_fin << "','" << obt_in << "','" << obt_fin << "','" << oT_sync << "','" << lT_sync_info << "','"        << pkt_number_fin << "','" << obt_in << "','" << obt_fin << "','" << oT_sync << "','" << lT_sync_info << "','"
878        << mtime_init << "','" << mtime_last << "','" << mboot_num << "','" << time_offset << "','" << bad_pkt << "','"        << mtime_init << "','" << mtime_last << "','" << mboot_num << "','" << time_offset << "','" << bad_pkt << "','"
879        << bad_pkt_read << "','" << bad_pkt_CalRead << "','" << num_PKT_Saved << "','" << nome_input << "'," << "NULL,"        << bad_pkt_read << "','" << bad_pkt_CalRead << "','" << num_PKT_Saved << "','" << nome_input << "'," << "NULL,"
880        << _time_is_estimated << ");";        << _time_is_estimated << ",'" << tag_value << "'" << ");";
881    string msg = oss.str();    string msg = oss.str();
882    mainLogUtil->logAll(msg);    mainLogUtil->logAll(msg);
883    
# Line 646  bool PacketUser::saveROOT_DB(const char* Line 901  bool PacketUser::saveROOT_DB(const char*
901      return false;      return false;
902    }    }
903    
904    //the ID of the current ROOT file in table Table_ROOT_Good  
905    my_id = select_maxIDN_DB(table_name);    if(!strcmp(table_name,Table_ROOT_Good)) {
906    if (!boot_number) {      //the ID of the current ROOT file in table Table_ROOT_Good
907      if (id_to_recover_index < 1000)      my_id = select_maxIDN_DB(table_name);
908        id_to_recover[id_to_recover_index++] = my_id;      if (!boot_number) {
909    }        if (id_to_recover_index < 1000)
910    else if (boot_number && id_to_recover_index && !is_new_route) {          id_to_recover[id_to_recover_index++] = my_id;
911      recover_boot_number();      }
912        else if (boot_number && id_to_recover_index && !is_new_route) {
913          recover_boot_number();
914        }
915    }    }
916    //    cout<<"DBG: my_id = "<<my_id<<endl;    //    cout<<"DBG: my_id = "<<my_id<<endl;
917    if (res) {    if (res) {
# Line 912  bool PacketUser::updateMergeROOT_DB(cons Line 1170  bool PacketUser::updateMergeROOT_DB(cons
1170    if (type_rel == AFTER) {    if (type_rel == AFTER) {
1171      mainLogUtil->logInfo("Relaz:AFTER = Updating Last values of the DB ROOT file");      mainLogUtil->logInfo("Relaz:AFTER = Updating Last values of the DB ROOT file");
1172      //marco_new:tolti tutti gli apici che qui non devono essere      //marco_new:tolti tutti gli apici che qui non devono essere
1173        
1174        int good = 1;
1175        if ( pkt_number_in >= (pkt_number_init - 1) && abs((int)(pkt_number_in-(pkt_number_init-1)))<10 ) good = 0;
1176        
1177      oss << "UPDATE " << table_name << " SET PKT_NUMBER_FINAL =" << (pkt_number_init - 1) << ", PKT_OBT_FINAL ="      oss << "UPDATE " << table_name << " SET PKT_NUMBER_FINAL =" << (pkt_number_init - 1) << ", PKT_OBT_FINAL ="
1178          << obt_init << ", REAL_TIME_LAST =" << real_time_init << " WHERE ID_N =" << ID_record << ";";          << obt_init << ", REAL_TIME_LAST =" << real_time_init << ", GOOD="<< good << " WHERE ID_N =" << ID_record << ";";
1179    
1180    }    }
1181    else if (type_rel == BEFORE) {    else if (type_rel == BEFORE) {
1182      mainLogUtil->logInfo("Relaz:BEFORE = Updating Init values of the DB ROOT file");      mainLogUtil->logInfo("Relaz:BEFORE = Updating Init values of the DB ROOT file");
1183    
1184        int good = 1;
1185        if ( (pkt_number_last+1) >= pkt_number_fin && abs((int)((pkt_number_last+1)-pkt_number_fin))<10 ) good = 0;
1186        
1187      oss << "UPDATE " << table_name << " SET PKT_NUMBER_INIT =" << (pkt_number_last + 1) << ", PKT_OBT_INIT ="      oss << "UPDATE " << table_name << " SET PKT_NUMBER_INIT =" << (pkt_number_last + 1) << ", PKT_OBT_INIT ="
1188          << obt_last << ", REAL_TIME_INIT =" << real_time_last << " WHERE ID_N =" << ID_record << ";";          << obt_last << ", REAL_TIME_INIT =" << real_time_last << ", GOOD="<< good << " WHERE ID_N =" << ID_record << ";";
1189    }    }
1190    else if (type_rel == SMALLER) {    else if (type_rel == SMALLER) {
1191      //spezzettamentento      //spezzettamentento
1192      mainLogUtil->logInfo("Relaz:SMALLER = (1st part) Updating Last values of the DB ROOT file");      mainLogUtil->logInfo("Relaz:SMALLER = (1st part) Updating Last values of the DB ROOT file");
1193    
1194        int good = 1;
1195        if ( pkt_number_in >= (pkt_number_init - 1) && abs((int)(pkt_number_in-(pkt_number_init-1)))<10 ) good = 0;
1196    
1197      oss << "UPDATE " << table_name << " SET PKT_NUMBER_FINAL=" << (pkt_number_init - 1) << ", PKT_OBT_FINAL ="      oss << "UPDATE " << table_name << " SET PKT_NUMBER_FINAL=" << (pkt_number_init - 1) << ", PKT_OBT_FINAL ="
1198          << obt_init << ", REAL_TIME_LAST =" << real_time_init << " WHERE ID_N =" << ID_record << ";";          << obt_init << ", REAL_TIME_LAST =" << real_time_init << ", GOOD="<< good << " WHERE ID_N =" << ID_record << ";";
1199    
1200      mainLogUtil->logInfo("Relaz:SMALLER = (2nd part) Saving the second part of the DB ROOT file");      mainLogUtil->logInfo("Relaz:SMALLER = (2nd part) Saving the second part of the DB ROOT file");
1201    
# Line 989  TSQLResult* PacketUser::Select_merging(c Line 1258  TSQLResult* PacketUser::Select_merging(c
1258    else    else
1259      return 0;      return 0;
1260    
1261    query << " order by REAL_TIME_INIT ASC";//marco_new: inutile    query << " order by REAL_TIME_INIT ASC;";//marco_new: inutile
1262    //se volessi mettere un filtro sulla qualita'    //se volessi mettere un filtro sulla qualita'
1263    //    query<<" and NUM_PKT_SAVED - BAD_PKT_CALREAD - BAD_PKT_READ - BAD_PKT >= 2" ;    //    query<<" and NUM_PKT_SAVED - BAD_PKT_CALREAD - BAD_PKT_READ - BAD_PKT >= 2" ;
1264    string msg = query.str();    string msg = query.str();
# Line 1012  bool PacketUser::saveMergeROOT_DB(const Line 1281  bool PacketUser::saveMergeROOT_DB(const
1281      unsigned long int pkt_number_fin, unsigned long int obt_in, unsigned long int obt_fin,      unsigned long int pkt_number_fin, unsigned long int obt_in, unsigned long int obt_fin,
1282      unsigned long int mtime_init, unsigned long int mtime_last, unsigned long int mboot_num, double percentage) {      unsigned long int mtime_init, unsigned long int mtime_last, unsigned long int mboot_num, double percentage) {
1283    
1284      int good = 1;
1285      if ( pkt_number_in >= pkt_number_fin && abs((int)(pkt_number_fin-pkt_number_in))<10 ) good = 0;
1286    
1287    stringstream oss;    stringstream oss;
1288    oss.str("");    oss.str("");
1289    oss << "INSERT INTO " << table_name    oss << "INSERT INTO " << table_name
1290        << " (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)"        << " (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,GOOD)"
1291        << " VALUES ('" << 0 << "','" << root_id << "','" << pkt_number_in << "','" << pkt_number_fin << "','" << obt_in        << " VALUES ('" << 0 << "','" << root_id << "','" << pkt_number_in << "','" << pkt_number_fin << "','" << obt_in
1292        << "','" << obt_fin << "','" << mtime_init << "','" << mtime_last << "','" << mboot_num << "','" << percentage        << "','" << obt_fin << "','" << mtime_init << "','" << mtime_last << "','" << mboot_num << "','" << percentage
1293        << "'," << "NULL" << ",'" << tag_value << "'" << ")";        << "'," << "NULL" << ",'" << tag_value << "','" << good <<"');";
1294    
1295    string msg = oss.str();    string msg = oss.str();
1296    mainLogUtil->logAll(msg);    mainLogUtil->logAll(msg);
# Line 1116  int PacketUser::LockTables(const char* t Line 1388  int PacketUser::LockTables(const char* t
1388    TSQLResult* res = NULL;    TSQLResult* res = NULL;
1389    stringstream oss;    stringstream oss;
1390    oss.str("");    oss.str("");
1391    if (!tableTobeLocked)    //  if (!tableTobeLocked)
1392      oss << "lock table " << Table_ROOT_Good << " write, " << Table_ROOT_Bad << " write, " << Table_GL_RESURS_OFFSET    oss << "lock table " << Table_ROOT_Good << " write, " << Table_ROOT_Bad << " write, " << Table_GL_RESURS_OFFSET
1393          << " write, " << Table_ROOT_Merging << " write;";        << " write, " << Table_ROOT_Merging << " write;";
1394    else      //  else
1395      oss << "lock table " << tableTobeLocked << " write; ";      //    oss << "lock table " << tableTobeLocked << " write; ";
1396    
1397    string msg = oss.str();    string msg = oss.str();
1398    mainLogUtil->logAll(msg);    mainLogUtil->logAll(msg);
# Line 1190  void PacketUser::OpenDBConnection(const Line 1462  void PacketUser::OpenDBConnection(const
1462    if (do_cont_check) {    if (do_cont_check) {
1463      //controllo che non sia gia' aperta      //controllo che non sia gia' aperta
1464      if (!sqlServer) {      if (!sqlServer) {
1465        sqlServer = TSQLServer::Connect(connection, db_user, db_pwd);        sqlServer = TSQLServer::Connect(pelosconnection, db_user, db_pwd);
1466        if ((!sqlServer) || (!(sqlServer->IsConnected()))) {        if ((!sqlServer) || (!(sqlServer->IsConnected()))) {
1467          cout << "Can not connect with MYSQL sever" << endl;          cout << "Can not connect with MYSQL sever" << endl;
1468        }        }
Legend:
Removed from v.1.9  
changed lines
  Added in v.1.17
  ViewVC Help
Powered by ViewVC 1.1.23