added HOMER library from PubSub package HLT-stable-20070905.141318 (rev. 2375)

[u/mrichter/AliRoot.git] / STEER / AliGRPPreprocessor.cxx

diff --git a/STEER/AliGRPPreprocessor.cxx b/STEER/AliGRPPreprocessor.cxx
index 8b1346203b5694b3a83743e4a87f1c16ca392d5a..dae280fd692c600249261c1b63feb78fbfbcb1e3 100644 (file)
--- a/STEER/AliGRPPreprocessor.cxx
+++ b/STEER/AliGRPPreprocessor.cxx
@@ -74,22 +74,41 @@ void AliGRPPreprocessor::Initialize(Int_t run, UInt_t startTime, UInt_t endTime)
 UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   // process data retrieved by the Shuttle
   const char* timeStart = GetRunParameter("time_start");
+  UInt_t iStartTime = atoi(timeStart);
   const char* timeEnd = GetRunParameter("time_end");
+  UInt_t iStopTime = atoi(timeEnd);
   const char* beamEnergy = GetRunParameter("beamEnergy");
   const char* beamType = GetRunParameter("beamType");
   const char* numberOfDetectors = GetRunParameter("numberOfDetectors");
   const char* detectorMask = GetRunParameter("detectorMask");
   const char* lhcPeriod = GetRunParameter("LHCperiod");
 
