Bugfix: lowercase b should be upper case B for component id: TPCClusterFinder32Bit

[u/mrichter/AliRoot.git] / T0 / AliT0Preprocessor.cxx

diff --git a/T0/AliT0Preprocessor.cxx b/T0/AliT0Preprocessor.cxx
index 61cda66a5831b85acce5cd2c2149574fd8fed072..fb753baccf84d6c940be3b35ccde93bd3de06ce9 100644 (file)
--- a/T0/AliT0Preprocessor.cxx
+++ b/T0/AliT0Preprocessor.cxx
@@ -17,7 +17,7 @@
 $Log: AliT0Preprocessor.cxx,v $
 Revision 1.8  2007/12/07 15:22:51  alla
 bug fixed by Alberto
-
+ 
 Revision 1.7  2007/12/06 16:35:24  alla
 new bugs fixed by Tomek
 
@@ -61,6 +61,9 @@ AliT0Preprocessor::AliT0Preprocessor(AliShuttleInterface* shuttle) :
   fData(0)
 {
   //constructor
+  AddRunType("PHYSICS");
+  AddRunType("STANDALONE");
+  AddRunType("LASER");
 }
 //____________________________________________________
 
@@ -77,7 +80,7 @@ void AliT0Preprocessor::Initialize(Int_t run, UInt_t startTime, UInt_t endTime)
   // Creates AliT0DataDCS object
   AliPreprocessor::Initialize(run, startTime, endTime);
   AliInfo(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run, TTimeStamp(startTime).AsString(), TTimeStamp(endTime).AsString()));
-  fData = new AliT0DataDCS(fRun, fStartTime, fEndTime);
+  fData = new AliT0DataDCS(fRun, fStartTime, fEndTime, GetStartTimeDCSQuery(), GetEndTimeDCSQuery());
 }
 //____________________________________________________
 
