/*
$Log$
+Revision 1.30 2007/02/13 11:23:21 acolla
+Moved getters and setters of Shuttle's main OCDB/Reference, local
+OCDB/Reference, temp and log folders to AliShuttleInterface
+
+Revision 1.27 2007/01/30 17:52:42 jgrosseo
+adding monalisa monitoring
+
+Revision 1.26 2007/01/23 19:20:03 acolla
+Removed old ldif files, added TOF, MCH ldif files. Added some options in
+AliShuttleConfig::Print. Added in Ali Shuttle: SetShuttleTempDir and
+SetShuttleLogDir
+
+Revision 1.25 2007/01/15 19:13:52 acolla
+Moved some AliInfo to AliDebug in SendMail function
+
+Revision 1.21 2006/12/07 08:51:26 jgrosseo
+update (alberto):
+table, db names in ldap configuration
+added GRP preprocessor
+DCS data can also be retrieved by data point
+
+Revision 1.20 2006/11/16 16:16:48 jgrosseo
+introducing strict run ordering flag
+removed giving preprocessor name to preprocessor, they have to know their name themselves ;-)
+
+Revision 1.19 2006/11/06 14:23:04 jgrosseo
+major update (Alberto)
+o) reading of run parameters from the logbook
+o) online offline naming conversion
+o) standalone DCSclient package
+
+Revision 1.18 2006/10/20 15:22:59 jgrosseo
+o) Adding time out to the execution of the preprocessors: The Shuttle forks and the parent process monitors the child
+o) Merging Collect, CollectAll, CollectNew function
+o) Removing implementation of empty copy constructors (declaration still there!)
+
+Revision 1.17 2006/10/05 16:20:55 jgrosseo
+adapting to new CDB classes
+
+Revision 1.16 2006/10/05 15:46:26 jgrosseo
+applying to the new interface
+
+Revision 1.15 2006/10/02 16:38:39 jgrosseo
+update (alberto):
+fixed memory leaks
+storing of objects that failed to be stored to the grid before
+interfacing of shuttle status table in daq system
+
Revision 1.14 2006/08/29 09:16:05 jgrosseo
small update
#include "AliCDBPath.h"
#include "AliCDBEntry.h"
#include "AliShuttleConfig.h"
-#include "AliDCSClient.h"
+#include "DCSClient/AliDCSClient.h"
#include "AliLog.h"
#include "AliPreprocessor.h"
#include "AliShuttleStatus.h"
#include <TSQLServer.h>
#include <TSQLResult.h>
#include <TSQLRow.h>
+#include <TMutex.h>
-#include <fstream>
-
-ClassImp(AliShuttle)
-
-TString AliShuttle::fgkMainCDB("alien://folder=ShuttleCDB");
-TString AliShuttle::fgkLocalCDB("local://LocalShuttleCDB");
-TString AliShuttle::fgkMainRefStorage("alien://folder=ShuttleReference");
-TString AliShuttle::fgkLocalRefStorage("local://LocalReferenceStorage");
-
-Bool_t AliShuttle::fgkProcessDCS(kTRUE);
+#include <TMonaLisaWriter.h>
+#include <fstream>
-const char* AliShuttle::fgkShuttleTempDir = gSystem->ExpandPathName("$ALICE_ROOT/SHUTTLE/temp");
-const char* AliShuttle::fgkShuttleLogDir = gSystem->ExpandPathName("$ALICE_ROOT/SHUTTLE/log");
+#include <sys/types.h>
+#include <sys/wait.h>
-const char* AliShuttle::fgkDetectorName[AliShuttle::kNDetectors] = {"SPD", "SDD", "SSD", "TPC", "TRD", "TOF",
- "PHOS", "CPV", "RICH", "EMCAL", "MUON_TRK", "MUON_TRG", "FMD", "ZDC", "PMD", "START", "VZERO"};
+ClassImp(AliShuttle)
-const char* AliShuttle::fgkDetectorCode[AliShuttle::kNDetectors] = {"SPD", "SDD", "SSD", "TPC", "TRD", "TOF",
- "PHS", "CPV", "HMP", "EMC", "MCH", "MTR", "FMD", "ZDC", "PMD", "T00", "V00"};
+Bool_t AliShuttle::fgkProcessDCS(kTRUE);
//______________________________________________________________________________________________
AliShuttle::AliShuttle(const AliShuttleConfig* config,
fTimeout(timeout), fRetries(retries),
fPreprocessorMap(),
fLogbookEntry(0),
-fCurrentDetector(""),
+fCurrentDetector(),
fStatusEntry(0),
-fGridError(kFALSE)
+fGridError(kFALSE),
+fMonitoringMutex(0),
+fLastActionTime(0),
+fLastAction(),
+fMonaLisa(0)
{
//
// config: AliShuttleConfig used
//
if (!fConfig->IsValid()) AliFatal("********** !!!!! Invalid configuration !!!!! **********");
- for(int iSys=0;iSys<3;iSys++) {
+ for(int iSys=0;iSys<4;iSys++) {
fServer[iSys]=0;
- fFESlist[iSys].SetOwner(kTRUE);
+ if (iSys < 3)
+ fFXSlist[iSys].SetOwner(kTRUE);
}
fPreprocessorMap.SetOwner(kTRUE);
-}
-//______________________________________________________________________
-AliShuttle::AliShuttle(const AliShuttle& /*other*/):
-AliShuttleInterface(),
-fConfig(0),
-fTimeout(0), fRetries(0),
-fPreprocessorMap(),
-fLogbookEntry(0),
-fCurrentDetector(""),
-fStatusEntry(0),
-fGridError(kFALSE)
-{
-// copy constructor (not implemented)
+ for (UInt_t iDet=0; iDet<NDetectors(); iDet++)
+ fFirstUnprocessed[iDet] = kFALSE;
-}
-
-//______________________________________________________________________
-AliShuttle &AliShuttle::operator=(const AliShuttle& /*other*/)
-{
-// assignment operator (not implemented)
-
-return *this;
+ fMonitoringMutex = new TMutex();
}
//______________________________________________________________________________________________
// destructor
fPreprocessorMap.DeleteAll();
- for(int iSys=0;iSys<3;iSys++)
+ for(int iSys=0;iSys<4;iSys++)
if(fServer[iSys]) {
fServer[iSys]->Close();
delete fServer[iSys];
+ fServer[iSys] = 0;
}
if (fStatusEntry){
delete fStatusEntry;
fStatusEntry = 0;
}
+
+ if (fMonitoringMutex)
+ {
+ delete fMonitoringMutex;
+ fMonitoringMutex = 0;
+ }
}
//______________________________________________________________________________________________
// with the same identificator (GetName()).
//
- if (fPreprocessorMap.GetValue(preprocessor->GetName())) {
- AliWarning(Form("AliPreprocessor %s is already registered!",
- preprocessor->GetName()));
+ const char* detName = preprocessor->GetName();
+ if(GetDetPos(detName) < 0)
+ AliFatal(Form("********** !!!!! Invalid detector name: %s !!!!! **********", detName));
+
+ if (fPreprocessorMap.GetValue(detName)) {
+ AliWarning(Form("AliPreprocessor %s is already registered!", detName));
return;
}
- fPreprocessorMap.Add(new TObjString(preprocessor->GetName()), preprocessor);
+ fPreprocessorMap.Add(new TObjString(detName), preprocessor);
}
//______________________________________________________________________________________________
UInt_t AliShuttle::Store(const AliCDBPath& path, TObject* object,
}
//______________________________________________________________________________________________
-UInt_t AliShuttle::StoreReferenceData(const AliCDBPath& path, TObject* object,
- AliCDBMetaData* metaData, Int_t validityStart, Bool_t validityInfinite)
+UInt_t AliShuttle::StoreReferenceData(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData)
{
// Stores a CDB object in the storage for reference data. This objects will not be available during
// offline reconstrunction. Use this function for reference data only!
// It calls WriteToCDB function which perform actual storage
- return WriteToCDB(fgkMainRefStorage, fgkLocalRefStorage, path, object,
- metaData, validityStart, validityInfinite);
+ return WriteToCDB(fgkMainRefStorage, fgkLocalRefStorage, path, object, metaData);
}
if(! dynamic_cast<TObjString*> (metaData->GetProperty("RunUsed(TObjString)"))){
TObjString runUsed = Form("%d", GetCurrentRun());
- metaData->SetProperty("RunUsed(TObjString)",&runUsed);
+ metaData->SetProperty("RunUsed(TObjString)", runUsed.Clone());
}
UInt_t result = 0;
fStatusEntry = 0;
}
- fStatusEntry = AliCDBManager::Instance()->GetStorage(AliShuttle::GetLocalCDB())
+ fStatusEntry = AliCDBManager::Instance()->GetStorage(GetLocalCDB())
->Get(Form("/SHUTTLE/STATUS/%s", fCurrentDetector.Data()), GetCurrentRun());
if (!fStatusEntry) return 0;
AliError(Form("WriteShuttleStatus for %s, run %d failed", fCurrentDetector.Data(), run));
return kFALSE;
}
+
+ SendMLInfo();
return kTRUE;
}
return;
}
- Log("SHUTTLE", Form("UpdateShuttleStatus - %s: Changing state from %s to %s", fCurrentDetector.Data(),
- status->GetStatusName(), status->GetStatusName(newStatus)));
+ TString actionStr = Form("UpdateShuttleStatus - %s: Changing state from %s to %s",
+ fCurrentDetector.Data(),
+ status->GetStatusName(),
+ status->GetStatusName(newStatus));
+ Log("SHUTTLE", actionStr);
+ SetLastAction(actionStr);
status->SetStatus(newStatus);
if (increaseCount) status->IncreaseCount();
AliCDBManager::Instance()->GetStorage(fgkLocalCDB)->Put(fStatusEntry);
+
+ SendMLInfo();
+}
+
+//______________________________________________________________________________________________
+void AliShuttle::SendMLInfo()
+{
+ //
+ // sends ML information about the current status of the current detector being processed
+ //
+
+ AliShuttleStatus* status = dynamic_cast<AliShuttleStatus*> (fStatusEntry->GetObject());
+
+ if (!status){
+ AliError("UNEXPECTED: status could not be read from current CDB entry");
+ return;
+ }
+
+ TMonaLisaText mlStatus(Form("%s_status", fCurrentDetector.Data()), status->GetStatusName());
+ TMonaLisaValue mlRetryCount(Form("%s_count", fCurrentDetector.Data()), status->GetCount());
+
+ TList mlList;
+ mlList.Add(&mlStatus);
+ mlList.Add(&mlRetryCount);
+
+ fMonaLisa->SendParameters(&mlList);
}
+
//______________________________________________________________________________________________
Bool_t AliShuttle::ContinueProcessing()
{
// checks if the processing should be continued
// if yes it returns kTRUE and updates the AliShuttleStatus with nextStatus
- if(!GetDetCode(fCurrentDetector)) {
- Log("SHUTTLE", Form("ContinueProcessing - %s: unknown detector",
- fCurrentDetector.Data()));
+ if (!fConfig->HostProcessDetector(fCurrentDetector)) return kFALSE;
+
+ AliPreprocessor* aPreprocessor =
+ dynamic_cast<AliPreprocessor*> (fPreprocessorMap.GetValue(fCurrentDetector));
+ if (!aPreprocessor)
+ {
+ AliInfo(Form("%s: no preprocessor registered", fCurrentDetector.Data()));
return kFALSE;
}
AliShuttleLogbookEntry::Status entryStatus =
- fLogbookEntry->GetDetectorStatus(GetDetCode(fCurrentDetector));
+ fLogbookEntry->GetDetectorStatus(fCurrentDetector);
if(entryStatus != AliShuttleLogbookEntry::kUnprocessed) {
- Log("SHUTTLE", Form("ContinueProcessing - %s is already %s",
+ AliInfo(Form("ContinueProcessing - %s is %s",
fCurrentDetector.Data(),
fLogbookEntry->GetDetectorStatusName(entryStatus)));
return kFALSE;
}
// if we get here, according to Shuttle logbook subdetector is in UNPROCESSED state
+
+ // check if current run is first unprocessed run for current detector
+ if (fConfig->StrictRunOrder(fCurrentDetector) &&
+ !fFirstUnprocessed[GetDetPos(fCurrentDetector)])
+ {
+ Log("SHUTTLE", Form("ContinueProcessing - %s requires strict run ordering but this is not the first unprocessed run!"));
+ return kFALSE;
+ }
+
AliShuttleStatus* status = ReadShuttleStatus();
if (!status) {
// first time
Log("SHUTTLE",
Form("ContinueProcessing - %s: Grid storage failed again",
fCurrentDetector.Data()));
+ // trigger ML information manually because we do not had a status change
+ SendMLInfo();
}
return kFALSE;
}
// if we get here, there is a restart
+ Bool_t cont = kFALSE;
// abort conditions
- // TODO we should add two counters, one for PP and one for DCS!
- if ((status->GetStatus() == AliShuttleStatus::kPPStarted ||
- status->GetStatus() == AliShuttleStatus::kPPError) &&
- (status->GetCount() >= fConfig->GetMaxPPRetries() ||
- status->GetCount() >= fConfig->GetMaxRetries())) {
- Log("SHUTTLE",
- Form("ContinueProcessing - %s failed %d times in status %s - Updating Shuttle Logbook",
- fCurrentDetector.Data(),
+ if (status->GetCount() >= fConfig->GetMaxRetries()) {
+ Log("SHUTTLE", Form("ContinueProcessing - %s failed %d times in status %s - "
+ "Updating Shuttle Logbook", fCurrentDetector.Data(),
status->GetCount(), status->GetStatusName()));
UpdateShuttleLogbook(fCurrentDetector.Data(), "FAILED");
- return kFALSE;
+ UpdateShuttleStatus(AliShuttleStatus::kFailed);
+ } else {
+ Log("SHUTTLE", Form("ContinueProcessing - %s: restarting. "
+ "Aborted before with %s. Retry number %d.", fCurrentDetector.Data(),
+ status->GetStatusName(), status->GetCount()));
+ UpdateShuttleStatus(AliShuttleStatus::kStarted, kTRUE);
+ cont = kTRUE;
}
- Log("SHUTTLE", Form("ContinueProcessing - %s: restarting. Got stuck before in %s. Retry number %d.",
- fCurrentDetector.Data(),
- status->GetStatusName(), status->GetCount()));
-
- UpdateShuttleStatus(AliShuttleStatus::kStarted);
+ // Send mail to detector expert!
+ AliInfo(Form("Sending mail to %s expert...", fCurrentDetector.Data()));
+ if (!SendMail())
+ Log("SHUTTLE", Form("ContinueProcessing - Could not send mail to %s expert",
+ fCurrentDetector.Data()));
- return kTRUE;
+ return cont;
}
//______________________________________________________________________________________________
fLogbookEntry = entry;
- if(fLogbookEntry->IsDone()){
+ if (fLogbookEntry->IsDone())
+ {
Log("SHUTTLE","Process - Shuttle is already DONE. Updating logbook");
UpdateShuttleLogbook("shuttle_done");
fLogbookEntry = 0;
return kTRUE;
}
+ // create ML instance that monitors this run
+ fMonaLisa = new TMonaLisaWriter(Form("%d", GetCurrentRun()), "SHUTTLE", "aliendb1.cern.ch");
+ // disable monitoring of other parameters that come e.g. from TFile
+ gMonitoringWriter = 0;
AliInfo(Form("\n\n \t\t\t^*^*^*^*^*^*^*^*^*^*^*^* run %d: START ^*^*^*^*^*^*^*^*^*^*^*^* \n",
GetCurrentRun()));
- fLogbookEntry->Print("");
+ // Set run type from run type logbook into current fLogbookEntry
+ SetRunType();
+
+ // Send the information to ML
+ TMonaLisaText mlStatus("SHUTTLE_status", "Processing");
+
+ TList mlList;
+ mlList.Add(&mlStatus);
+
+ fMonaLisa->SendParameters(&mlList);
+
+ fLogbookEntry->Print("all");
// Initialization
Bool_t hasError = kFALSE;
- for(Int_t iSys=0;iSys<3;iSys++) fFESCalled[iSys]=kFALSE;
AliCDBStorage *mainCDBSto = AliCDBManager::Instance()->GetStorage(fgkMainCDB);
if(mainCDBSto) mainCDBSto->QueryCDB(GetCurrentRun());
TIter iter(fConfig->GetDetectors());
TObjString* aDetector = 0;
- while ((aDetector = (TObjString*) iter.Next())) {
+ while ((aDetector = (TObjString*) iter.Next()))
+ {
fCurrentDetector = aDetector->String();
- if (!fConfig->HostProcessDetector(fCurrentDetector)) continue;
-
- AliPreprocessor* aPreprocessor =
- dynamic_cast<AliPreprocessor*> (fPreprocessorMap.GetValue(fCurrentDetector));
- if(!aPreprocessor){
- Log("SHUTTLE",Form("Process - %s: no preprocessor registered. Skipping"));
- continue;
- }
-
if (ContinueProcessing() == kFALSE) continue;
AliInfo(Form("\n\n \t\t\t****** run %d - %s: START ******",
GetCurrentRun(), aDetector->GetName()));
- UInt_t result = ProcessCurrentDetector();
+ for(Int_t iSys=0;iSys<3;iSys++) fFXSCalled[iSys]=kFALSE;
- if(!result) {
- hasError = kTRUE;
- AliInfo(Form("\n \t\t\t****** run %d - %s: PREPROCESSOR ERROR ****** \n\n",
+ Log(fCurrentDetector.Data(), "Starting processing");
+
+ Int_t pid = fork();
+
+ if (pid < 0)
+ {
+ Log("SHUTTLE", "ERROR: Forking failed");
+ }
+ else if (pid > 0)
+ {
+ // parent
+ AliInfo(Form("In parent process of %d - %s: Starting monitoring",
GetCurrentRun(), aDetector->GetName()));
- continue;
+
+ Long_t begin = time(0);
+
+ int status; // to be used with waitpid, on purpose an int (not Int_t)!
+ while (waitpid(pid, &status, WNOHANG) == 0)
+ {
+ Long_t expiredTime = time(0) - begin;
+
+ if (expiredTime > fConfig->GetPPTimeOut())
+ {
+ Log("SHUTTLE", Form("Process time out. Run time: %d seconds. Killing...",
+ expiredTime));
+
+ kill(pid, 9);
+
+ hasError = kTRUE;
+
+ gSystem->Sleep(1000);
+ }
+ else
+ {
+ if (expiredTime % 60 == 0)
+ Log("SHUTTLE", Form("Checked process. Run time: %d seconds.",
+ expiredTime));
+ gSystem->Sleep(1000);
+ }
+ }
+
+ AliInfo(Form("In parent process of %d - %s: Client has terminated.",
+ GetCurrentRun(), aDetector->GetName()));
+
+ if (WIFEXITED(status))
+ {
+ Int_t returnCode = WEXITSTATUS(status);
+
+ Log("SHUTTLE", Form("The return code is %d", returnCode));
+
+ if (returnCode != 0)
+ hasError = kTRUE;
+ }
}
+ else if (pid == 0)
+ {
+ // client
+ AliInfo(Form("In client process of %d - %s", GetCurrentRun(), aDetector->GetName()));
+
+ UInt_t result = ProcessCurrentDetector();
+
+ Int_t returnCode = 0; // will be set to 1 in case of an error
- if(result == 2) {
- AliInfo(Form("\n \t\t\t****** run %d - %s: STORAGE ERROR ****** \n\n",
+ if (!result)
+ {
+ returnCode = 1;
+ AliInfo(Form("\n \t\t\t****** run %d - %s: PREPROCESSOR ERROR ****** \n\n",
GetCurrentRun(), aDetector->GetName()));
- } else {
- AliInfo(Form("\n \t\t\t****** run %d - %s: DONE ****** \n\n",
+ }
+ else if (result == 2)
+ {
+ AliInfo(Form("\n \t\t\t****** run %d - %s: STORAGE ERROR ****** \n\n",
GetCurrentRun(), aDetector->GetName()));
- }
+ } else
+ {
+ AliInfo(Form("\n \t\t\t****** run %d - %s: DONE ****** \n\n",
+ GetCurrentRun(), aDetector->GetName()));
+ }
- // Process successful: Update time_processed field in FES logbooks!
- if(fFESCalled[kDAQ]) {
- hasError = (UpdateDAQTable() == kFALSE);
- fFESlist[kDAQ].Clear();
- }
- //if(fFESCalled[kDCS]) {
- // hasError = UpdateDCSTable(aDetector->GetName());
- // fFESlist[kDCS].Clear();
- //}
- //if(fFESCalled[kHLT]) {
- // hasError = UpdateHLTTable(aDetector->GetName());
- // fFESlist[kHLT].Clear();
- //}
+ if (result > 0)
+ {
+ // Process successful: Update time_processed field in FXS logbooks!
+ if (UpdateTable() == kFALSE) returnCode = 1;
+ }
+ for (UInt_t iSys=0; iSys<3; iSys++)
+ {
+ if (fFXSCalled[iSys]) fFXSlist[iSys].Clear();
+ }
+
+ AliInfo(Form("Client process of %d - %s is exiting now with %d.",
+ GetCurrentRun(), aDetector->GetName(), returnCode));
+
+ // the client exits here
+ gSystem->Exit(returnCode);
+
+ AliError("We should never get here!!!");
+ }
}
AliInfo(Form("\n\n \t\t\t^*^*^*^*^*^*^*^*^*^*^*^* run %d: FINISH ^*^*^*^*^*^*^*^*^*^*^*^* \n",
//check if shuttle is done for this run, if so update logbook
TObjArray checkEntryArray;
checkEntryArray.SetOwner(1);
- TString whereClause = Form("where run=%d",GetCurrentRun());
- if(QueryShuttleLogbook(whereClause.Data(), checkEntryArray)) {
+ TString whereClause = Form("where run=%d", GetCurrentRun());
+ if (!QueryShuttleLogbook(whereClause.Data(), checkEntryArray) || checkEntryArray.GetEntries() == 0) {
+ Log("SHUTTLE", Form("Process - Warning: Cannot check status of run %d on Shuttle logbook!",
+ GetCurrentRun()));
+ return hasError == kFALSE;
+ }
-
AliShuttleLogbookEntry* checkEntry = dynamic_cast<AliShuttleLogbookEntry*>
- (checkEntryArray.At(0));
+ AliShuttleLogbookEntry* checkEntry = dynamic_cast<AliShuttleLogbookEntry*>
+ (checkEntryArray.At(0));
- if(checkEntry && checkEntry->IsDone()){
+ if (checkEntry)
+ {
+ if (checkEntry->IsDone())
+ {
Log("SHUTTLE","Process - Shuttle is DONE. Updating logbook");
UpdateShuttleLogbook("shuttle_done");
}
+ else
+ {
+ for (UInt_t iDet=0; iDet<NDetectors(); iDet++)
+ {
+ if (checkEntry->GetDetectorStatus(iDet) == AliShuttleLogbookEntry::kUnprocessed)
+ {
+ AliDebug(2, Form("Run %d: setting %s as \"not first time unprocessed\"",
+ checkEntry->GetRun(), GetDetName(iDet)));
+ fFirstUnprocessed[iDet] = kFALSE;
+ }
+ }
+ }
}
+ // remove ML instance
+ delete fMonaLisa;
+ fMonaLisa = 0;
+
fLogbookEntry = 0;
return hasError == kFALSE;
UpdateShuttleStatus(AliShuttleStatus::kDCSStarted);
- TString host(fConfig->GetDCSHost(fCurrentDetector));
- Int_t port = fConfig->GetDCSPort(fCurrentDetector);
-
- TIter iter(fConfig->GetDCSAliases(fCurrentDetector));
- TObjString* anAlias;
- TMap aliasMap;
- aliasMap.SetOwner(1);
+ TMap dcsMap;
+ dcsMap.SetOwner(1);
Bool_t aDCSError = kFALSE;
fGridError = kFALSE;
- while ((anAlias = (TObjString*) iter.Next())) {
- TObjArray *valueSet = new TObjArray();
- valueSet->SetOwner(1);
- // TODO Test only... I've added a flag that allows to
- // exclude DCS archive DB query
- if(fgkProcessDCS){
- AliInfo("Querying DCS archive DB data...");
- aDCSError = (GetValueSet(host, port, anAlias->String(), valueSet) == 0);
- } else {
- AliInfo(Form("Skipping DCS processing. Port = %d",port));
- aDCSError = kFALSE;
+ // TODO Test only... I've added a flag that allows to
+ // exclude DCS archive DB query
+ if (!fgkProcessDCS)
+ {
+ AliInfo("Skipping DCS processing!");
+ aDCSError = kFALSE;
+ } else {
+ TString host(fConfig->GetDCSHost(fCurrentDetector));
+ Int_t port = fConfig->GetDCSPort(fCurrentDetector);
+
+ // Retrieval of Aliases
+ TObjString* anAlias = 0;
+ Int_t iAlias = 1;
+ Int_t nTotAliases= ((TMap*)fConfig->GetDCSAliases(fCurrentDetector))->GetEntries();
+ TIter iterAliases(fConfig->GetDCSAliases(fCurrentDetector));
+ while ((anAlias = (TObjString*) iterAliases.Next()))
+ {
+ TObjArray *valueSet = new TObjArray();
+ valueSet->SetOwner(1);
+
+ if (((iAlias-1) % 500) == 0 || iAlias == nTotAliases)
+ AliInfo(Form("Querying DCS archive: alias %s (%d of %d)",
+ anAlias->GetName(), iAlias++, nTotAliases));
+ aDCSError = (GetValueSet(host, port, anAlias->String(), valueSet, kAlias) == 0);
+
+ if(!aDCSError)
+ {
+ dcsMap.Add(anAlias->Clone(), valueSet);
+ } else {
+ Log(fCurrentDetector,
+ Form("ProcessCurrentDetector - Error while retrieving alias %s",
+ anAlias->GetName()));
+ UpdateShuttleStatus(AliShuttleStatus::kDCSError);
+ dcsMap.DeleteAll();
+ return 0;
+ }
}
- if(!aDCSError) {
- aliasMap.Add(anAlias->Clone(), valueSet);
- }else{
- Log(fCurrentDetector, Form("ProcessCurrentDetector - Error while retrieving alias %s",
- anAlias->GetName()));
- UpdateShuttleStatus(AliShuttleStatus::kDCSError, kTRUE);
- aliasMap.DeleteAll();
- return 0;
+
+ // Retrieval of Data Points
+ TObjString* aDP = 0;
+ Int_t iDP = 0;
+ Int_t nTotDPs= ((TMap*)fConfig->GetDCSDataPoints(fCurrentDetector))->GetEntries();
+ TIter iterDP(fConfig->GetDCSDataPoints(fCurrentDetector));
+ while ((aDP = (TObjString*) iterDP.Next()))
+ {
+ TObjArray *valueSet = new TObjArray();
+ valueSet->SetOwner(1);
+ if (((iDP-1) % 500) == 0 || iDP == nTotDPs)
+ AliInfo(Form("Querying DCS archive: DP %s (%d of %d)",
+ aDP->GetName(), iDP++, nTotDPs));
+ aDCSError = (GetValueSet(host, port, aDP->String(), valueSet, kDP) == 0);
+
+ if(!aDCSError)
+ {
+ dcsMap.Add(aDP->Clone(), valueSet);
+ } else {
+ Log(fCurrentDetector,
+ Form("ProcessCurrentDetector - Error while retrieving data point %s",
+ aDP->GetName()));
+ UpdateShuttleStatus(AliShuttleStatus::kDCSError);
+ dcsMap.DeleteAll();
+ return 0;
+ }
}
}
dynamic_cast<AliPreprocessor*> (fPreprocessorMap.GetValue(fCurrentDetector));
aPreprocessor->Initialize(GetCurrentRun(), GetCurrentStartTime(), GetCurrentEndTime());
-
- UInt_t aPPResult = aPreprocessor->Process(&aliasMap);
+ UInt_t aPPResult = aPreprocessor->Process(&dcsMap);
UInt_t returnValue = 0;
if (aPPResult == 0) { // Preprocessor error
- UpdateShuttleStatus(AliShuttleStatus::kPPError, kTRUE);
+ UpdateShuttleStatus(AliShuttleStatus::kPPError);
returnValue = 0;
} else if (fGridError == kFALSE) { // process and Grid storage ok!
UpdateShuttleStatus(AliShuttleStatus::kDone);
returnValue = 2;
}
- aliasMap.DeleteAll();
+ dcsMap.DeleteAll();
return returnValue;
}
// Query DAQ's Shuttle logbook and fills detector status object.
// Call QueryRunParameters to query DAQ logbook for run parameters.
+ entries.SetOwner(1);
+
// check connection, in case connect
- if(!Connect(kDAQ)) return kFALSE;
+ if(!Connect(3)) return kFALSE;
TString sqlQuery;
- sqlQuery = Form("select * from logbook_shuttle %s order by run", whereClause);
+ sqlQuery = Form("select * from %s %s order by run", fConfig->GetShuttlelbTable(), whereClause);
- TSQLResult* aResult = fServer[kDAQ]->Query(sqlQuery);
+ TSQLResult* aResult = fServer[3]->Query(sqlQuery);
if (!aResult) {
AliError(Form("Can't execute query <%s>!", sqlQuery.Data()));
return kFALSE;
}
+ AliDebug(2,Form("Query = %s", sqlQuery.Data()));
+
if(aResult->GetRowCount() == 0) {
- if(sqlQuery.Contains("where shuttle_done=0")){
- Log("SHUTTLE", "QueryShuttleLogbook - All runs in Shuttle Logbook are already DONE");
+// if(sqlQuery.EndsWith("where shuttle_done=0 order by run")){
+// Log("SHUTTLE", "QueryShuttleLogbook - All runs in Shuttle Logbook are already DONE");
+// delete aResult;
+// return kTRUE;
+// } else {
+ AliInfo("No entries in Shuttle Logbook match request");
delete aResult;
return kTRUE;
- } else {
- AliError("No entries in Shuttle Logbook match request");
- delete aResult;
- return kFALSE;
- }
+// }
}
// TODO Check field count!
- const UInt_t nCols = 24;
+ const UInt_t nCols = 22;
if (aResult->GetFieldCount() != (Int_t) nCols) {
AliError("Invalid SQL result field number!");
delete aResult;
return kFALSE;
}
- entries.SetOwner(1);
-
TSQLRow* aRow;
while ((aRow = aResult->Next())) {
TString runString(aRow->GetField(0), aRow->GetFieldLength(0));
Int_t run = runString.Atoi();
- UInt_t startTime, endTime;
- if(!QueryRunParameters(run, startTime, endTime)) continue;
-
- const UInt_t nDet = AliShuttle::kNDetectors;
- AliShuttleLogbookEntry::Status detStatus[nDet];
+ AliShuttleLogbookEntry *entry = QueryRunParameters(run);
+ if (!entry)
+ continue;
// loop on detectors
- for(UInt_t ii = 0; ii < nCols; ii++){
- TString detCode(aResult->GetFieldName(ii));
- Int_t detPos = AliShuttle::GetDetPos(detCode.Data());
- if(detPos < 0) continue;
- TString statusString(aRow->GetField(ii), aRow->GetFieldLength(ii));
- if(statusString == "UNPROCESSED"){
- detStatus[detPos] = AliShuttleLogbookEntry::kUnprocessed;
- } else if (statusString == "INACTIVE") {
- detStatus[detPos] = AliShuttleLogbookEntry::kInactive;
- } else if (statusString == "FAILED") {
- detStatus[detPos] = AliShuttleLogbookEntry::kFailed;
- } else if (statusString == "DONE") {
- detStatus[detPos] = AliShuttleLogbookEntry::kDone;
- }
- }
+ for(UInt_t ii = 0; ii < nCols; ii++)
+ entry->SetDetectorStatus(aResult->GetFieldName(ii), aRow->GetField(ii));
- entries.AddLast(new AliShuttleLogbookEntry(run, startTime, endTime, detStatus));
+ entries.AddLast(entry);
delete aRow;
}
- if(sqlQuery.Contains("where shuttle_done=0"))
- Log("SHUTTLE", Form("QueryShuttleLogbook - Found %d unprocessed runs in Shuttle Logbook",
- entries.GetEntriesFast()));
+// if(sqlQuery.EndsWith("where shuttle_done=0 order by run"))
+// Log("SHUTTLE", Form("QueryShuttleLogbook - Found %d unprocessed runs in Shuttle Logbook",
+// entries.GetEntriesFast()));
delete aResult;
return kTRUE;
}
//______________________________________________________________________________________________
-Bool_t AliShuttle::QueryRunParameters(Int_t& run, UInt_t& startTime, UInt_t& endTime)
+AliShuttleLogbookEntry* AliShuttle::QueryRunParameters(Int_t run)
{
-// Retrieve start time and end time for run in the DAQ logbook
+ //
+ // Retrieve run parameters written in the DAQ logbook and sets them into AliShuttleLogbookEntry object
+ //
// check connection, in case connect
- if(!Connect(kDAQ)) return kFALSE;
+ if (!Connect(3))
+ return 0;
TString sqlQuery;
- sqlQuery = Form("select time_start, time_end from logbook where run=%d", run);
+ sqlQuery.Form("select * from %s where run=%d", fConfig->GetDAQlbTable(), run);
- TSQLResult* aResult = fServer[kDAQ]->Query(sqlQuery);
+ TSQLResult* aResult = fServer[3]->Query(sqlQuery);
if (!aResult) {
AliError(Form("Can't execute query <%s>!", sqlQuery.Data()));
- return kFALSE;
+ return 0;
}
- if(aResult->GetRowCount() == 0) {
+ if (aResult->GetRowCount() == 0) {
Log("SHUTTLE", Form("QueryRunParameters - No entry in DAQ Logbook for run %d. Skipping", run));
delete aResult;
- return kFALSE;
+ return 0;
}
- if(aResult->GetRowCount() > 1) {
+ if (aResult->GetRowCount() > 1) {
AliError(Form("More than one entry in DAQ Logbook for run %d. Skipping", run));
delete aResult;
- return kFALSE;
+ return 0;
}
- TSQLRow* aRow;
- while ((aRow = aResult->Next())) {
+ TSQLRow* aRow = aResult->Next();
+ if (!aRow)
+ {
+ AliError(Form("Could not retrieve row for run %d. Skipping", run));
+ delete aResult;
+ return 0;
+ }
- TString startTimeString(aRow->GetField(0),
- aRow->GetFieldLength(0));
- startTime = startTimeString.Atoi();
- TString endTimeString(aRow->GetField(1),
- aRow->GetFieldLength(1));
- endTime = endTimeString.Atoi();
+ AliShuttleLogbookEntry* entry = new AliShuttleLogbookEntry(run);
- if (!startTime || !endTime || startTime > endTime) {
- Log("SHUTTLE",
- Form("QueryRunParameters - Invalid parameters for Run %d: startTime = %d, endTime = %d",
- run, startTime, endTime));
- delete aRow;
- delete aResult;
- return kFALSE;
- }
+ for (Int_t ii = 0; ii < aResult->GetFieldCount(); ii++)
+ entry->SetRunParameter(aResult->GetFieldName(ii), aRow->GetField(ii));
+
+ UInt_t startTime = entry->GetStartTime();
+ UInt_t endTime = entry->GetEndTime();
+ if (!startTime || !endTime || startTime > endTime) {
+ Log("SHUTTLE",
+ Form("QueryRunParameters - Invalid parameters for Run %d: startTime = %d, endTime = %d",
+ run, startTime, endTime));
+ delete entry;
delete aRow;
+ delete aResult;
+ return 0;
}
+ delete aRow;
delete aResult;
- return kTRUE;
+
+ return entry;
}
//______________________________________________________________________________________________
{
// Called by TryToStoreAgain(), performs actual storage retry
- TList* gridIds=0;
+ TObjArray* gridIds=0;
Bool_t result = kTRUE;
// get objects previously stored in local CDB
AliCDBStorage *backupSto = man->GetStorage(backupURI);
- AliCDBPath aPath(fCurrentDetector,"*","*");
+ AliCDBPath aPath(GetOfflineDetName(fCurrentDetector.Data()),"*","*");
// Local objects were stored with current run as Grid version!
TList* localEntries = backupSto->GetAll(aPath.GetPath(), GetCurrentRun(), GetCurrentRun());
localEntries->SetOwner(1);
TIter gridIter(gridIds);
AliCDBId* aGridId = 0;
while((aGridId = dynamic_cast<AliCDBId*> (gridIter.Next()))){
- // If local object is valid up to infinity we store it anyway
- // TODO This does not work! It may hide more recent objects...
- if(aLocId.GetLastRun() == AliCDBRunRange::Infinity()) {
- // TODO Check that it won't hide more recent files! how????
- break;
+ // If local object is valid up to infinity we store it only if it is
+ // the first unprocessed run!
+ if (aLocId.GetLastRun() == AliCDBRunRange::Infinity())
+ {
+ if (!fFirstUnprocessed[GetDetPos(fCurrentDetector)])
+ {
+ Log(fCurrentDetector.Data(),
+ ("TryToStoreAgain - This object has validity infinite but "
+ "there are previous unprocessed runs!"));
+ continue;
+ } else {
+ break;
+ }
}
if(aGridId->GetPath() != aLocId.GetPath()) continue;
// skip all objects valid up to infinity
}
//______________________________________________________________________________________________
-Bool_t AliShuttle::GetValueSet(const char* host, Int_t port, const char* alias,
- TObjArray* valueSet)
+Bool_t AliShuttle::GetValueSet(const char* host, Int_t port, const char* entry,
+ TObjArray* valueSet, DCSType type)
{
-// Retrieve all "alias" data points from the DCS server
+// Retrieve all "entry" data points from the DCS server
// host, port: TSocket connection parameters
-// alias: name of the alias
+// entry: name of the alias or data point
// valueSet: array of retrieved AliDCSValue's
+// type: kAlias or kDP
AliDCSClient client(host, port, fTimeout, fRetries);
- if (!client.IsConnected()) {
+ if (!client.IsConnected())
+ {
return kFALSE;
}
- Int_t result = client.GetAliasValues(alias,
- GetCurrentStartTime(), GetCurrentEndTime(), valueSet);
+ Int_t result=0;
- if (result < 0) {
+ if (type == kAlias)
+ {
+ result = client.GetAliasValues(entry,
+ GetCurrentStartTime(), GetCurrentEndTime(), valueSet);
+ } else
+ if (type == kDP)
+ {
+ result = client.GetDPValues(entry,
+ GetCurrentStartTime(), GetCurrentEndTime(), valueSet);
+ }
+
+ if (result < 0)
+ {
Log(fCurrentDetector.Data(), Form("GetValueSet - Can't get '%s'! Reason: %s",
- alias, AliDCSClient::GetErrorString(result)));
+ entry, AliDCSClient::GetErrorString(result)));
- if (result == AliDCSClient::fgkServerError) {
+ if (result == AliDCSClient::fgkServerError)
+ {
Log(fCurrentDetector.Data(), Form("GetValueSet - Server error: %s",
client.GetServerError().Data()));
}
const char* id, const char* source)
{
// Get calibration file from file exchange servers
-// calls specific getter according to system index (kDAQ, kDCS, kHLT)
-
- switch(system){
- case kDAQ:
- return GetDAQFileName(detector, id, source);
- break;
- case kDCS:
- return GetDCSFileName(detector, id, source);
- break;
- case kHLT:
- return GetHLTFileName(detector, id, source);
- break;
- default:
- AliError(Form("No valid system index: %d",system));
- }
-
- return 0;
-}
-
-//______________________________________________________________________________________________
-TList* AliShuttle::GetFileSources(Int_t system, const char* detector, const char* id)
-{
-// Get sources producing the condition file Id from file exchange servers
-// calls specific getter according to system index (kDAQ, kDCS, kHLT)
-
- switch(system){
- case kDAQ:
- return GetDAQFileSources(detector, id);
- break;
- case kDCS:
- return GetDCSFileSources(detector, id);
- break;
- case kHLT:
- return GetHLTFileSources(detector, id);
- break;
- default:
- AliError(Form("No valid system index: %d",system));
- }
-
- return NULL;
-}
-
-//______________________________________________________________________________________________
-Bool_t AliShuttle::Connect(Int_t system)
-{
-// Connect to MySQL Server of the system's FES logbook
-// DAQ Logbook, Shuttle Logbook and DAQ FES Logbook are on the same host
-
- // check connection: if already connected return
- if(fServer[system] && fServer[system]->IsConnected()) return kTRUE;
-
- TString aFESlbHost= Form("mysql://%s", fConfig->GetFESlbHost(system));
-
- fServer[system] = TSQLServer::Connect(aFESlbHost,
- fConfig->GetFESlbUser(system),
- fConfig->GetFESlbPass(system));
- if (!fServer[system] || !fServer[system]->IsConnected()) {
- AliError(Form("Can't establish connection to FES logbook for %s",fkSystemNames[system]));
- if(fServer[system]) delete fServer[system];
- return kFALSE;
- }
-
- // Get tables
- // TODO in the configuration should the table name be there too?
- TSQLResult* aResult=0;
- switch(system){
- case kDAQ:
- aResult = fServer[kDAQ]->GetTables("REFSYSLOG");
- break;
- case kDCS:
- //aResult = fServer[kDCS]->GetTables("REFSYSLOG");
- break;
- case kHLT:
- //aResult = fServer[kHLT]->GetTables("REFSYSLOG");
- break;
- default:
- break;
- }
-
- delete aResult;
- return kTRUE;
-}
-
-//______________________________________________________________________________________________
-const char* AliShuttle::GetDAQFileName(const char* detector, const char* id, const char* source)
-{
-// Retrieves a file from the DAQ FES.
-// First queris the DAQ logbook_fs for the DAQ file name, using the run, detector, id and source info
-// then calls RetrieveDAQFile(DAQfilename) for actual copy to local disk
+// First queris the FXS database for the file name, using the run, detector, id and source info
+// then calls RetrieveFile(filename) for actual copy to local disk
// run: current run being processed (given by Logbook entry fLogbookEntry)
-// detector: comes from the Preprocessor name (must be converted into detector code with GetDetCode)
+// detector: the Preprocessor name
// id: provided as a parameter by the Preprocessor
// source: provided by the Preprocessor through GetFileSources function
// check connection, in case connect
- if(!Connect(kDAQ)){
- Log(detector, "GetDAQFileName - Couldn't connect to DAQ Logbook");
+ if (!Connect(system))
+ {
+ Log(detector, Form("GetFile - Couldn't connect to %s FXS database", GetSystemName(system)));
return 0;
}
// Query preparation
- TString sqlQueryStart = "select filePath from logbook_fs where";
- TString whereClause = Form("run=%d and detector=\"%s\" and fileId=\"%s\" and DAQsource=\"%s\"",
- GetCurrentRun(), GetDetCode(detector), id, source);
+ TString sourceName(source);
+ Int_t nFields = 3;
+ TString sqlQueryStart = Form("select filePath,size,fileChecksum from %s where",
+ fConfig->GetFXSdbTable(system));
+ TString whereClause = Form("run=%d and detector=\"%s\" and fileId=\"%s\"",
+ GetCurrentRun(), detector, id);
+
+ if (system == kDAQ)
+ {
+ whereClause += Form(" and DAQsource=\"%s\"", source);
+ }
+ else if (system == kDCS)
+ {
+ sourceName="none";
+ }
+ else if (system == kHLT)
+ {
+ whereClause += Form(" and DDLnumbers=\"%s\"", source);
+ nFields = 3;
+ }
+
TString sqlQuery = Form("%s %s", sqlQueryStart.Data(), whereClause.Data());
AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
// Query execution
TSQLResult* aResult = 0;
- aResult = dynamic_cast<TSQLResult*> (fServer[kDAQ]->Query(sqlQuery));
+ aResult = dynamic_cast<TSQLResult*> (fServer[system]->Query(sqlQuery));
if (!aResult) {
- Log(detector, Form("GetDAQFileName - Can't execute SQL query for: id = %s, source = %s",
- id, source));
+ Log(detector, Form("GetFileName - Can't execute SQL query to %s database for: id = %s, source = %s",
+ GetSystemName(system), id, sourceName.Data()));
return 0;
}
- if (aResult->GetRowCount() == 0) {
+ if(aResult->GetRowCount() == 0)
+ {
Log(detector,
- Form("GetDAQFileName - No entry in FES table for: id = %s, source = %s",
- id, source));
+ Form("GetFileName - No entry in %s FXS db for: id = %s, source = %s",
+ GetSystemName(system), id, sourceName.Data()));
delete aResult;
return 0;
}
- if (aResult->GetRowCount() >1) {
+ if (aResult->GetRowCount() > 1) {
Log(detector,
- Form("GetDAQFileName - More than one entry in FES table for: id = %s, source = %s",
- id, source));
+ Form("GetFileName - More than one entry in %s FXS db for: id = %s, source = %s",
+ GetSystemName(system), id, sourceName.Data()));
+ delete aResult;
+ return 0;
+ }
+
+ if (aResult->GetFieldCount() != nFields) {
+ Log(detector,
+ Form("GetFileName - Wrong field count in %s FXS db for: id = %s, source = %s",
+ GetSystemName(system), id, sourceName.Data()));
delete aResult;
return 0;
}
TSQLRow* aRow = dynamic_cast<TSQLRow*> (aResult->Next());
- if(!aRow){
- Log(detector, Form("GetDAQFileName - Empty set result from query: id = %s, source = %s",
- id, source));
+ if (!aRow){
+ Log(detector, Form("GetFileName - Empty set result in %s FXS db from query: id = %s, source = %s",
+ GetSystemName(system), id, sourceName.Data()));
delete aResult;
return 0;
}
TString filePath(aRow->GetField(0), aRow->GetFieldLength(0));
+ TString fileSize(aRow->GetField(1), aRow->GetFieldLength(1));
+ TString fileChecksum(aRow->GetField(2), aRow->GetFieldLength(2));
delete aResult;
delete aRow;
- AliDebug(2, Form("filePath = %s",filePath.Data()));
+ AliDebug(2, Form("filePath = %s; size = %s, fileChecksum = %s",
+ filePath.Data(), fileSize.Data(), fileChecksum.Data()));
// retrieved file is renamed to make it unique
- TString localFileName = Form("%s_%d_%s_%s.shuttle",
- detector, GetCurrentRun(), id, source);
+ TString localFileName = Form("%s_%s_%d_%s_%s.shuttle",
+ GetSystemName(system), detector, GetCurrentRun(), id, sourceName.Data());
- // file retrieval from DAQ FES
- Bool_t result = RetrieveDAQFile(filePath.Data(), localFileName.Data());
- if(!result) {
- Log(detector, Form("GetDAQFileName - Copy of file %s from DAQ FES failed", filePath.Data()));
- return 0;
- } else {
- AliInfo(Form("File %s copied from DAQ FES into %s/%s",
- filePath.Data(), fgkShuttleTempDir, localFileName.Data()));
+
+ // file retrieval from FXS
+ UInt_t nRetries = 0;
+ UInt_t maxRetries = 3;
+ Bool_t result = kFALSE;
+
+ // copy!! if successful TSystem::Exec returns 0
+ while(nRetries++ < maxRetries) {
+ AliDebug(2, Form("Trying to copy file. Retry # %d", nRetries));
+ result = RetrieveFile(system, filePath.Data(), localFileName.Data());
+ if(!result)
+ {
+ Log(detector, Form("GetFileName - Copy of file %s from %s FXS failed",
+ filePath.Data(), GetSystemName(system)));
+ continue;
+ } else {
+ AliInfo(Form("File %s copied from %s FXS into %s/%s",
+ filePath.Data(), GetSystemName(system),
+ GetShuttleTempDir(), localFileName.Data()));
+ }
+
+ if (fileChecksum.Length()>0)
+ {
+ // compare md5sum of local file with the one stored in the FXS DB
+ Int_t md5Comp = gSystem->Exec(Form("md5sum %s/%s |grep %s 2>&1 > /dev/null",
+ GetShuttleTempDir(), localFileName.Data(), fileChecksum.Data()));
+
+ if (md5Comp != 0)
+ {
+ Log(detector, Form("GetFileName - md5sum of file %s does not match with local copy!",
+ filePath.Data()));
+ result = kFALSE;
+ continue;
+ }
+ } else {
+ Log(fCurrentDetector, Form("GetFile - md5sum of file %s not set in %s database, skipping comparison",
+ filePath.Data(), GetSystemName(system)));
+ }
+ if (result) break;
}
+ if(!result) return 0;
+
+ fFXSCalled[system]=kTRUE;
+ TObjString *fileParams = new TObjString(Form("%s#!?!#%s", id, sourceName.Data()));
+ fFXSlist[system].Add(fileParams);
+
+ static TString fullLocalFileName;
+ fullLocalFileName = TString::Format("%s/%s", GetShuttleTempDir(), localFileName.Data());
- fFESCalled[kDAQ]=kTRUE;
- TObjString *fileParams = new TObjString(Form("%s_!?!_%s", id, source));
- fFESlist[kDAQ].Add(fileParams);
+ AliInfo(Form("fullLocalFileName = %s", fullLocalFileName.Data()));
- return localFileName.Data();
+ return fullLocalFileName.Data();
}
//______________________________________________________________________________________________
-Bool_t AliShuttle::RetrieveDAQFile(const char* daqFileName, const char* localFileName)
+Bool_t AliShuttle::RetrieveFile(UInt_t system, const char* fxsFileName, const char* localFileName)
{
+// Copies file from FXS to local Shuttle machine
// check temp directory: trying to cd to temp; if it does not exist, create it
- AliDebug(2, Form("Copy file %s from DAQ FES into folder %s and rename it as %s",
- daqFileName,fgkShuttleTempDir, localFileName));
+ AliDebug(2, Form("Copy file %s from %s FXS into %s/%s",
+ GetSystemName(system), fxsFileName, GetShuttleTempDir(), localFileName));
- void* dir = gSystem->OpenDirectory(fgkShuttleTempDir);
+ void* dir = gSystem->OpenDirectory(GetShuttleTempDir());
if (dir == NULL) {
- if (gSystem->mkdir(fgkShuttleTempDir, kTRUE)) {
- AliError(Form("Can't open directory <%s>", fgkShuttleTempDir));
+ if (gSystem->mkdir(GetShuttleTempDir(), kTRUE)) {
+ AliError(Form("Can't open directory <%s>", GetShuttleTempDir()));
return kFALSE;
}
gSystem->FreeDirectory(dir);
}
- TString baseDAQFESFolder = "DAQ";
- TString command = Form("scp %s@%s:%s/%s %s/%s",
- fConfig->GetFESUser(kDAQ),
- fConfig->GetFESHost(kDAQ),
- baseDAQFESFolder.Data(),
- daqFileName,
- fgkShuttleTempDir,
- localFileName);
+ TString baseFXSFolder;
+ if (system == kDAQ)
+ {
+ baseFXSFolder = "FES/";
+ }
+ else if (system == kDCS)
+ {
+ baseFXSFolder = "";
+ }
+ else if (system == kHLT)
+ {
+ baseFXSFolder = "~/";
+ }
- AliDebug(2, Form("%s",command.Data()));
- UInt_t nRetries = 0;
- UInt_t maxRetries = 3;
+ TString command = Form("scp -oPort=%d -2 %s@%s:%s%s %s/%s",
+ fConfig->GetFXSPort(system),
+ fConfig->GetFXSUser(system),
+ fConfig->GetFXSHost(system),
+ baseFXSFolder.Data(),
+ fxsFileName,
+ GetShuttleTempDir(),
+ localFileName);
- // copy!! if successful TSystem::Exec returns 0
- while(nRetries++ < maxRetries) {
- AliDebug(2, Form("Trying to copy file. Retry # %d", nRetries));
- if(gSystem->Exec(command.Data()) == 0) return kTRUE;
- }
+ AliDebug(2, Form("%s",command.Data()));
- return kFALSE;
+ Bool_t result = (gSystem->Exec(command.Data()) == 0);
+ return result;
}
//______________________________________________________________________________________________
-TList* AliShuttle::GetDAQFileSources(const char* detector, const char* id)
+TList* AliShuttle::GetFileSources(Int_t system, const char* detector, const char* id)
{
-// Retrieves a file from the DCS FES.
+// Get sources producing the condition file Id from file exchange servers
+
+ if (system == kDCS)
+ {
+ AliError("DCS system has only one source of data!");
+ return NULL;
+
+ }
// check connection, in case connect
- if(!Connect(kDAQ)){
- Log(detector, "GetDAQFileSources - Couldn't connect to DAQ Logbook");
- return 0;
+ if (!Connect(system))
+ {
+ Log(detector, Form("GetFile - Couldn't connect to %s FXS database", GetSystemName(system)));
+ return NULL;
}
- // Query preparation
- TString sqlQueryStart = "select DAQsource from logbook_fs where";
+ TString sourceName = 0;
+ if (system == kDAQ)
+ {
+ sourceName = "DAQsource";
+ } else if (system == kHLT)
+ {
+ sourceName = "DDLnumbers";
+ }
+
+ TString sqlQueryStart = Form("select %s from %s where", sourceName.Data(), fConfig->GetFXSdbTable(system));
TString whereClause = Form("run=%d and detector=\"%s\" and fileId=\"%s\"",
- GetCurrentRun(), GetDetCode(detector), id);
+ GetCurrentRun(), detector, id);
TString sqlQuery = Form("%s %s", sqlQueryStart.Data(), whereClause.Data());
AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
// Query execution
TSQLResult* aResult;
- aResult = fServer[kDAQ]->Query(sqlQuery);
+ aResult = fServer[system]->Query(sqlQuery);
if (!aResult) {
- Log(detector, Form("GetDAQFileSources - Can't execute SQL query for id: %s", id));
+ Log(detector, Form("GetFileSources - Can't execute SQL query to %s database for id: %s",
+ GetSystemName(system), id));
return 0;
}
- if (aResult->GetRowCount() == 0) {
+ if (aResult->GetRowCount() == 0)
+ {
Log(detector,
- Form("GetDAQFileSources - No entry in FES table for id: %s", id));
+ Form("GetFileSources - No entry in %s FXS table for id: %s", GetSystemName(system), id));
delete aResult;
return 0;
}
TList *list = new TList();
list->SetOwner(1);
- while((aRow = aResult->Next())){
+ while ((aRow = aResult->Next()))
+ {
- TString daqSource(aRow->GetField(0), aRow->GetFieldLength(0));
- AliDebug(2, Form("daqSource = %s", daqSource.Data()));
- list->Add(new TObjString(daqSource));
+ TString source(aRow->GetField(0), aRow->GetFieldLength(0));
+ AliDebug(2, Form("%s = %s", sourceName.Data(), source.Data()));
+ list->Add(new TObjString(source));
delete aRow;
}
+
delete aResult;
return list;
-
-}
-
-//______________________________________________________________________________________________
-const char* AliShuttle::GetDCSFileName(const char* /*detector*/, const char* /*id*/, const char* /*source*/){
-// Retrieves a file from the DCS FES.
-
-return "You're in DCS";
-
}
//______________________________________________________________________________________________
-TList* AliShuttle::GetDCSFileSources(const char* /*detector*/, const char* /*id*/){
-// Retrieves a file from the DCS FES.
-
-return NULL;
-
-}
+Bool_t AliShuttle::Connect(Int_t system)
+{
+// Connect to MySQL Server of the system's FXS MySQL databases
+// DAQ Logbook, Shuttle Logbook and DAQ FXS db are on the same host
-//______________________________________________________________________________________________
-const char* AliShuttle::GetHLTFileName(const char* /*detector*/, const char* /*id*/, const char* /*source*/){
-// Retrieves a file from the HLT FES.
+ // check connection: if already connected return
+ if(fServer[system] && fServer[system]->IsConnected()) return kTRUE;
-return "You're in HLT";
+ TString dbHost, dbUser, dbPass, dbName;
-}
+ if (system < 3) // FXS db servers
+ {
+ dbHost = Form("mysql://%s:%d", fConfig->GetFXSdbHost(system), fConfig->GetFXSdbPort(system));
+ dbUser = fConfig->GetFXSdbUser(system);
+ dbPass = fConfig->GetFXSdbPass(system);
+ dbName = fConfig->GetFXSdbName(system);
+ } else { // Run & Shuttle logbook servers
+ // TODO Will the Shuttle logbook server be the same as the Run logbook server ???
+ dbHost = Form("mysql://%s:%d", fConfig->GetDAQlbHost(), fConfig->GetDAQlbPort());
+ dbUser = fConfig->GetDAQlbUser();
+ dbPass = fConfig->GetDAQlbPass();
+ dbName = fConfig->GetDAQlbDB();
+ }
-//______________________________________________________________________________________________
-TList* AliShuttle::GetHLTFileSources(const char* /*detector*/, const char* /*id*/){
-// Retrieves a file from the HLT FES.
+ fServer[system] = TSQLServer::Connect(dbHost.Data(), dbUser.Data(), dbPass.Data());
+ if (!fServer[system] || !fServer[system]->IsConnected()) {
+ if(system < 3)
+ {
+ AliError(Form("Can't establish connection to FXS database for %s",
+ AliShuttleInterface::GetSystemName(system)));
+ } else {
+ AliError("Can't establish connection to Run logbook.");
+ }
+ if(fServer[system]) delete fServer[system];
+ return kFALSE;
+ }
-return NULL;
+ // Get tables
+ TSQLResult* aResult=0;
+ switch(system){
+ case kDAQ:
+ aResult = fServer[kDAQ]->GetTables(dbName.Data());
+ break;
+ case kDCS:
+ aResult = fServer[kDCS]->GetTables(dbName.Data());
+ break;
+ case kHLT:
+ aResult = fServer[kHLT]->GetTables(dbName.Data());
+ break;
+ default:
+ aResult = fServer[3]->GetTables(dbName.Data());
+ break;
+ }
+ delete aResult;
+ return kTRUE;
}
//______________________________________________________________________________________________
-Bool_t AliShuttle::UpdateDAQTable()
+Bool_t AliShuttle::UpdateTable()
{
-// Update DAQ table filling time_processed field in all rows corresponding to current run and detector
+// Update FXS table filling time_processed field in all rows corresponding to current run and detector
- // check connection, in case connect
- if(!Connect(kDAQ)){
- Log(fCurrentDetector, "UpdateDAQTable - Couldn't connect to DAQ Logbook");
- return kFALSE;
- }
+ Bool_t result = kTRUE;
- TTimeStamp now; // now
+ for (UInt_t system=0; system<3; system++)
+ {
+ if(!fFXSCalled[system]) continue;
- // Loop on FES list entries
- TIter iter(&fFESlist[kDAQ]);
- TObjString *aFESentry=0;
- while((aFESentry = dynamic_cast<TObjString*> (iter.Next()))){
- TString aFESentrystr = aFESentry->String();
- TObjArray *aFESarray = aFESentrystr.Tokenize("_!?!_");
- if(!aFESarray || aFESarray->GetEntries() != 2 ) {
- Log(fCurrentDetector, Form("UpdateDAQTable - error updating FES entry. Check string: <%s>",
- aFESentrystr.Data()));
- if(aFESarray) delete aFESarray;
- return kFALSE;
+ // check connection, in case connect
+ if (!Connect(system))
+ {
+ Log(fCurrentDetector, Form("UpdateTable - Couldn't connect to %s FXS database", GetSystemName(system)));
+ result = kFALSE;
+ continue;
}
- const char* fileId = ((TObjString*) aFESarray->At(0))->GetName();
- const char* daqSource = ((TObjString*) aFESarray->At(1))->GetName();
- TString whereClause = Form("where run=%d and detector=\"%s\" and fileId=\"%s\" and DAQsource=\"%s\";",
- GetCurrentRun(), GetDetCode(fCurrentDetector), fileId, daqSource);
- delete aFESarray;
+ TTimeStamp now; // now
+
+ // Loop on FXS list entries
+ TIter iter(&fFXSlist[system]);
+ TObjString *aFXSentry=0;
+ while ((aFXSentry = dynamic_cast<TObjString*> (iter.Next())))
+ {
+ TString aFXSentrystr = aFXSentry->String();
+ TObjArray *aFXSarray = aFXSentrystr.Tokenize("#!?!#");
+ if (!aFXSarray || aFXSarray->GetEntries() != 2 )
+ {
+ Log(fCurrentDetector, Form("UpdateTable - error updating %s FXS entry. Check string: <%s>",
+ GetSystemName(system), aFXSentrystr.Data()));
+ if(aFXSarray) delete aFXSarray;
+ result = kFALSE;
+ continue;
+ }
+ const char* fileId = ((TObjString*) aFXSarray->At(0))->GetName();
+ const char* source = ((TObjString*) aFXSarray->At(1))->GetName();
+
+ TString whereClause;
+ if (system == kDAQ)
+ {
+ whereClause = Form("where run=%d and detector=\"%s\" and fileId=\"%s\" and DAQsource=\"%s\";",
+ GetCurrentRun(), fCurrentDetector.Data(), fileId, source);
+ }
+ else if (system == kDCS)
+ {
+ whereClause = Form("where run=%d and detector=\"%s\" and fileId=\"%s\";",
+ GetCurrentRun(), fCurrentDetector.Data(), fileId);
+ }
+ else if (system == kHLT)
+ {
+ whereClause = Form("where run=%d and detector=\"%s\" and fileId=\"%s\" and DDLnumbers=\"%s\";",
+ GetCurrentRun(), fCurrentDetector.Data(), fileId, source);
+ }
- TString sqlQuery = Form("update logbook_fs set time_processed=%d %s", now.GetSec(), whereClause.Data());
+ delete aFXSarray;
- AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
+ TString sqlQuery = Form("update %s set time_processed=%d %s", fConfig->GetFXSdbTable(system),
+ now.GetSec(), whereClause.Data());
- // Query execution
- TSQLResult* aResult;
- aResult = dynamic_cast<TSQLResult*> (fServer[kDAQ]->Query(sqlQuery));
- if (!aResult) {
- Log(fCurrentDetector, Form("UpdateDAQTable - Can't execute SQL query <%s>", sqlQuery.Data()));
- return kFALSE;
+ AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
+
+ // Query execution
+ TSQLResult* aResult;
+ aResult = dynamic_cast<TSQLResult*> (fServer[system]->Query(sqlQuery));
+ if (!aResult)
+ {
+ Log(fCurrentDetector, Form("UpdateTable - %s db: can't execute SQL query <%s>",
+ GetSystemName(system), sqlQuery.Data()));
+ result = kFALSE;
+ continue;
+ }
+ delete aResult;
}
- delete aResult;
}
- return kTRUE;
+ return result;
}
-
//______________________________________________________________________________________________
Bool_t AliShuttle::UpdateShuttleLogbook(const char* detector, const char* status)
{
-// Update Shuttle logbook filling detector or shuttle_done column
-// ex. of usage: UpdateShuttleLogbook("PHOS", "DONE") or UpdateShuttleLogbook("shuttle_done")
+ //
+ // Update Shuttle logbook filling detector or shuttle_done column
+ // ex. of usage: UpdateShuttleLogbook("PHOS", "DONE") or UpdateShuttleLogbook("shuttle_done")
+ //
// check connection, in case connect
- if(!Connect(kDAQ)){
+ if(!Connect(3)){
Log("SHUTTLE", "UpdateShuttleLogbook - Couldn't connect to DAQ Logbook.");
return kFALSE;
}
TString detName(detector);
TString setClause;
- if(detName == "shuttle_done") {
+ if(detName == "shuttle_done")
+ {
setClause = "set shuttle_done=1";
+
+ // Send the information to ML
+ TMonaLisaText mlStatus("SHUTTLE_status", "Done");
+
+ TList mlList;
+ mlList.Add(&mlStatus);
+
+ fMonaLisa->SendParameters(&mlList);
} else {
- TString detCode = GetDetCode(detector);
- if(detCode.IsNull()) {
- Log("SHUTTLE", Form("UpdateShuttleLogbook - Unknown detector %s", detector));
- return kFALSE;
- }
TString statusStr(status);
if(statusStr.Contains("done", TString::kIgnoreCase) ||
statusStr.Contains("failed", TString::kIgnoreCase)){
- setClause = Form("set %s=\"%s\"", detCode.Data(), status);
+ setClause = Form("set %s=\"%s\"", detector, status);
} else {
Log("SHUTTLE",
Form("UpdateShuttleLogbook - Invalid status <%s> for detector %s",
TString whereClause = Form("where run=%d", GetCurrentRun());
- TString sqlQuery = Form("update logbook_shuttle %s %s",
- setClause.Data(), whereClause.Data());
+ TString sqlQuery = Form("update %s %s %s",
+ fConfig->GetShuttlelbTable(), setClause.Data(), whereClause.Data());
AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
// Query execution
TSQLResult* aResult;
- aResult = dynamic_cast<TSQLResult*> (fServer[kDAQ]->Query(sqlQuery));
+ aResult = dynamic_cast<TSQLResult*> (fServer[3]->Query(sqlQuery));
if (!aResult) {
Log("SHUTTLE", Form("UpdateShuttleLogbook - Can't execute query <%s>", sqlQuery.Data()));
return kFALSE;
return fLogbookEntry ? fLogbookEntry->GetEndTime() : 0;
}
-//______________________________________________________________________________________________
-const char* AliShuttle::GetDetCode(const char* detector){
-// Return detector code
-
- for(UInt_t iDet=0; iDet < kNDetectors; iDet++){
- if(!strcmp(fgkDetectorName[iDet], detector)) return fgkDetectorCode[iDet];
- }
-
- AliErrorClass(Form("Unknown detector: %s",detector));
- return 0;
-}
-
-//______________________________________________________________________________________________
-const char* AliShuttle::GetDetCode(UInt_t detPos){
-// Return detector code
-
- if( detPos >= kNDetectors) {
- AliErrorClass(Form("Invalid parameter: %d", detPos));
- return 0;
- }
- return fgkDetectorCode[detPos];
-}
-
-//______________________________________________________________________________________________
-const Int_t AliShuttle::GetDetPos(const char* detCode){
-// Return detector position in the detector code array
-
- for(UInt_t iDet=0; iDet < kNDetectors; iDet++){
- if(!strcmp(fgkDetectorCode[iDet], detCode)) return iDet;
- }
- return -1;
-}
-
//______________________________________________________________________________________________
void AliShuttle::Log(const char* detector, const char* message)
{
// Fill log string with a message
- void* dir = gSystem->OpenDirectory(fgkShuttleLogDir);
+ void* dir = gSystem->OpenDirectory(GetShuttleLogDir());
if (dir == NULL) {
- if (gSystem->mkdir(fgkShuttleLogDir, kTRUE)) {
- AliError(Form("Can't open directory <%s>", fgkShuttleTempDir));
+ if (gSystem->mkdir(GetShuttleLogDir(), kTRUE)) {
+ AliError(Form("Can't open directory <%s>", GetShuttleLogDir()));
return;
}
gSystem->FreeDirectory(dir);
}
- TString toLog = Form("%s: %s - ", TTimeStamp(time(0)).AsString("s"), detector);
- if(GetCurrentRun()>=0 ) toLog += Form("run %d - ", GetCurrentRun());
+ TString toLog = Form("%s (%d): %s - ", TTimeStamp(time(0)).AsString("s"), getpid(), detector);
+ if (GetCurrentRun() >= 0)
+ toLog += Form("run %d - ", GetCurrentRun());
toLog += Form("%s", message);
AliInfo(toLog.Data());
TString fileName;
- fileName.Form("%s/%s.log", fgkShuttleLogDir, detector);
+ if (GetCurrentRun() >= 0)
+ fileName.Form("%s/%s_%d.log", GetShuttleLogDir(), detector, GetCurrentRun());
+ else
+ fileName.Form("%s/%s.log", GetShuttleLogDir(), detector);
+
gSystem->ExpandPathName(fileName);
ofstream logFile;
logFile.close();
}
-
//______________________________________________________________________________________________
Bool_t AliShuttle::Collect(Int_t run)
{
- //
- // Collects conditions data for the given run.
- //
+//
+// Collects conditions data for all UNPROCESSED run written to DAQ LogBook in case of run = -1 (default)
+// If a dedicated run is given this run is processed
+//
+// In operational mode, this is the Shuttle function triggered by the EOR signal.
+//
- AliInfo(Form("Collecting conditions data for run %d", run));
+ if (run == -1)
+ Log("SHUTTLE","Collect - Shuttle called. Collecting conditions data for unprocessed runs");
+ else
+ Log("SHUTTLE", Form("Collect - Shuttle called. Collecting conditions data for run %d", run));
- TString whereClause("where run=");
- whereClause += run;
+ SetLastAction("Starting");
- TObjArray dateEntries;
- if (!QueryShuttleLogbook(whereClause, dateEntries)) {
- AliError("Can't retrieve entries from Shuttle logbook!");
- return kFALSE;
- }
+ TString whereClause("where shuttle_done=0");
+ if (run != -1)
+ whereClause += Form(" and run=%d", run);
- if (!dateEntries.GetEntriesFast()) {
- AliError(Form("Retrieval of parameters for run %d failed!", run));
+ TObjArray shuttleLogbookEntries;
+ if (!QueryShuttleLogbook(whereClause, shuttleLogbookEntries))
+ {
+ Log("SHUTTLE", "Collect - Can't retrieve entries from Shuttle logbook");
return kFALSE;
}
- if (dateEntries.GetEntriesFast() > 1) {
- AliError(Form("There is more than one entry for run <%d> in Shuttle logbook!", run));
- return kFALSE;
+ if (shuttleLogbookEntries.GetEntries() == 0)
+ {
+ if (run == -1)
+ Log("SHUTTLE","Collect - Found no UNPROCESSED runs in Shuttle logbook");
+ else
+ Log("SHUTTLE", Form("Collect - Run %d is already DONE "
+ "or it does not exist in Shuttle logbook", run));
+ return kTRUE;
}
- if (!RetrieveConditionsData(dateEntries)) {
- AliError("An error occured during conditions data retrieval!");
+ for (UInt_t iDet=0; iDet<NDetectors(); iDet++)
+ fFirstUnprocessed[iDet] = kTRUE;
+
+ if (run != -1)
+ {
+ // query Shuttle logbook for earlier runs, check if some detectors are unprocessed,
+ // flag them into fFirstUnprocessed array
+ TString whereClause(Form("where shuttle_done=0 and run < %d", run));
+ TObjArray tmpLogbookEntries;
+ if (!QueryShuttleLogbook(whereClause, tmpLogbookEntries))
+ {
+ Log("SHUTTLE", "Collect - Can't retrieve entries from Shuttle logbook");
+ return kFALSE;
+ }
+
+ TIter iter(&tmpLogbookEntries);
+ AliShuttleLogbookEntry* anEntry = 0;
+ while ((anEntry = dynamic_cast<AliShuttleLogbookEntry*> (iter.Next())))
+ {
+ for (UInt_t iDet=0; iDet<NDetectors(); iDet++)
+ {
+ if (anEntry->GetDetectorStatus(iDet) == AliShuttleLogbookEntry::kUnprocessed)
+ {
+ AliDebug(2, Form("Run %d: setting %s as \"not first time unprocessed\"",
+ anEntry->GetRun(), GetDetName(iDet)));
+ fFirstUnprocessed[iDet] = kFALSE;
+ }
+ }
+
+ }
+
+ }
+
+ if (!RetrieveConditionsData(shuttleLogbookEntries))
+ {
+ Log("SHUTTLE", "Collect - Process of at least one run failed");
return kFALSE;
}
+ Log("SHUTTLE", "Collect - Requested run(s) successfully processed");
return kTRUE;
}
//______________________________________________________________________________________________
-Bool_t AliShuttle::CollectNew()
+Bool_t AliShuttle::RetrieveConditionsData(const TObjArray& dateEntries)
{
- //
- // Collects conditions data for all UNPROCESSED run written to DAQ LogBook.
- // In operational mode, this is the Shuttle function triggered by the EOR signal.
- //
+// Retrieve conditions data for all runs that aren't processed yet
- Log("SHUTTLE","CollectNew - Shuttle called. Collecting conditions data for unprocessed runs");
+ Bool_t hasError = kFALSE;
- TString whereClause("where shuttle_done=0");
+ TIter iter(&dateEntries);
+ AliShuttleLogbookEntry* anEntry;
- TObjArray shuttleLogbookEntries;
- if (!QueryShuttleLogbook(whereClause, shuttleLogbookEntries)) {
- Log("SHUTTLE", "CollectNew - Can't retrieve entries from Shuttle logbook");
- return kFALSE;
+ while ((anEntry = (AliShuttleLogbookEntry*) iter.Next())){
+ if (!Process(anEntry)){
+ hasError = kTRUE;
+ }
+
+ // clean SHUTTLE temp directory
+ TString command = Form("rm -f %s/*.shuttle", GetShuttleTempDir());
+ gSystem->Exec(command.Data());
}
- if (!RetrieveConditionsData(shuttleLogbookEntries)) {
- Log("SHUTTLE", "CollectNew - Process of at least one run failed");
- return kFALSE;
+ return hasError == kFALSE;
+}
+
+//______________________________________________________________________________________________
+ULong_t AliShuttle::GetTimeOfLastAction() const
+{
+ ULong_t tmp;
+
+ fMonitoringMutex->Lock();
+
+ tmp = fLastActionTime;
+
+ fMonitoringMutex->UnLock();
+
+ return tmp;
+}
+
+//______________________________________________________________________________________________
+const TString AliShuttle::GetLastAction() const
+{
+ // returns a string description of the last action
+
+ TString tmp;
+
+ fMonitoringMutex->Lock();
+
+ tmp = fLastAction;
+
+ fMonitoringMutex->UnLock();
+
+ return tmp;
+}
+
+//______________________________________________________________________________________________
+void AliShuttle::SetLastAction(const char* action)
+{
+ // updates the monitoring variables
+
+ fMonitoringMutex->Lock();
+
+ fLastAction = action;
+ fLastActionTime = time(0);
+
+ fMonitoringMutex->UnLock();
+}
+
+//______________________________________________________________________________________________
+const char* AliShuttle::GetRunParameter(const char* param)
+{
+// returns run parameter read from DAQ logbook
+
+ if(!fLogbookEntry) {
+ AliError("No logbook entry!");
+ return 0;
}
- return kTRUE;
+ return fLogbookEntry->GetRunParameter(param);
}
//______________________________________________________________________________________________
-Bool_t AliShuttle::CollectAll()
+AliCDBEntry* AliShuttle::GetFromOCDB(const AliCDBPath& path)
{
- //
- // Collects conditions data for all runs (even if they're already done!) written in Shuttle LogBook.
- //
+// returns obiect from OCDB valid for current run
- AliInfo("Collecting conditions data for all runs ...");
+ AliCDBStorage *sto = AliCDBManager::Instance()->GetStorage(fgkMainCDB);
+ if (!sto)
+ {
+ Log("SHUTTLE", "GetFromOCDB - Cannot activate main OCDB for query!");
+ return 0;
+ }
- TObjArray dateEntries;
- if (!QueryShuttleLogbook("", dateEntries)) {
- AliError("Can't retrieve entries from Shuttle logbook");
- return kFALSE;
+ return dynamic_cast<AliCDBEntry*> (sto->Get(path, GetCurrentRun()));
+}
+
+//______________________________________________________________________________________________
+Bool_t AliShuttle::SendMail()
+{
+// sends a mail to the subdetector expert in case of preprocessor error
+
+ void* dir = gSystem->OpenDirectory(GetShuttleLogDir());
+ if (dir == NULL)
+ {
+ if (gSystem->mkdir(GetShuttleLogDir(), kTRUE))
+ {
+ AliError(Form("Can't open directory <%s>", GetShuttleLogDir()));
+ return kFALSE;
+ }
+
+ } else {
+ gSystem->FreeDirectory(dir);
+ }
+
+ TString bodyFileName;
+ bodyFileName.Form("%s/mail.body", GetShuttleLogDir());
+ gSystem->ExpandPathName(bodyFileName);
+
+ ofstream mailBody;
+ mailBody.open(bodyFileName, ofstream::out);
+
+ if (!mailBody.is_open())
+ {
+ AliError(Form("Could not open mail body file %s", bodyFileName.Data()));
+ return kFALSE;
+ }
+
+ TString to="";
+ TIter iterExperts(fConfig->GetResponsibles(fCurrentDetector));
+ TObjString *anExpert=0;
+ while ((anExpert = (TObjString*) iterExperts.Next()))
+ {
+ to += Form("%s,", anExpert->GetName());
}
+ to.Remove(to.Length()-1);
+ AliDebug(2, Form("to: %s",to.Data()));
- if (!RetrieveConditionsData(dateEntries)) {
- AliError("An error occured during conditions data retrieval!");
+ // TODO this will be removed...
+ if (to.Contains("not_yet_set")) {
+ AliInfo("List of detector responsibles not yet set!");
return kFALSE;
}
- return kTRUE;
-}
+ TString cc="alberto.colla@cern.ch";
+
+ TString subject = Form("%s Shuttle preprocessor error in run %d !",
+ fCurrentDetector.Data(), GetCurrentRun());
+ AliDebug(2, Form("subject: %s", subject.Data()));
+
+ TString body = Form("Dear %s expert(s), \n\n", fCurrentDetector.Data());
+ body += Form("SHUTTLE just detected that your preprocessor "
+ "exited with ERROR state in run %d!!\n\n", GetCurrentRun());
+ body += Form("Please check %s status on the web page asap!\n\n", fCurrentDetector.Data());
+ body += Form("The last 10 lines of %s log file are following:\n\n");
+
+ AliDebug(2, Form("Body begin: %s", body.Data()));
+
+ mailBody << body.Data();
+ mailBody.close();
+ mailBody.open(bodyFileName, ofstream::out | ofstream::app);
+
+ TString logFileName = Form("%s/%s_%d.log", GetShuttleLogDir(), fCurrentDetector.Data(), GetCurrentRun());
+ TString tailCommand = Form("tail -n 10 %s >> %s", logFileName.Data(), bodyFileName.Data());
+ if (gSystem->Exec(tailCommand.Data()))
+ {
+ mailBody << Form("%s log file not found ...\n\n", fCurrentDetector.Data());
+ }
+ TString endBody = Form("------------------------------------------------------\n\n");
+ endBody += Form("In case of problems please contact the SHUTTLE core team.\n\n");
+ endBody += "Please do not answer this message directly, it is automatically generated.\n\n";
+ endBody += "Sincerely yours,\n\n \t\t\tthe SHUTTLE\n";
+
+ AliDebug(2, Form("Body end: %s", endBody.Data()));
+
+ mailBody << endBody.Data();
+
+ mailBody.close();
+
+ // send mail!
+ TString mailCommand = Form("mail -s \"%s\" -c %s %s < %s",
+ subject.Data(),
+ cc.Data(),
+ to.Data(),
+ bodyFileName.Data());
+ AliDebug(2, Form("mail command: %s", mailCommand.Data()));
+
+ Bool_t result = gSystem->Exec(mailCommand.Data());
+
+ return result == 0;
+}
//______________________________________________________________________________________________
-Bool_t AliShuttle::RetrieveConditionsData(const TObjArray& dateEntries)
+void AliShuttle::SetRunType()
{
-// Retrieve conditions data for all runs that aren't processed yet
+// Gets run type from logbook and fills current Shuttle logbook entry
- Bool_t hasError = kFALSE;
+ // check connection, in case connect
+ if(!Connect(3)){
+ Log("SHUTTLE", "GetRunType - Couldn't connect to DAQ Logbook.");
+ return;
+ }
- TIter iter(&dateEntries);
- AliShuttleLogbookEntry* anEntry;
+ TString sqlQuery = Form("select detector,run_type from %s where run_number=%d",
+ fConfig->GetRunTypelbTable(), GetCurrentRun());
- while ((anEntry = (AliShuttleLogbookEntry*) iter.Next())){
- if (!Process(anEntry)){
- hasError = kTRUE;
- }
+ AliDebug(2, Form("SQL query: \n%s",sqlQuery.Data()));
+
+ // Query execution
+ TSQLResult* aResult;
+ aResult = dynamic_cast<TSQLResult*> (fServer[3]->Query(sqlQuery));
+ if (!aResult) {
+ Log("SHUTTLE", Form("GetRunType - Can't execute query <%s>", sqlQuery.Data()));
+ return;
}
- return hasError == kFALSE;
+ TSQLRow* aRow;
+ while ((aRow = aResult->Next())) {
+ TString det(aRow->GetField(0), aRow->GetFieldLength(0));
+ TString runType(aRow->GetField(1), aRow->GetFieldLength(1));
+
+ fLogbookEntry->SetRunType(det, runType);
+ delete aRow;
+ }
+
+ delete aResult;
+
+ return;
+
+}
+
+//______________________________________________________________________________________________
+const char* AliShuttle::GetRunType(const char* detCode)
+{
+// returns run type read from "run type" logbook
+
+ if(!fLogbookEntry) {
+ AliError("No logbook entry!");
+ return 0;
+ }
+
+ return fLogbookEntry->GetRunType(detCode);
+}
+
+//______________________________________________________________________________________________
+void AliShuttle::SetShuttleTempDir(const char* tmpDir)
+{
+// sets Shuttle temp directory
+
+ fgkShuttleTempDir = gSystem->ExpandPathName(tmpDir);
+}
+
+//______________________________________________________________________________________________
+void AliShuttle::SetShuttleLogDir(const char* logDir)
+{
+// sets Shuttle log directory
+
+ fgkShuttleLogDir = gSystem->ExpandPathName(logDir);
}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff