TRIGGER/AliTRIPreprocessor.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 /* $Id$*/
  17
  18 // Trigger preprocessor class.
  19 // According to the TriggerDetectorMask read from the logbook_trigger_clusters
  20 // DAQ table, the triggering detectors are identified, and the
  21 // corresponding procedure is called.
  22 // Data are stored in the OCDB, in /TRIGGER/<DET>/<level3>, where
  23 // <DET> correspond to the triggering detector,
  24 // and <level3> is defined in the detector procedure
  25
  26 #include "AliTRIPreprocessor.h"
  27
  28 #include "AliCDBMetaData.h"
  29 #include "AliCDBEntry.h"
  30 #include "AliLog.h"
  31 #include "AliITSTriggerConditions.h"
  32
  33 #include <TTimeStamp.h>
  34 #include <TObjString.h>
  35 #include <TList.h>
  36 #include <TROOT.h>
  37 #include <TSystem.h>
  38
  39 ClassImp(AliTRIPreprocessor)
  40
  41 // names of detectors/systems in the DETECTORS_MAP in /date/db/detCodes.h
  42 const char* AliTRIPreprocessor::fgkDetectorsMapName[AliTRIPreprocessor::kNDetectorsMap] = {"SPD"/*0*/, "SDD"/*1*/, "SSD"/*2*/, "TPC"/*3*/, "TRD"/*4*/,
  43                                                                                "TOF"/*5*/, "HMP"/*6*/, "PHS"/*7*/, "CPV"/*8*/, "PMD"/*9*/,
  44                                                                                "MCH"/*10*/,"MTR"/*11*/,"FMD"/*12*/,"T00"/*13*/,"V00"/*14*/,
  45                                                                                "ZDC"/*15*/,"ACO"/*16*/,"TRI"/*17*/,"EMC"/*18*/,"TST"/*19*/,
  46                                                                                ""/*20*/,   ""/*21*/,   ""/*22*/,   ""/*23*/,   ""/*24*/,
  47                                                                                ""/*25*/,   ""/*26*/,   ""/*27*/,   ""/*28*/,   "GRP"/*29*/,
  48                                                                                "HLT"/*30*/};
  49
  50 //______________________________________________________________________________________________
  51 AliTRIPreprocessor::AliTRIPreprocessor(AliShuttleInterface* shuttle) :
  52   AliPreprocessor("TRI", shuttle),
  53   fShuttle(shuttle)
  54
  55 {
  56         //
  57         // constructor
  58         //
  59
  60         AddRunType("PHYSICS");
  61 }
  62
  63 //______________________________________________________________________________________________
  64 AliTRIPreprocessor::~AliTRIPreprocessor()
  65 {
  66         //
  67         // destructor
  68         //
  69 }
  70
  71 //______________________________________________________________________________________________
  72 void AliTRIPreprocessor::Initialize(Int_t run, UInt_t startTime,
  73         UInt_t endTime)
  74 {
  75
  76         //
  77         // Initialize preprocessor
  78         //
  79
  80         AliPreprocessor::Initialize(run, startTime, endTime);
  81
  82         Log(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run,
  83                 TTimeStamp(startTime).AsString(),
  84                 TTimeStamp(endTime).AsString()));
  85
  86 }
  87
  88 //______________________________________________________________________________________________
  89 Bool_t AliTRIPreprocessor::ProcessDCS()
  90 {
  91         //
  92         // DCS data are never needed
  93         //
  94
  95         return kFALSE;
  96 }
  97
  98 //______________________________________________________________________________________________
  99 UInt_t AliTRIPreprocessor::Process(TMap* /*dcsAliasMap*/)
 100 {
 101
 102         // Procees function:
 103         // After reading the TriggerDetectorMask, the
 104         // corresponding triggering detector procedures to
 105         // process the trigger data are called.
 106
 107         typedef Short_t (AliTRIPreprocessor::*AliProcessTriggerData)();
 108         const AliProcessTriggerData processTriggerDataArray[AliTRIPreprocessor::kNDetectorsMap]= {
 109                 &AliTRIPreprocessor::ProcessSPDTriggerData,
 110                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 111                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 112                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 113                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 114                 &AliTRIPreprocessor::ProcessTOFTriggerData,
 115                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 116                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 117                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 118                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 119                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 120                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 121                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 122                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 123                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 124                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 125                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 126                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 127                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 128                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 129                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 130                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 131                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 132                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 133                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 134                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 135                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 136                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 137                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 138                 &AliTRIPreprocessor::ProcessEmptyTriggerData,
 139                 &AliTRIPreprocessor::ProcessEmptyTriggerData};
 140
 141
 142         // getting the list of triggering detectors from DAQ logbook
 143
 144         TString triggerDetectorMask = (TString)GetTriggerDetectorMask();
 145         Int_t result=0;
 146         if (!triggerDetectorMask.IsNull()){
 147                 Int_t length = triggerDetectorMask.Length();
 148                 Log(Form("mask = %s", triggerDetectorMask.Data()));
 149                   for (Int_t i = 0; i<length; i++){
 150                         AliDebug(2,Form("%d-th bit = %c in index %d",i,triggerDetectorMask[length-1-i],length-1-i));
 151                         if (triggerDetectorMask[length-1-i] == '1'){
 152                                 Log("****************************************");
 153                                 Log(Form("Processing Trigger data for %s",fgkDetectorsMapName[i]));
 154                                 Log("****************************************");
 155
 156                                 result+=(this->*processTriggerDataArray[i])();
 157                         }
 158                 }
 159         }
 160
 161         // result should be 0 to end successfully
 162
 163         return result;
 164
 165 }
 166 //______________________________________________________________________________________________
 167 Short_t AliTRIPreprocessor::ProcessSPDTriggerData()
 168 {
 169         //
 170         // Processing SPD Trigger Data
 171         //
 172
 173         Log("************** Processing SPD Trigger data... **************");
 174
 175         // Read new conditions from dcs fxs
 176         AliITSTriggerConditions* newCond = new AliITSTriggerConditions();
 177         TString fxsID = "PITConditions";
 178         TList* list = GetFileSources(kDCS, fxsID.Data());
 179         if (!list) {
 180                 AliError("FXS file not found.");
 181                 return 1;
 182         }
 183         UInt_t nFiles = 0;
 184         while (list->At(nFiles)!=NULL) {
 185                 TObjString* fileNameEntry = (TObjString*) list->At(nFiles);
 186                 TString fileName = GetFile(kDCS, fxsID.Data(), fileNameEntry->GetString().Data());
 187                 if (fileName.IsNull()) {
 188                         Log(Form("GetFile failed to retrieve file %s.",fileNameEntry->GetString().Data()));
 189                         return 1;
 190                 }
 191                 if (nFiles==0) newCond->ReadFromTextFile(fileName.Data());
 192                 nFiles++;
 193         }
 194         if (nFiles!=1) {
 195                 AliWarning(Form("Found %d files with id %s (expected exactly 1).",nFiles,fxsID.Data()));
 196         }
 197
 198         // Read old conditions from ocdb
 199         AliITSTriggerConditions* oldCond = NULL;
 200         AliCDBEntry* pitCond = GetFromOCDB("SPD", "PITConditions");
 201         if (pitCond) {
 202                 oldCond = (AliITSTriggerConditions*) pitCond->GetObject();
 203                 if (!oldCond) {
 204                         AliError("AliCDBEntry::GetObject() returned NULL.");
 205                         return 1;
 206                 }
 207         }
 208         else {
 209                 Log("Old conditions not found in database.");
 210         }
 211
 212         // Do we need to update db?
 213         Bool_t doUpdate = kTRUE;
 214         if (oldCond) {
 215                 // compare to see if there were any changes...
 216                 if (newCond->IsEqualTo(oldCond)) {
 217                         Log("Old conditions equal to new conditions. Do nothing.");
 218                         doUpdate = kFALSE;
 219                 }
 220         }
 221
 222         if (doUpdate) {
 223                 // store new conditions in ocdb
 224                 AliCDBMetaData metaData;
 225                 metaData.SetResponsible("Henrik Tydesjo");
 226                 metaData.SetComment("Created by Trigger PreProcessor");
 227                 if (!Store("SPD", "PITConditions", newCond, &metaData, 0, kTRUE)) {
 228                         Log("Failed to store conditions data.");
 229                         return 1;
 230                 }
 231                 Log("Database updated.");
 232         }
 233
 234         delete newCond;
 235
 236         Log("************************* ...done.*************************");
 237
 238         return 0; // 0 means success
 239
 240 }
 241 //______________________________________________________________________________________________
 242 Short_t AliTRIPreprocessor::ProcessTOFTriggerData()
 243 {
 244         //
 245         // Processing TOF Trigger Data
 246         //
 247
 248         Log("************** Processing TOF Trigger data... **************");
 249         Log("************************* ...done.*************************");
 250         return 0;
 251 }
 252 //______________________________________________________________________________________________
 253 Short_t AliTRIPreprocessor::ProcessEmptyTriggerData()
 254 {
 255         //
 256         // Processing TOF Trigger Data
 257         //
 258
 259         Log("************** Trigger data Processing not yet implemented **************");
 260         return 0;
 261 }
 262
 263