--- chewbacca/YodaProfiler/src/PamelaDBOperations.cpp	2009/01/12 18:23:37	1.21
+++ chewbacca/YodaProfiler/src/PamelaDBOperations.cpp	2009/01/13 13:38:15	1.23
@@ -185,7 +185,7 @@
 	  if ( !chboot ){
 	    qu.str("");
 	    //	    qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<10000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<7200 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; 
-	    qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<20000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<40000 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; // relax conditions... 090112 [8RED: error -29]
+	    qu << "SELECT BOOT_NUMBER from ROOT_TABLE where BOOT_NUMBER!=0 AND ABS(LAST_TIME_SYNC_INFO-"<< chlastts <<")<40000 AND ABS(REAL_TIME_INIT-"<< row2->GetField(10) <<")<40000 group by BOOT_NUMBER order by BOOT_NUMBER asc;"; // relax conditions... 090112 [8RED: error -29]
 	    if ( debug ) printf(" chewbacca: query is %s \n",qu.str().c_str());
 	    result3 = conn->Query(qu.str().c_str());
 	    if ( result3 ){
@@ -1504,6 +1504,14 @@
     glrun->SetRUNTRAILER_PKT(lastPkt);
     //    
   };
+  //
+  // ad hoc solution for INF EV_TO [8RED] 090113
+  //
+  if ( !firstev && lastev == -1 ){
+    if ( IsDebug() ) printf(" EE firstev %i lastev %i nevents %i \n",firstev,lastev,lastev-firstev+1);
+    firstev = 1;
+    lastev = 0;
+  };
   glrun->SetEV_FROM((UInt_t)firstev);
   glrun->SetEV_TO((UInt_t)lastev);
   glrun->SetNEVENTS((UInt_t)lastev-(UInt_t)firstev+1);
@@ -3363,6 +3371,7 @@
 	  glrun->SetID_RUN_FRAG(IDRL2B);
 	  glrun->Fill_GL_RUN(conn);	
 	  glrun->DeleteRun(conn,0,"GL_RUN_FRAGMENTS");
+	  delete glA;
 	  //
 	} else {
 	  //
@@ -6121,7 +6130,7 @@
 	      row2 = result2->Next();
 	      //
 	      if ( row2 ){
-		if ( IsDebug() ) printf(" The already exist in the GL_RUN table! \n");
+		if ( IsDebug() ) printf(" The run already exists in the GL_RUN table! \n");
 		if ( PEDANTIC ) throw -83;
 		row2->Close();
 	      };
@@ -6198,7 +6207,7 @@
       glrun->Query_GL_RUN_FRAGMENTS(oss.str().c_str(),conn);   
       //
       oss.str("");
-      oss << " SELECT ID,NEVENTS,TRK_CALIB_USED,PKT_COUNTER FROM GL_RUN WHERE "
+      oss << " SELECT ID,NEVENTS,TRK_CALIB_USED,PKT_COUNTER,ID_ROOT_L0 FROM GL_RUN WHERE "
 	  << " BOOT_NUMBER=" << glrun->GetBOOT_NUMBER() << " AND ("
 	  << " (RUNHEADER_TIME>=" << (UInt_t)(glrun->GetRUNHEADER_TIME()-10) << " AND "
 	  << " RUNTRAILER_TIME<=" << (UInt_t)(glrun->GetRUNTRAILER_TIME()+10) << " AND ("
@@ -6256,8 +6265,199 @@
 	moved++;
 	//
       } else {
-	if ( IsDebug() ) printf(" The already exist in the GL_RUN table! \n");
-	if ( PEDANTIC ) throw -83;
+
+	// questa parte mah mah mah... da controllare
+
+	//
+	// we end up here if chewbacca and we have RH---| small gap |---RT, in this case the two pieces are attached and moved to GL_RUN. We are now processing the 
+	// "small gap" piece... we recognize this since: we have two entries from this query, the pkt number is consistent with our pkt number.
+	//
+	// 090112 [8RED (-70): RUN ALREADY INSERTED]
+	//
+	Bool_t OK = false;
+	UInt_t IDRL2A = 0;
+	UInt_t IDRL2B = 0;
+	  if ( result2->GetRowCount() == 2 ){
+	    IDRL2A = (UInt_t)atoll(row2->GetField(0));
+	    UInt_t IDRL0A = (UInt_t)atoll(row2->GetField(4));
+	    row2 = result2->Next();
+	    IDRL2B = (UInt_t)atoll(row2->GetField(0));
+	    UInt_t IDRL0B = (UInt_t)atoll(row2->GetField(4));
+	    if ( IsDebug() ) printf(" IDRL0A %u B %u IDRL2A %u B %u \n",IDRL0A,IDRL0B,IDRL2A,IDRL2B);
+	    //	    if ( IDRL0A == IDRL0B ){
+// 	      TSQLResult *result2a = 0;
+// 	      TSQLRow    *row2a    = 0;
+// 	      oss.str("");
+// 	      oss << "select PKT_NUMBER_FINAL from ROOT_TABLE_MERGING where REAL_TIME_INIT<" << chrtinit << " order by REAL_TIME_INIT desc limit 1;";
+// 	      if ( IsDebug() ) printf(" Check if we are in the case RH---| small gap |---RT: query is \n %s \n",oss.str().c_str());
+// 	      result2a = conn->Query(oss.str().c_str());
+// 	      //
+// 	      if ( !result2a ) throw -4;
+// 	      //
+// 	      row2a = result2a->Next();
+// 	      //
+// 	      if ( row2a ){
+// 		UInt_t PKA = (UInt_t)atoll(row2a->GetField(0));
+// 		delete result2a;
+// 		oss.str("");
+// 		oss << "select PKT_NUMBER_INIT from ROOT_TABLE_MERGING where REAL_TIME_INIT>" << chrtinit << " order by REAL_TIME_INIT asc limit 1;";
+// 		if ( IsDebug() ) printf(" Check if we are in the case RH---| small gap |---RT: query is \n %s \n",oss.str().c_str());
+// 		result2a = conn->Query(oss.str().c_str());
+// 		//
+// 		if ( !result2a ) throw -4;
+// 		//
+// 		row2a = result2a->Next();
+// 		//
+// 		if ( row2a ){
+// 		  UInt_t PKB = (UInt_t)atoll(row2a->GetField(0));
+// 		  //
+// 		  if ( IsDebug() ) printf(" PKT(PKA) + 1 %llu == runheaderpkt %llu && PKB = runtrailer %llu + 1 %llu \n",PKT(PKA)+1LL, PKT(glrun->GetRUNHEADER_PKT()),PKT(PKB), PKT(glrun->GetRUNTRAILER_PKT())+1LL);
+// 		  if ( PKT(PKA)+1LL == PKT(glrun->GetRUNHEADER_PKT()) && PKT(PKB) == PKT(glrun->GetRUNTRAILER_PKT())+1LL ){
+// 		    if ( IsDebug() ) printf(" Ok, we are in the case: RH---| small gap |---RT \n");
+		    OK = true;
+		    //		  };
+		    //		};
+		    //	      };		  
+		    //	  };
+	  };	  
+	if ( OK ){
+	  //
+	  // this is the case in which we must insert a piece of run between two fragments in the GL_RUN table
+	  //
+	  // we have to update with runheader/trailer infos our run and we have to change the ROOT_ID_FRAG of the header piece ( 1/2 2/1 must become 1/3 3/2 2/1 )
+	  //
+	  GL_RUN *glA = new GL_RUN();
+	  glA->Query_GL_RUN(IDRL2A,conn);
+	  //
+	  if ( glA->GetACQ_BUILD_INFO() != 0 ){
+	    //
+	    // the first piece contains a good runheader we can update all the other runs with correct infos!
+	    //
+	    oss.str("");
+	    oss << "UPDATE GL_RUN_FRAGMENTS SET "
+		<< " RUNHEADER_TIME=" << glA->GetRUNHEADER_TIME()<< " , "
+		<< " RUNHEADER_OBT=" << glA->GetRUNHEADER_OBT()<< " , "
+		<< " RUNHEADER_PKT=" << glA->GetRUNHEADER_PKT()<< " , "
+		<< " COMPILATIONTIMESTAMP=" << glA->GetCOMPILATIONTIMESTAMP()<< " , "
+		<< " FAV_WRK_SCHEDULE=" << glA->GetFAV_WRK_SCHEDULE()<< " , "
+		<< " EFF_WRK_SCHEDULE=" << glA->GetEFF_WRK_SCHEDULE()<< " , "
+		<< " PRH_VAR_TRG_MODE_A=" << glA->GetPRH_VAR_TRG_MODE_A()<< " , "
+		<< " PRH_VAR_TRG_MODE_B=" << glA->GetPRH_VAR_TRG_MODE_B()<< " , "
+		<< " ACQ_BUILD_INFO=" << glA->GetACQ_BUILD_INFO()<< " , "
+		<< " ACQ_VAR_INFO=" << glA->GetACQ_VAR_INFO()<< " , "
+		<< " RM_ACQ_AFTER_CALIB=" << glA->GetRM_ACQ_AFTER_CALIB()<< " , "  
+		<< " RM_ACQ_SETTING_MODE=" << glA->GetRM_ACQ_SETTING_MODE()<< " , "  
+		<< " TRK_CALIB_USED=" << glA->GetTRK_CALIB_USED()<< " , "  
+		<< " CAL_DSP_MASK=" << glA->GetCAL_DSP_MASK()<< " , "  
+		<< " LAST_TIMESYNC=" << glA->GetLAST_TIMESYNC()<< " , ";
+	    //
+	    if ( glA->GetPHYSENDRUN_MASK_S3S2S12() )
+	      oss << " PHYSENDRUN_MASK_S3S2S12=" << glA->GetPHYSENDRUN_MASK_S3S2S12() << " , "; 
+	    if ( glA->GetPHYSENDRUN_MASK_S11CRC() )
+	      oss << " PHYSENDRUN_MASK_S11CRC=" << glA->GetPHYSENDRUN_MASK_S11CRC() << " , ";
+	    //	      
+	    oss << " OBT_TIMESYNC=" << glA->GetOBT_TIMESYNC();
+	    oss << " WHERE ID=" << glrun->GetID() << ";";
+	    if ( IsDebug() ) printf(" update with correct infos: %s\n",oss.str().c_str());
+	    conn->Query(oss.str().c_str());	
+	    //
+	  } else {
+	    //
+	    // sig no runheader, let set anyway what is possible...
+	    //
+	    oss.str("");
+	    oss << "UPDATE GL_RUN_FRAGMENTS SET "
+		<< " RUNHEADER_TIME=" << glA->GetRUNHEADER_TIME()<< " , ";
+	    //
+	    if ( glA->GetPHYSENDRUN_MASK_S3S2S12() )
+	      oss << " PHYSENDRUN_MASK_S3S2S12=" << glA->GetPHYSENDRUN_MASK_S3S2S12()<< " , ";
+	    if ( glA->GetPHYSENDRUN_MASK_S11CRC() )
+	      oss << " PHYSENDRUN_MASK_S11CRC=" << glA->GetPHYSENDRUN_MASK_S11CRC()<< " , "; 
+	    //	      
+	    oss << " RUNHEADER_OBT=" << glA->GetRUNHEADER_OBT()<< " , "
+		<< " RUNHEADER_PKT=" << glA->GetRUNHEADER_PKT();
+	    oss << " WHERE ID=" << glrun->GetID() << ";";
+	    if ( IsDebug() ) printf(" update with correct infos2: %s\n",oss.str().c_str());
+	    conn->Query(oss.str().c_str());	
+	  };
+	  //
+	  // update runheader ROOT_ID_FRAG
+	  //
+	  oss.str("");
+	  oss << "UPDATE GL_RUN SET ID_RUN_FRAG = " << glrun->GetID() << " where ID = " << IDRL2A << ";";
+	  if ( IsDebug() ) printf(" update gl_run to have cross indexing: %s\n",oss.str().c_str());
+	  conn->Query(oss.str().c_str());
+	  //
+	  // now let's look for runtrailer if any in the last run
+	  //
+	  glA->Query_GL_RUN(IDRL2B,conn);
+	  //
+	  if ( glA->GetPKT_READY_COUNTER() != 0 ){
+	    //
+	    // the first piece contains a good runtrailer we can update all the other runs with correct infos!
+	    //
+	    oss.str("");
+	    oss << "UPDATE GL_RUN_FRAGMENTS SET "
+		<< " RUNTRAILER_TIME=" << glA->GetRUNTRAILER_TIME()<< " , "
+		<< " RUNTRAILER_OBT=" << glA->GetRUNTRAILER_OBT()<< " , "
+		<< " RUNTRAILER_PKT=" << glA->GetRUNTRAILER_PKT()<< " , "
+		<< " PKT_COUNTER=" << glA->GetPKT_COUNTER()<< " , ";
+	    //
+	    if ( glA->GetPHYSENDRUN_MASK_S3S2S12() ){
+	      oss << " PHYSENDRUN_MASK_S3S2S12=" << glA->GetPHYSENDRUN_MASK_S3S2S12()<< " , "; };
+	    if ( glA->GetPHYSENDRUN_MASK_S11CRC() ) {
+	      oss << " PHYSENDRUN_MASK_S11CRC=" << glA->GetPHYSENDRUN_MASK_S11CRC()<< " , "; };
+	    //	      
+	    oss << " PKT_READY_COUNTER=" << glA->GetPKT_READY_COUNTER()
+		<< " WHERE ID=" << glrun->GetID() << ";";
+	    if ( IsDebug() ) printf(" update with correct trailer infos: %s\n",oss.str().c_str());
+	    conn->Query(oss.str().c_str());	
+	    //
+	  } else {
+	    //
+	    // sig no runtrailer, let set anyway what is possible...
+	    //
+	    oss.str("");
+	    oss << "UPDATE GL_RUN_FRAGMENTS SET "
+		<< " RUNTRAILER_TIME=" << glA->GetRUNTRAILER_TIME()<< " , "
+		<< " RUNTRAILER_OBT=" << glA->GetRUNTRAILER_OBT()<< " , ";
+	      //
+	    if ( glA->GetPHYSENDRUN_MASK_S3S2S12() ){
+	      oss << " PHYSENDRUN_MASK_S3S2S12=" << glA->GetPHYSENDRUN_MASK_S3S2S12()<< " , "; };
+	    if ( glA->GetPHYSENDRUN_MASK_S11CRC() ){
+	      oss << " PHYSENDRUN_MASK_S11CRC=" << glA->GetPHYSENDRUN_MASK_S11CRC()<< " , "; };
+	    //	      
+	    oss << " RUNTRAILER_PKT=" << glrun->GetRUNTRAILER_PKT()
+		<< " WHERE ID=" << glrun->GetID() << ";";
+	    if ( IsDebug() ) printf(" update with correct trailer infos2: %s\n",oss.str().c_str());
+	    conn->Query(oss.str().c_str());	
+	  };
+	  //
+	  UInt_t myi = glrun->GetID();
+	  oss.str("");
+	  oss << " ID= "<< myi;
+	  //
+	  glrun->Query_GL_RUN_FRAGMENTS(oss.str().c_str(),conn);   
+	  //
+	  // fill the new run in GL_RUN
+	  //
+	  glrun->SetID_RUN_FRAG(IDRL2B);
+	  glrun->Fill_GL_RUN(conn);	
+	  glrun->DeleteRun(conn,0,"GL_RUN_FRAGMENTS");
+	  delete glA;
+	  moved++;
+	  //
+	} else {
+	  //
+	  // is just a repetition
+	  //
+	  if ( IsDebug() ) printf(" The run %u is already present in the GL_RUN table...\n",glrun->GetID());	
+	  //	  printf(" CCCCCCCCICCCCCCCCCCCCIOOOOOOOOOO si muove Ciccio! %u \n",glrun->GetID());
+	  //	  if ( PEDANTIC && glrun->GetID() != 61563 ) throw -83; 
+	  if ( PEDANTIC ) throw -83; 
+	};
+	//	if ( IsDebug() ) printf(" The run already exists in the GL_RUN table! ...\n");
+	//	if ( PEDANTIC ) throw -83;
       };
       if ( IsDebug() ) printf(" Delete run %s from the GL_RUN_FRAGMENTS table \n",row->GetField(0));      
       //