1ca8b37a55e77345dbc25d13d9897cfd14c95269
[u/mrichter/AliRoot.git] / T0 / AliT0Preprocessor.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: AliT0Preprocessor.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 "AliT0Preprocessor.h"
41 #include "AliT0DataDCS.h"
42 #include "AliT0CalibWalk.h"
43 #include "AliT0CalibTimeEq.h"
44
45 #include "AliCDBMetaData.h"
46 #include "AliDCSValue.h"
47 #include "AliCDBEntry.h"
48 #include "AliLog.h"
49
50 #include <TTimeStamp.h>
51 #include <TFile.h>
52 #include <TObjString.h>
53 #include <TNamed.h>
54 #include "AliT0Dqclass.h"
55 #include "TClass.h"
56
57
58 ClassImp(AliT0Preprocessor)
59
60 //____________________________________________________
61 AliT0Preprocessor::AliT0Preprocessor(AliShuttleInterface* shuttle) : 
62   AliPreprocessor("T00", shuttle), 
63   fData(0)
64 {
65   //constructor
66   AddRunType("PHYSICS");
67   AddRunType("STANDALONE");
68   AddRunType("AMPLITUDE_CALIBRATION");
69 }
70 //____________________________________________________
71
72 AliT0Preprocessor::~AliT0Preprocessor()
73 {
74   //destructor
75   delete fData;
76   fData = 0;
77 }
78 //____________________________________________________
79
80 void AliT0Preprocessor::Initialize(Int_t run, UInt_t startTime, UInt_t endTime)
81 {
82   // Creates AliT0DataDCS object
83   AliPreprocessor::Initialize(run, startTime, endTime);
84   AliInfo(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run, TTimeStamp(startTime).AsString(), TTimeStamp(endTime).AsString()));
85   fData = new AliT0DataDCS(fRun, fStartTime, fEndTime, GetStartTimeDCSQuery(), GetEndTimeDCSQuery());
86 }
87 //____________________________________________________
88
89 Bool_t AliT0Preprocessor::ProcessDCS(){
90         // Check whether DCS should be processed or not...
91         TString runType = GetRunType();
92         Log(Form("ProcessDCS - RunType: %s",runType.Data()));
93
94         if((runType == "STANDALONE")||
95            (runType == "PHYSICS") 
96            || (runType == "AMPLITUDE_CALIBRATION")){
97
98           //      return kFALSE;
99                 return kTRUE;
100         }else{
101         return kFALSE;
102         }
103 }
104 //____________________________________________________
105
106 UInt_t AliT0Preprocessor::ProcessDCSDataPoints(TMap* dcsAliasMap){
107         // Fills data into AliT0DataDCS object
108         Log("Processing DCS DP");
109         Bool_t resultDCSMap=kFALSE;
110         Bool_t resultDCSStore=kFALSE;
111
112         if(!dcsAliasMap)
113         {
114           Log("No DCS input data");
115           return 1;
116         }
117         else
118         {
119           resultDCSMap=fData->ProcessData(*dcsAliasMap);
120           if(!resultDCSMap)
121           {
122             Log("Error when processing DCS data");
123             return 2;// return error Code for processed DCS data not stored
124           }
125           else
126           {
127             AliCDBMetaData metaDataDCS;
128             metaDataDCS.SetBeamPeriod(0);
129             metaDataDCS.SetResponsible("Tomasz Malkiewicz");
130             metaDataDCS.SetComment("This preprocessor fills an AliTODataDCS object.");
131             AliInfo("Storing DCS Data");
132             resultDCSStore = StoreReferenceData("Calib","DCSData",fData, &metaDataDCS);
133             if (!resultDCSStore)
134             {
135               Log("Some problems occurred while storing DCS data results in ReferenceDB");
136               return 2;// return error Code for processed DCS data not stored
137             }
138           }
139         }
140         return 0;
141 }
142 //____________________________________________________
143
144 UInt_t AliT0Preprocessor::ProcessLaser()
145 {
146   // Processing data from DAQ Standalone run
147   Log("Processing Laser calibration - Walk Correction");
148   Bool_t resultLaser = kFALSE;
149   Bool_t writeok = kFALSE;
150   //processing DAQ
151   TObjString *source;
152   TList* list = GetFileSources(kDAQ, "AMPLITUDE_CALIBRATION");
153   AliT0CalibWalk *laser = new AliT0CalibWalk();
154   if (list)
155     {
156       TIter iter(list);
157       while ((source = dynamic_cast<TObjString *> (iter.Next())))
158         {
159           const char *laserFile = GetFile(kDAQ, "AMPLITUDE_CALIBRATION", source->GetName());
160           if (laserFile)
161             {
162               Log(Form("File with Id LASER found in source %s!", source->GetName()));
163              writeok = laser->MakeWalkCorrGraph(laserFile);
164               
165             }
166         }
167       
168       AliCDBMetaData metaData;
169       metaData.SetBeamPeriod(0);
170       metaData.SetResponsible("Tomek&Michal");
171       metaData.SetComment("Walk correction from laser runs.");
172       if (writeok) resultLaser=Store("Calib","Slewing_Walk", laser, &metaData, 0, 1);
173       else {
174         
175         Log(Form("writeok = %d no peaks in CFD spectra",writeok));
176         return 0;
177       }           
178       Log(Form("resultLaser = %d",resultLaser));
179     }
180   else
181     {
182       Log(Form("Could not find file with Id LASER in source %s!", source->GetName()));
183       return 1;
184     }
185   
186   if (!resultLaser)
187     {
188       Log("No Laser Data stored");
189       return 3;//return error code for failure in storing Laser Data
190     }
191   else {
192     Log("No sources found for id LASER!");
193     return 1;
194   }
195   return 0;
196 }
197
198 //____________________________________________________
199
200 UInt_t AliT0Preprocessor::ProcessPhysics(){
201         //Processing data from DAQ Physics run
202         Log("Processing Physics");
203         
204         Bool_t resultOnline=kFALSE; 
205         //processing DAQ
206         TList* listPhys = GetFileSources(kDAQ, "PHYSICS");
207         if (listPhys)
208           {
209             TIter iter(listPhys);
210             TObjString *sourcePhys;
211             while ((sourcePhys = dynamic_cast<TObjString *> (iter.Next())))
212             {
213               const char *filePhys = GetFile(kDAQ, "PHYSICS", sourcePhys->GetName());
214               if (filePhys)
215               {
216                 AliT0CalibTimeEq *online = new AliT0CalibTimeEq();
217                 online->Reset();
218                 Bool_t writeok = online->ComputeOnlineParams(filePhys);
219                 AliCDBMetaData metaData;
220                 metaData.SetBeamPeriod(0);
221                 metaData.SetResponsible("Alla Maevskaya");
222                 metaData.SetComment("Time equalizing result.");
223
224                 if (writeok) resultOnline = Store("Calib","TimeDelay", online, &metaData, 0, 1);
225                 else {
226                   
227                   Log(Form("writeok = %d not enough data for equalizing",resultOnline));
228                   return 0;
229                 }                 
230                 Log(Form("resultOnline = %d",resultOnline));
231                 delete online;
232               }
233                 else
234               {
235                 Log(Form("Could not find file with Id PHYSICS in source %s!", sourcePhys->GetName()));
236                 return 1;
237               }
238               
239             }
240             if (!resultOnline)
241             {
242               Log("No Data stored");
243               return 4;//return error code for failure in storing OCDB Data
244             }
245           } else {
246                 Log("No sources found for id PHYSICS!");
247                 return 1;
248           }
249         return 0;
250 }
251 //____________________________________________________
252
253 UInt_t AliT0Preprocessor::Process(TMap* dcsAliasMap )
254 {
255   // T0 preprocessor return codes:
256   // return=0 : all ok
257   // return=1 : no DCS input data 
258   // return=2 : failed to store DCS data
259   // return=3 : no Laser data (Walk correction)
260   // return=4 : failed to store OCDB time equalized data
261   // return=5 : no DAQ input for OCDB
262   // return=6 : failed to retrieve DAQ data from OCDB
263   // return=7 : failed to store T0 OCDB data
264   // return=8 : not enough data for equalizing
265   Bool_t dcsDP = ProcessDCS();
266   Log(Form("dcsDP = %d",dcsDP));        
267   TString runType = GetRunType();
268   Log(Form("RunType: %s",runType.Data()));
269   //processing
270   if(runType == "STANDALONE"){
271     if(dcsDP==1){
272       Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
273       return iresultDCS;
274     }
275   }
276   
277   if(runType == "AMPLITUDE_CALIBRATION"){
278     Int_t iresultLaser = ProcessLaser();
279     if(dcsDP==1){
280       Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
281       return iresultDCS;
282     }
283     
284     Log(Form("iresultLaser = %d",iresultLaser));
285     return iresultLaser;
286   }
287   
288   else if(runType == "PHYSICS"){
289     Int_t iresultPhysics = ProcessPhysics();
290     if(dcsDP==1){
291       Int_t iresultDCS = ProcessDCSDataPoints(dcsAliasMap);
292       return iresultDCS;
293     }
294     Log(Form("iresultPhysics = %d",iresultPhysics));
295           return iresultPhysics; 
296       }
297   
298         
299         
300         return 0;
301 }