T0/AliT0PreprocessorCosmic.cxx

   1 /**************************************************************************
   2  * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
   3  *                                                                        *
   4  * Author: The ALICE Off-line Project.                                    *
   5  * Contributors are mentioned in the code where appropriate.              *
   6  *                                                                        *
   7  * Permission to use, copy, modify and distribute this software and its   *
   8  * documentation strictly for non-commercial purposes is hereby granted   *
   9  * without fee, provided that the above copyright notice appears in all   *
  10  * copies and that both the copyright notice and this permission notice   *
  11  * appear in the supporting documentation. The authors make no claims     *
  12  * about the suitability of this software for any purpose. It is          *
  13  * provided "as is" without express or implied warranty.                  *
  14  **************************************************************************/
  15
  16 /*
  17 $Log: AliT0PreprocessorCosmic.cxx,v $
  18 Revision 1.8  2007/12/07 15:22:51  alla
  19 bug fixed by Alberto
  20
  21 Revision 1.7  2007/12/06 16:35:24  alla
  22 new bugs fixed by Tomek
  23
  24 Revision 1.5  2007/11/23 19:28:52  alla
  25 bug fixed
  26
  27 Version 2.1  2007/11/21
  28 Preprocessor storing data to OCDB (T.Malkiewicz)
  29
  30 Version 1.1  2006/10
  31 Preliminary test version (T.Malkiewicz)
  32 */
  33 // T0 preprocessor:
  34 // 1) takes data from DCS and passes it to the class AliTOFDataDCS
  35 // for processing and writes the result to the Reference DB.
  36 // 2) takes data form DAQ (both from Laser Calibration and Physics runs),
  37 // processes it, and stores either to OCDB or to Reference DB.
  38
  39
  40 #include "AliT0PreprocessorCosmic.h"
  41 #include "AliT0DataDCS.h"
  42 #include "AliT0CalibWalk.h"
  43 #include "AliT0CalibTimeEq.h"
  44
  45 #include "AliCDBMetaData.h"
  46 #include "AliDCSValue.h"
  47 #include "AliLog.h"
  48
  49 #include <TTimeStamp.h>
  50 #include <TFile.h>
  51 #include <TObjString.h>
  52 #include <TNamed.h>
  53 #include "AliT0Dqclass.h"
  54
  55
  56 ClassImp(AliT0PreprocessorCosmic)
  57
  58 //____________________________________________________
  59 AliT0PreprocessorCosmic::AliT0PreprocessorCosmic(AliShuttleInterface* shuttle) :
  60   AliPreprocessor("T00", shuttle),
  61   fData(0)
  62 {
  63   //constructor
  64 }
  65 //____________________________________________________
  66
  67 AliT0PreprocessorCosmic::~AliT0PreprocessorCosmic()
  68 {
  69   //destructor
  70   delete fData;
  71   fData = 0;
  72 }
  73 //____________________________________________________
  74
  75 void AliT0PreprocessorCosmic::Initialize(Int_t run, UInt_t startTime, UInt_t endTime)
  76 {
  77   // Creates AliT0DataDCS object
  78   AliPreprocessor::Initialize(run, startTime, endTime);
  79   AliInfo(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run, TTimeStamp(startTime).AsString(), TTimeStamp(endTime).AsString()));
  80   fData = new AliT0DataDCS(fRun, fStartTime, fEndTime);
  81 }
  82 //____________________________________________________
  83
  84 Bool_t AliT0PreprocessorCosmic::ProcessDCS(){
  85         // Check whether DCS should be processed or not...
  86         TString runType = GetRunType();
  87         Log(Form("ProcessDCS - RunType: %s",runType.Data()));
  88
  89         if((runType == "STANDALONE")||(runType == "PHYSICS")){
  90                 return kFALSE;
  91         }else{
  92         return kFALSE;
  93         }
  94 }
  95 //____________________________________________________
  96
  97 UInt_t AliT0PreprocessorCosmic::ProcessDCSDataPoints(TMap* dcsAliasMap){
  98         // Fills data into AliT0DataDCS object
  99         Log("Processing DCS DP");
 100         Bool_t resultDCSMap=kFALSE;
 101         Bool_t resultDCSStore=kFALSE;
 102
 103         if(!dcsAliasMap)
 104         {
 105           Log("No DCS input data");
 106           return 1;
 107         }
 108         else
 109         {
 110           resultDCSMap=fData->ProcessData(*dcsAliasMap);
 111           if(!resultDCSMap)
 112           {
 113             Log("Error when processing DCS data");
 114             return 2;// return error Code for processed DCS data not stored
 115           }
 116           else
 117           {
 118             AliCDBMetaData metaDataDCS;
 119             metaDataDCS.SetBeamPeriod(0);
 120             metaDataDCS.SetResponsible("Tomasz Malkiewicz");
 121             metaDataDCS.SetComment("This preprocessor fills an AliTODataDCS object.");
 122             AliInfo("Storing DCS Data");
 123             resultDCSStore = Store("Calib","DCSData",fData, &metaDataDCS);
 124             if (!resultDCSStore)
 125             {
 126               Log("Some problems occurred while storing DCS data results in ReferenceDB");
 127               return 2;// return error Code for processed DCS data not stored
 128             }
 129           }
 130         }
 131         return 0;
 132 }
 133 //____________________________________________________
 134
 135 UInt_t AliT0PreprocessorCosmic::ProcessLaser(){
 136         // Processing data from DAQ Standalone run
 137         Log("Processing Laser calibration");
 138
 139         Bool_t resultLaser=kFALSE;
 140         //processing DAQ
 141         TList* list = GetFileSources(kDAQ, "COSMIC");
 142         if (list)
 143         {
 144             TIter iter(list);
 145             TObjString *source;
 146             while ((source = dynamic_cast<TObjString *> (iter.Next())))
 147             {
 148               const char *laserFile = GetFile(kDAQ, "COSMIC", source->GetName());
 149               if (laserFile)
 150               {
 151                 Log(Form("File with Id COSMIC found in source %s!", source->GetName()));
 152                 AliT0CalibWalk *laser = new AliT0CalibWalk();
 153                 laser->MakeWalkCorrGraph(laserFile);
 154                 AliCDBMetaData metaData;
 155                 metaData.SetBeamPeriod(0);
 156                 metaData.SetResponsible("Tomek&Michal");
 157                 metaData.SetComment("Walk correction from laser runs.");
 158                 resultLaser=Store("Calib","Slewing_Walk", laser, &metaData, 0, 1);
 159                 delete laser;
 160               }
 161               else
 162               {
 163                 Log(Form("Could not find file with Id COSMIC in source %s!", source->GetName()));
 164                 return 1;
 165               }
 166             }
 167             if (!resultLaser)
 168             {
 169               Log("No Laser Data stored");
 170               return 3;//return error code for failure in storing Laser Data
 171             }
 172           } else {
 173                 Log("No sources found for id COSMIC!");
 174                 return 1;
 175           }
 176         return 0;
 177 }
 178 //____________________________________________________
 179
 180 UInt_t AliT0PreprocessorCosmic::ProcessPhysics(){
 181         //Processing data from DAQ Physics run
 182         Log("Processing Physics");
 183
 184         Bool_t resultOnline=kFALSE;
 185         //processing DAQ
 186         TList* listPhys = GetFileSources(kDAQ, "COSMIC");
 187         if (listPhys)
 188           {
 189             TIter iter(listPhys);
 190             TObjString *sourcePhys;
 191             while ((sourcePhys = dynamic_cast<TObjString *> (iter.Next())))
 192             {
 193               const char *filePhys = GetFile(kDAQ, "COSMIC", sourcePhys->GetName());
 194               if (filePhys)
 195               {
 196                 AliT0CalibTimeEq *online = new AliT0CalibTimeEq();
 197                 online->Reset();
 198                 online->ComputeOnlineParams(filePhys);
 199                 AliCDBMetaData metaData;
 200                 metaData.SetBeamPeriod(0);
 201                 metaData.SetResponsible("Tomek&Michal");
 202                 metaData.SetComment("Time equalizing result.");
 203                 resultOnline = Store("Calib","TimeDelay", online, &metaData, 0, 1);
 204                 delete online;
 205               }
 206               else
 207               {
 208                 Log(Form("Could not find file with Id COSMIC in source %s!", sourcePhys->GetName()));
 209                 return 1;
 210               }
 211             }
 212             if (!resultOnline)
 213             {
 214               Log("No Laser Data stored");
 215               return 4;//return error code for failure in storing OCDB Data
 216             }
 217           } else {
 218                 Log("No sources found for id COSMIC!");
 219                 return 1;
 220           }
 221         return 0;
 222 }
 223 //____________________________________________________
 224
 225 UInt_t AliT0PreprocessorCosmic::Process(TMap* dcsAliasMap )
 226 {
 227   // T0 preprocessor return codes:
 228   // return=0 : all ok
 229   // return=1 : no DCS input data
 230   // return=2 : failed to store DCS data
 231   // return=3 : no Laser data (Walk correction)
 232   // return=4 : failed to store OCDB time equalized data
 233   // return=5 : no DAQ input for OCDB
 234   // return=6 : failed to retrieve DAQ data from OCDB
 235   // return=7 : failed to store T0 OCDB data
 236         Bool_t dcsDP = ProcessDCS();
 237         Log(Form("dcsDP = %d",dcsDP));
 238         TString runType = GetRunType();
 239         Log(Form("RunType: %s",runType.Data()));
 240         //processing
 241         if((runType == "STANDALONE")||(runType == "PHYSICS")){
 242                 Int_t iresultLaser = ProcessLaser();
 243                 Int_t iresultPhysics = ProcessPhysics();
 244                 if(dcsDP==1){
 245                         Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
 246                         return iresultDCS;
 247                 }
 248                 if(iresultLaser==0){
 249                         Log(Form("iresultLaser = %d", iresultLaser));
 250                         Log(Form("iresultPhysics = %d", iresultPhysics));
 251                         return iresultPhysics;
 252                 }
 253                 else return iresultLaser;
 254         }
 255        else{ return 0; }
 256
 257   return 0;
 258 }