From: zampolli <zampolli@f7af4fe6-9843-0410-8265-dc069ae4e863>
Date: Fri, 12 Sep 2008 14:59:17 +0000 (+0000)
Subject: Added function to update FXS logbooks' time_processed field
X-Git-Url: http://git.uio.no/git/?p=u%2Fmrichter%2FAliRoot.git;a=commitdiff_plain;h=bd23d48b18127925e1b3c49fb8a52fb97a283603

Added function to update FXS logbooks' time_processed field
when a run is skipped.
---

diff --git a/SHUTTLE/AliShuttle.cxx b/SHUTTLE/AliShuttle.cxx
index 338ff79719f..d2976058491 100644
--- a/SHUTTLE/AliShuttle.cxx
+++ b/SHUTTLE/AliShuttle.cxx
@@ -1638,6 +1638,10 @@ Int_t AliShuttle::ProcessCurrentDetector()
 	{
 		UpdateShuttleStatus(AliShuttleStatus::kSkipped);
 		UpdateShuttleLogbook(fCurrentDetector, "DONE");
+		if (!UpdateTableSkippedCase(fCurrentDetector.Data()))
+		{
+			AliError(Form("Could not update FXS tables for run %d !", GetCurrentRun()));
+		}
 		Log(fCurrentDetector, Form("ProcessCurrentDetector - %s preprocessor is not interested in this run type", fCurrentDetector.Data()));
 	
 		return 2;
@@ -2006,6 +2010,10 @@ AliShuttleLogbookEntry* AliShuttle::QueryRunParameters(Int_t run)
 		{
 			AliError(Form("Could not update logbook for run %d !", run));
 		}
+		if (!UpdateTableSkippedCase("ALL"))
+		{
+			AliError(Form("Could not update FXS tables for run %d !", run));
+		}
 		fLogbookEntry = 0;
 	}
 			
@@ -2599,6 +2607,59 @@ Bool_t AliShuttle::UpdateTable()
 	return result;
 }
 
+//_______________________________________________________________________________
+Bool_t AliShuttle::UpdateTableSkippedCase(const char* detector)
+{
+	//
+	// Update FXS table filling time_processed field in all rows corresponding to current run and detector
+	// if detector = "ALL" update all detectors
+	//
+
+	Bool_t result = kTRUE;
+
+	for (UInt_t system=0; system<3; system++)
+	{
+
+		// check connection, in case connect
+		if (!Connect(system))
+		{
+			Log(fCurrentDetector, Form("UpdateTableSkippedCase - Couldn't connect to %s FXS database", GetSystemName(system)));
+			result = kFALSE;
+			continue;
+		}
+
+		TTimeStamp now; // now
+
+		// Loop on FXS list entries
+		TIter iter(&fFXSlist[system]);
+			
+		TString whereClause;
+		if (detector == "ALL") whereClause = Form("where run=%d and time_processed IS NULL;",GetCurrentRun());
+		else whereClause = Form("where run=%d and detector=\"%s\" and time_processed IS NULL;",GetCurrentRun(), detector);
+
+		Log("SHUTTLE",Form(" whereClause = %s ",whereClause.Data()));
+
+		TString sqlQuery = Form("update %s set time_processed=%d %s", fConfig->GetFXSdbTable(system),
+					now.GetSec(), whereClause.Data());
+
+		AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
+
+		// Query execution
+		TSQLResult* aResult;
+		aResult = dynamic_cast<TSQLResult*> (fServer[system]->Query(sqlQuery));
+		if (!aResult)
+		{
+			Log("SHUTTLE", Form("UpdateTableSkippedCase - %s db: can't execute SQL query <%s>",
+							GetSystemName(system), sqlQuery.Data()));
+			result = kFALSE;
+			continue;
+		}
+		delete aResult;
+		
+	}
+
+	return result;
+}
 //______________________________________________________________________________________________
 Bool_t AliShuttle::UpdateTableFailCase()
 {
diff --git a/SHUTTLE/AliShuttle.h b/SHUTTLE/AliShuttle.h
index 1f91b4f9b56..a32de38414c 100644
--- a/SHUTTLE/AliShuttle.h
+++ b/SHUTTLE/AliShuttle.h
@@ -104,6 +104,7 @@ private:
 	Bool_t RetrieveFile(UInt_t system, const char* daqFileName, const char* localFileName);
 
 	Bool_t UpdateTable();
+	Bool_t UpdateTableSkippedCase(const char* detector="ALL");
 	Bool_t UpdateTableFailCase();
 
 	Bool_t StoreLocally(const TString& localUri, const AliCDBPath& path, TObject* object,