+  TList* list = GetFileSources(kDAQ);
+  TIterator* iter = list->MakeIterator();
+  TObject* obj = 0;
+  while ((obj = iter->Next()))
+  {
+       TObjString* objStr = dynamic_cast<TObjString*> (obj);
+       if (objStr)
+       {
+               Log(Form("Found source %s", objStr->String().Data()));
+               TList* list2 = GetFileIDs(kDAQ, objStr->String());
+               list2->Print();
+               delete list2;
+       }
+   }
+   delete iter;
+   delete list;  
+  
   //===========//
   //DCS data points
   //===========//
   TObjArray *aliasLHCState = (TObjArray *)valueMap->GetValue("LHCState");
   if(!aliasLHCState) {
     Log(Form("LHCState not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs1 = new AliGRPDCS(aliasLHCState);
+  AliGRPDCS *dcs1 = new AliGRPDCS(aliasLHCState,iStartTime,iStopTime);
   TString sLHCState = dcs1->ProcessDCS(3);  
   if (sLHCState) {
     Log(Form("<LHCState> for run %d: %s",fRun, sLHCState.Data()));
@@ -100,9 +119,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasLHCPeriod = (TObjArray *)valueMap->GetValue("LHCPeriod");
   if(!aliasLHCPeriod) {
     Log(Form("LHCPeriod not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs2 = new AliGRPDCS(aliasLHCPeriod);
+  AliGRPDCS *dcs2 = new AliGRPDCS(aliasLHCPeriod,iStartTime,iStopTime);
   TString sLHCPeriod = dcs2->ProcessDCS(3);  
   if (sLHCPeriod) {
     Log(Form("<LHCPeriod> for run %d: %s",fRun, sLHCPeriod.Data()));
@@ -113,9 +132,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasLHCLuminosity = (TObjArray *)valueMap->GetValue("LHCLuminosity");
   if(!aliasLHCLuminosity) {
     Log(Form("LHCLuminosity not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs3 = new AliGRPDCS(aliasLHCLuminosity);
+  AliGRPDCS *dcs3 = new AliGRPDCS(aliasLHCLuminosity,iStartTime,iStopTime);
   TString sMeanLHCLuminosity = dcs3->ProcessDCS(2);  
   if (sMeanLHCLuminosity) {
     Log(Form("<LHCLuminosity> for run %d: %s",fRun, sMeanLHCLuminosity.Data()));
@@ -126,9 +145,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasBeamIntensity = (TObjArray *)valueMap->GetValue("BeamIntensity");
   if(!aliasBeamIntensity) {
     Log(Form("BeamIntensity not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs4 = new AliGRPDCS(aliasBeamIntensity);
+  AliGRPDCS *dcs4 = new AliGRPDCS(aliasBeamIntensity,iStartTime,iStopTime);
   TString sMeanBeamIntensity = dcs4->ProcessDCS(2);  
   if (sMeanBeamIntensity) {
     Log(Form("<BeamIntensity> for run %d: %s",fRun, sMeanBeamIntensity.Data()));
@@ -139,9 +158,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasL3Current = (TObjArray *)valueMap->GetValue("L3Current");
   if(!aliasL3Current) {
     Log(Form("L3Current not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs5 = new AliGRPDCS(aliasL3Current);
+  AliGRPDCS *dcs5 = new AliGRPDCS(aliasL3Current,iStartTime,iStopTime);
   TString sMeanL3Current = dcs5->ProcessDCS(2);  
   if (sMeanL3Current) {
     Log(Form("<L3Current> for run %d: %s",fRun, sMeanL3Current.Data()));
@@ -152,9 +171,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasL3Polarity = (TObjArray *)valueMap->GetValue("L3Polarity");
   if(!aliasL3Polarity) {
     Log(Form("L3Polarity not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs6 = new AliGRPDCS(aliasL3Polarity);
+  AliGRPDCS *dcs6 = new AliGRPDCS(aliasL3Polarity,iStartTime,iStopTime);
   TString sL3Polarity = dcs6->ProcessDCS(4);  
   if (sL3Polarity) {
     Log(Form("<L3Polarity> for run %d: %s",fRun, sL3Polarity.Data()));
@@ -165,9 +184,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasDipoleCurrent = (TObjArray *)valueMap->GetValue("DipoleCurrent");
   if(!aliasDipoleCurrent) {
     Log(Form("DipoleCurrent not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs7 = new AliGRPDCS(aliasDipoleCurrent);
+  AliGRPDCS *dcs7 = new AliGRPDCS(aliasDipoleCurrent,iStartTime,iStopTime);
   TString sMeanDipoleCurrent = dcs7->ProcessDCS(2);  
   if (sMeanDipoleCurrent) {
     Log(Form("<DipoleCurrent> for run %d: %s",fRun, sMeanDipoleCurrent.Data()));
@@ -178,9 +197,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasDipolePolarity = (TObjArray *)valueMap->GetValue("DipolePolarity");
   if(!aliasDipolePolarity) {
     Log(Form("DipolePolarity not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs8 = new AliGRPDCS(aliasDipolePolarity);
+  AliGRPDCS *dcs8 = new AliGRPDCS(aliasDipolePolarity,iStartTime,iStopTime);
   TString sDipolePolarity = dcs8->ProcessDCS(4);  
   if (sDipolePolarity) {
     Log(Form("<DipolePolarity> for run %d: %s",fRun, sDipolePolarity.Data()));
@@ -191,9 +210,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasCavernTemperature = (TObjArray *)valueMap->GetValue("CavernTemperature");
   if(!aliasCavernTemperature) {
     Log(Form("CavernTemperature not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs9 = new AliGRPDCS(aliasCavernTemperature);
+  AliGRPDCS *dcs9 = new AliGRPDCS(aliasCavernTemperature,iStartTime,iStopTime);
   TString sMeanCavernTemperature = dcs9->ProcessDCS(2);  
   if (sMeanCavernTemperature) {
     Log(Form("<CavernTemperature> for run %d: %s",fRun, sMeanCavernTemperature.Data()));
@@ -204,9 +223,9 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   TObjArray *aliasCavernPressure = (TObjArray *)valueMap->GetValue("CavernPressure");
   if(!aliasCavernPressure) {
     Log(Form("CavernPressure not found!!!"));
-    return 0;
+    return 1;
   }
-  AliGRPDCS *dcs10 = new AliGRPDCS(aliasCavernPressure);
+  AliGRPDCS *dcs10 = new AliGRPDCS(aliasCavernPressure,iStartTime,iStopTime);
   TString sMeanCavernPressure = dcs10->ProcessDCS(2);  
   if (sMeanCavernPressure) {
     Log(Form("<CavernPressure> for run %d: %s",fRun, sMeanCavernPressure.Data()));
@@ -329,11 +348,13 @@ UInt_t AliGRPPreprocessor::Process(TMap* valueMap) {
   AliCDBMetaData md;
   md.SetResponsible("Panos");
   
-  Int_t result=0;
-  result = Store("GRP", "Values", values, &md);
+  Bool_t result = Store("GRP", "Values", values, &md);
   
   delete values;
   
-  return result;
+  if (result)
+    return 0;
+  else
+    return 1;
 }