@@ -86,8 +89,11 @@ Bool_t AliT0Preprocessor::ProcessDCS(){
        TString runType = GetRunType();
        Log(Form("ProcessDCS - RunType: %s",runType.Data()));
 
-       if((runType == "STANDALONE")||(runType == "PHYSICS")){
-               return kFALSE;
+       if((runType == "STANDALONE")||
+          (runType == "PHYSICS")||
+          (runType == "LASER")){
+         //            return kFALSE;
+               return kTRUE;
        }else{
        return kFALSE;
        }
@@ -120,7 +126,7 @@ UInt_t AliT0Preprocessor::ProcessDCSDataPoints(TMap* dcsAliasMap){
             metaDataDCS.SetResponsible("Tomasz Malkiewicz");
             metaDataDCS.SetComment("This preprocessor fills an AliTODataDCS object.");
             AliInfo("Storing DCS Data");
-            resultDCSStore = Store("Calib","DCSData",fData, &metaDataDCS);
+            resultDCSStore = StoreReferenceData("Calib","DCSData",fData, &metaDataDCS);
             if (!resultDCSStore)
             {
               Log("Some problems occurred while storing DCS data results in ReferenceDB");
@@ -134,7 +140,7 @@ UInt_t AliT0Preprocessor::ProcessDCSDataPoints(TMap* dcsAliasMap){
 
 UInt_t AliT0Preprocessor::ProcessLaser(){
        // Processing data from DAQ Standalone run
-       Log("Processing Laser calibration");
+       Log("Processing Laser calibration - Walk Correction");
        
        Bool_t resultLaser=kFALSE;
        //processing DAQ
@@ -157,6 +163,7 @@ UInt_t AliT0Preprocessor::ProcessLaser(){
                 metaData.SetComment("Walk correction from laser runs.");
                resultLaser=Store("Calib","Slewing_Walk", laser, &metaData, 0, 1);
                 delete laser;
+               Log(Form("resultLaser = %d",resultLaser));
               }
               else
               {
@@ -181,7 +188,7 @@ UInt_t AliT0Preprocessor::ProcessPhysics(){
        //Processing data from DAQ Physics run
        Log("Processing Physics");
 
-       Bool_t resultOnline=kFALSE;  
+       Bool_t resultOnline=kFALSE; 
        //processing DAQ
        TList* listPhys = GetFileSources(kDAQ, "PHYSICS");
         if (listPhys)
@@ -201,17 +208,19 @@ UInt_t AliT0Preprocessor::ProcessPhysics(){
                 metaData.SetResponsible("Tomek&Michal");
                 metaData.SetComment("Time equalizing result.");
                 resultOnline = Store("Calib","TimeDelay", online, &metaData, 0, 1);
+               Log(Form("resultOnline = %d",resultOnline));
                 delete online;
               }
-              else
+               else
               {
                 Log(Form("Could not find file with Id PHYSICS in source %s!", sourcePhys->GetName()));
                 return 1;
               }
+              
             }
             if (!resultOnline)
             {
-              Log("No Laser Data stored");
+              Log("No Data stored");
               return 4;//return error code for failure in storing OCDB Data
             }
           } else {
@@ -222,6 +231,53 @@ UInt_t AliT0Preprocessor::ProcessPhysics(){
 }
 //____________________________________________________
 
+UInt_t AliT0Preprocessor::ProcessCosmic(){
+       //Processing data from DAQ Physics run
+       Log("Processing Laser Physics");
+
+       Bool_t resultLaserOnline=kFALSE; 
+       //processing DAQ
+       TList* listLaser = GetFileSources(kDAQ, "COSMIC");
+        if (listLaser)
+          {
+            TIter iter(listLaser);
+            TObjString *sourceLaser;
+            while ((sourceLaser = dynamic_cast<TObjString *> (iter.Next())))
+            {
+              const char *fileLaser = GetFile(kDAQ, "COSMIC", sourceLaser->GetName());
+              if (fileLaser)
+              {
+                AliT0CalibTimeEq *onlineLaser = new AliT0CalibTimeEq();
+                onlineLaser->Reset();
+                onlineLaser->ComputeOnlineParams(fileLaser);
+                AliCDBMetaData metaData;
+                metaData.SetBeamPeriod(0);
+                metaData.SetResponsible("Tomek&Michal");
+                metaData.SetComment("Time equalizing result.");
+                resultLaserOnline = Store("Calib","LaserTimeDelay", onlineLaser, &metaData, 0, 1);
+               Log(Form("resultLaserOnline = %d",resultLaserOnline));
+                delete onlineLaser;
+              }
+               else
+              {
+                Log(Form("Could not find file with Id COSMIC in source %s!", sourceLaser->GetName()));
+                return 0;
+              }
+              
+            }
+            if (!resultLaserOnline)
+            {
+              Log("No Laser Data stored");
+              return 0;//return error code for failure in storing OCDB Data
+            }
+          } else {
+               Log("No sources found for id COSMIC!");
+               return 0;
+         }
+       return 0;
+}
+//____________________________________________________
+
 UInt_t AliT0Preprocessor::Process(TMap* dcsAliasMap )
 {
   // T0 preprocessor return codes:
@@ -239,21 +295,32 @@ UInt_t AliT0Preprocessor::Process(TMap* dcsAliasMap )
        Log(Form("RunType: %s",runType.Data()));
        //processing
        if(runType == "STANDALONE"){
-               Int_t iresultLaser = ProcessLaser();
-                       if(dcsDP==1){
-                       Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
-                       return iresultDCS;
-               }
-               return iresultLaser;
+         if(dcsDP==1){
+           Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
+           return iresultDCS;
+         }
        }
-       else if(runType == "PHYSICS"){
-               Int_t iresultPhysics = ProcessPhysics();
-               if(dcsDP==1){
-                       Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
-                       return iresultDCS;
-               }
-               return iresultPhysics; 
-       }       
-
-  return 0;
+       if(runType == "LASER"){
+         Int_t iresultLaser = ProcessLaser();
+         if(dcsDP==1){
+            Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
+            return iresultDCS;
+          }
+         Log(Form("iresultLaser = %d",iresultLaser));
+         return iresultLaser;
+       }
+       else if(runType == "PHYSICS"){
+         Int_t iresultPhysics = ProcessPhysics();
+        //      Int_t iresultCosmic = ProcessCosmic();
+         if(dcsDP==1){
+           Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
+           return iresultDCS;
+         }
+         Log(Form("iresultPhysics = %d",iresultPhysics));
+         return iresultPhysics; 
+         //            Log(Form("iresultPhysics =iresultCosmic %d",iresultCosmic));
+         //    return iresultCosmic; 
+       }       
+       
+       return 0;
 }