- Implementing functions for the GRP preprocessor to retrieve DA output files from...
[u/mrichter/AliRoot.git] / SHUTTLE / TestShuttle / AliTestShuttle.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$
18 Revision 1.14  2007/08/06 12:25:47  acolla
19 Function Bool_t GetHLTStatus added to preprocessor. It returns the status of HLT
20 read from the run logbook.
21 TestShuttle setup updated.
22 TRD data point configuration updated.
23
24 Revision 1.13  2007/05/30 06:35:21  jgrosseo
25 Adding functionality to the Shuttle/TestShuttle:
26 o) Function to retrieve list of sources from a given system (GetFileSources with id=0)
27 o) Function to retrieve list of IDs for a given source      (GetFileIDs)
28 These functions are needed for dealing with the tag files that are saved for the GRP preprocessor
29 Example code has been added to the TestProcessor in TestShuttle
30
31 Revision 1.12  2007/04/27 07:06:48  jgrosseo
32 GetFileSources returns empty list in case of no files, but successful query
33 No mails sent in testmode
34
35 Revision 1.11  2007/04/04 10:33:36  jgrosseo
36 1) Storing of files to the Grid is now done _after_ your preprocessors succeeded. This is transparent, which means that you can still use the same functions (Store, StoreReferenceData) to store files to the Grid. However, the Shuttle first stores them locally and transfers them after the preprocessor finished. The return code of these two functions has changed from UInt_t to Bool_t which gives you the success of the storing.
37 In case of an error with the Grid, the Shuttle will retry the storing later, the preprocessor does not need to be run again.
38
39 2) The meaning of the return code of the preprocessor has changed. 0 is now success and any other value means failure. This value is stored in the log and you can use it to keep details about the error condition.
40
41 3) New function StoreReferenceFile to _directly_ store a file (without opening it) to the reference storage.
42
43 4) The memory usage of the preprocessor is monitored. If it exceeds 2 GB it is terminated.
44
45 5) New function AliPreprocessor::ProcessDCS(). If you do not need to have DCS data in all cases, you can skip the processing by implemting this function and returning kFALSE under certain conditions. E.g. if there is a certain run type.
46 If you always need DCS data (like before), you do not need to implement it.
47
48 6) The run type has been added to the monitoring page
49
50 Revision 1.10  2007/02/28 10:41:01  acolla
51 Run type field added in SHUTTLE framework. Run type is read from "run type" logbook and retrieved by
52 AliPreprocessor::GetRunType() function.
53 Added some ldap definition files.
54
55 Revision 1.8  2007/02/13 11:22:25  acolla
56 Shuttle getters and setters of main/local OCDB/Reference storages, temp and log
57 folders moved to AliShuttleInterface
58
59 Revision 1.6  2006/11/06 14:22:47  jgrosseo
60 major update (Alberto)
61 o) reading of run parameters from the logbook
62 o) online offline naming conversion
63 o) standalone DCSclient package
64
65 Revision 1.5  2006/10/02 12:58:52  jgrosseo
66 Small interface change in StoreReferenceData
67
68 Revision 1.4  2006/08/08 14:19:07  jgrosseo
69 Update to shuttle classes (Alberto)
70
71 - Possibility to set the full object's path in the Preprocessor's and
72 Shuttle's  Store functions
73 - Possibility to extend the object's run validity in the same classes
74 ("startValidity" and "validityInfinite" parameters)
75 - Implementation of the StoreReferenceData function to store reference
76 data in a dedicated CDB storage.
77
78 Revision 1.3  2006/07/11 12:44:32  jgrosseo
79 adding parameters for extended validity range of data produced by preprocessor
80
81 Revision 1.2  2006/06/06 14:20:05  jgrosseo
82 o) updated test preprocessor (alberto)
83 o) added comments to example macro
84 o) test shuttle implements new interface
85
86 Revision 1.2  2006/03/07 07:52:34  hristov
87 New version (B.Yordanov)
88
89 Revision 1.3  2005/11/17 17:47:34  byordano
90 TList changed to TObjArray
91
92 Revision 1.2  2005/11/17 14:43:22  byordano
93 import to local CVS
94
95 Revision 1.1.1.1  2005/10/28 07:33:58  hristov
96 Initial import as subdirectory in AliRoot
97
98 Revision 1.1.1.1  2005/09/12 22:11:40  byordano
99 SHUTTLE package
100
101 Revision 1.2  2005/08/29 21:15:47  byordano
102 some docs added
103
104 */
105
106 //
107 // test implementation of the AliShuttleInterface, to be used for local tests of preprocessors
108 //
109 // reads files from the local disk
110 // stores to local CDB
111 // logs to the screen
112 //
113
114 #include "AliTestShuttle.h"
115 #include "AliLog.h"
116
117 #include "AliCDBManager.h"
118 #include "AliCDBStorage.h"
119 #include "AliCDBMetaData.h"
120 #include "AliCDBPath.h"
121 #include "AliCDBId.h"
122 #include "AliPreprocessor.h"
123
124 #include <TMap.h>
125 #include <TList.h>
126 #include <TObjString.h>
127 #include <TSystem.h>
128 #include <TTimeStamp.h>
129
130 ClassImp(AliTestShuttle)
131
132 //______________________________________________________________________________________________
133 AliTestShuttle::AliTestShuttle(Int_t run, UInt_t startTime, UInt_t endTime) :
134   fRun(run),
135   fStartTime(startTime),
136   fEndTime(endTime),
137   fTimeCreated(startTime),
138   fDCSQueryOffset(0),
139   fInputFiles(0),
140   fRunParameters(0),
141   fRunType(),
142   fPreprocessors(0),
143   fDcsAliasMap(0),
144   fTriggerConfiguration(""),
145   fTriggerDetectorMask(""),
146   fCTPtiming("")
147 {
148   // constructor
149
150   fInputFiles = new TMap;
151   fRunParameters = new TMap;
152   fPreprocessors = new TObjArray;
153
154   fInputFiles->SetOwner(1);
155   fRunParameters->SetOwner(1);
156   fPreprocessors->SetOwner(1);
157 }
158
159 //______________________________________________________________________________________________
160 AliTestShuttle::~AliTestShuttle()
161 {
162   // destructor
163
164   delete fInputFiles;
165   fInputFiles = 0;
166
167   delete fRunParameters;
168   fRunParameters = 0;
169
170   delete fPreprocessors;
171   fPreprocessors = 0;
172
173   delete fDcsAliasMap;
174   fDcsAliasMap = 0;
175 }
176
177 //______________________________________________________________________________________________
178 Bool_t AliTestShuttle::Store(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData,
179                                 Int_t validityStart, Bool_t validityInfinite)
180 {
181   // Stores the CDB object
182   // This function should be called at the end of the preprocessor cycle
183   //
184   // This implementation just stores it on the local disk, the full AliShuttle
185   // puts it to the Grid FileCatalog
186
187   Int_t startRun = fRun - validityStart;
188   if(startRun < 0) {
189         AliError("First valid run happens to be less than 0! Setting it to 0...");
190         startRun=0;
191   }
192
193   Int_t endRun = -1;
194   if(validityInfinite) {
195         endRun = AliCDBRunRange::Infinity();
196   } else {
197         endRun = fRun;
198   }
199
200   AliCDBId id(path, startRun, endRun);
201
202   return AliCDBManager::Instance()->GetStorage(fgkMainCDB)->Put(object, id, metaData);
203 }
204
205 //______________________________________________________________________________________________
206 Bool_t AliTestShuttle::StoreReferenceData(const AliCDBPath& path, TObject* object, AliCDBMetaData* metaData)
207 {
208   // Stores the object as reference data
209   // This function should be called at the end of the preprocessor cycle
210   //
211   // This implementation just stores it on the local disk, the full AliShuttle
212   // puts it to the Grid FileCatalog
213
214   AliCDBId id(path, fRun, fRun);
215
216   return AliCDBManager::Instance()->GetStorage(fgkMainRefStorage)->Put(object, id, metaData);
217 }
218
219 //______________________________________________________________________________________________
220 Bool_t AliTestShuttle::StoreReferenceFile(const char* detector, const char* localFile, const char* gridFileName)
221 {
222         //
223         // Stores reference file directly (without opening it). 
224         //
225         // This implementation just stores it on the local disk, the full AliShuttle 
226         // puts it to the Grid FileCatalog
227         
228         AliCDBManager* man = AliCDBManager::Instance();
229         AliCDBStorage* sto = man->GetStorage(fgkLocalRefStorage);
230         
231         TString localBaseFolder = sto->GetBaseFolder();
232         
233         TString targetDir = GetRefFilePrefix(localBaseFolder.Data(), detector); 
234         
235         return CopyFileLocally(targetDir, localFile, gridFileName);
236 }
237
238 //______________________________________________________________________________________________
239 Bool_t AliTestShuttle::StoreRunMetadataFile(const char* localFile, const char* gridFileName)
240 {
241         //
242         // Stores Run metadata file to the Grid, in the run folder
243         //
244         // Only GRP can call this function.
245         
246         AliCDBManager* man = AliCDBManager::Instance();
247         AliCDBStorage* sto = man->GetStorage(fgkLocalRefStorage);
248         
249         TString localBaseFolder = sto->GetBaseFolder();
250         
251         // Build Run level folder
252         // folder = /alice/data/year/lhcPeriod/runNb/Raw
253         
254         TTimeStamp startTime(fStartTime);
255                 
256         TString year =  Form("%d",startTime.GetDate());
257         year = year(0,4);
258                 
259         TString lhcPeriod = GetRunParameter("LHCperiod");
260         
261         if (lhcPeriod.Length() == 0) 
262         {
263                 Log("SHUTTLE","StoreRunMetaDataFile - LHCPeriod not found in logbook!");
264                 return 0;
265         }
266         
267         // TODO: currently SHUTTLE cannot write in /alice/data/ !!!!!
268         //TString targetDir = Form("%s/GRP/RunMetadata/alice/data/%s/%s/%d/Raw", 
269         //                      localBaseFolder.Data(), year.Data(), 
270         //                      lhcPeriod.Data(), fRun);
271         
272         TString targetDir = Form("%s/GRP/RunMetadata/alice/simulation/%s/%s/%d/Raw", 
273                                 localBaseFolder.Data(), year.Data(), 
274                                 lhcPeriod.Data(), fRun);
275                                         
276         return CopyFileLocally(targetDir, localFile, gridFileName);
277 }
278
279 //______________________________________________________________________________________________
280 Bool_t AliTestShuttle::CopyFileLocally(TString& targetDir, const char* localFile, const char* gridFileName)
281 {
282         //
283         // Stores file locally. Called by StoreReferenceFile and StoreRunMetadataFile
284         //
285         
286         //try to open folder, if it does not exist
287         void* dir = gSystem->OpenDirectory(targetDir.Data());
288         if (dir == NULL) {
289                 if (gSystem->mkdir(targetDir.Data(), kTRUE)) {
290                         Log("SHUTTLE", Form("StoreFileLocally - Can't open directory <%s>", targetDir.Data()));
291                         return kFALSE;
292                 }
293
294         } else {
295                 gSystem->FreeDirectory(dir);
296         }
297
298         TString target = Form("%s/%s", targetDir.Data(), gridFileName);
299         
300         Int_t result = gSystem->GetPathInfo(localFile, 0, (Long64_t*) 0, 0, 0);
301         if (result)
302         {
303                 Log("SHUTTLE", Form("StoreFileLocally - %s does not exist", localFile));
304                 return kFALSE;
305         }
306
307         result = gSystem->CopyFile(localFile, target);
308
309         if (result == 0)
310         {
311                 Log("SHUTTLE", Form("StoreFileLocally - File %s stored locally to %s", localFile, target.Data()));
312                 return kTRUE;
313         }
314         else
315         {
316                 Log("SHUTTLE", Form("StoreFileLocally - Could not store file %s to %s!. Error code = %d", 
317                                 localFile, target.Data(), result));
318                 return kFALSE;
319         }       
320
321
322
323 }
324
325 //______________________________________________________________________________________________
326 const char* AliTestShuttle::GetRefFilePrefix(const char* base, const char* detector)
327 {
328         //
329         // Get folder name of reference files 
330         //
331
332         TString offDetStr(GetOfflineDetName(detector));
333         static TString dir;
334         if (offDetStr == "ITS" || offDetStr == "MUON" || offDetStr == "PHOS")
335         {
336                 dir.Form("%s/%s/%s", base, offDetStr.Data(), detector);
337         } else {
338                 dir.Form("%s/%s", base, offDetStr.Data());
339         }
340         
341         return dir.Data();
342 }
343
344 //______________________________________________________________________________________________
345 const char* AliTestShuttle::GetFile(Int_t system, const char* detector, const char* id, const char* source)
346 {
347   // This function retrieves a file from the given system (kDAQ, kDCS, kHLT) with the given file id
348   // and from the given source in the system.
349   // The function returnes the path to the local file.
350   //
351   // test implementation of GetFile
352   // takes files from the local disks, files are passen in a TMap in the constructor
353
354   TString key;
355   key.Form("%s-%s-%s", fkSystemNames[system], detector, id);
356   TPair* sourceListPair = dynamic_cast<TPair*> (fInputFiles->FindObject(key.Data()));
357   TMap* sourceList = 0;
358   if (sourceListPair)
359     sourceList = dynamic_cast<TMap*> (sourceListPair->Value());
360   if (!sourceList)
361   {
362     AliError(Form("Could not find any file in %s with id %s (%s)", fkSystemNames[system], id, key.Data()));
363     return 0;
364   }
365
366   TObjString* fileName = 0;
367   TPair* fileNamePair = dynamic_cast<TPair*> (sourceList->FindObject(source));
368   if (fileNamePair)
369         fileName = dynamic_cast<TObjString*> (fileNamePair->Value());
370   if (!fileName)
371   {
372     AliError(Form("Could not find files from source %s in %s with id %s",
373                         source, fkSystemNames[system], id));
374     return 0;
375   }
376
377   return fileName->GetString().Data();
378 }
379
380 //______________________________________________________________________________________________
381 TList* AliTestShuttle::GetFileSources(Int_t system, const char* detector, const char* id)
382 {
383   // Returns a list of sources in a given system that saved a file with the given id
384   //
385   // test implementation of GetFileSources
386   // takes files from the local disks, files are passen in a TMap in the constructor
387
388   TString key;
389   if (id)
390     key.Form("%s-%s-%s", fkSystemNames[system], detector, id);
391   else
392     key.Form("%s-%s", fkSystemNames[system], detector);
393   
394   TList* list = new TList;
395   
396   TIterator* iter = fInputFiles->MakeIterator();
397   TObject* obj = 0;
398   while ((obj = iter->Next()))
399   {
400         TObjString* objStr = dynamic_cast<TObjString*> (obj);
401         if (objStr)
402         {
403                 Bool_t found = kFALSE;
404                 if (id)
405                 {
406                         found = (objStr->String().CompareTo(key) == 0);
407                 }
408                 else
409                         found = objStr->String().BeginsWith(key);
410                 
411                 if (found)
412                 {
413                         TPair* sourceListPair = dynamic_cast<TPair*> (fInputFiles->FindObject(objStr->String().Data()));
414                         TMap* sourceList = dynamic_cast<TMap*> (sourceListPair->Value());
415         
416                         TIterator* iter2 = sourceList->GetTable()->MakeIterator();
417                         TObject* obj2 = 0;
418                         while ((obj2 = iter2->Next()))
419                         {
420                                 TPair* pair = dynamic_cast<TPair*> (obj2);
421                                 if (pair)
422                                 {
423                                         if (!list->FindObject(pair->Key()))
424                                                 list->Add(new TObjString(pair->Key()->GetName()));
425                                 }
426                         }
427                         
428                         delete iter2;
429                 }
430         }
431   }
432   
433   if (list->GetEntries() == 0)
434     AliInfo(Form("Could not find any file in %s with id %s (%s)", fkSystemNames[system], id, key.Data()));
435   
436   return list;
437 }
438
439 //______________________________________________________________________________________________
440 TList* AliTestShuttle::GetFileIDs(Int_t system, const char* detector, const char* source)
441 {
442   // Returns a list of ids in a given system that saved a file with the given source
443   //
444   // test implementation of GetFileSources
445   // takes files from the local disks, files are passen in a TMap in the constructor
446
447
448   TString key;
449   key.Form("%s-%s", fkSystemNames[system], detector);
450   
451   TList* list = new TList;
452   
453   TIterator* iter = fInputFiles->MakeIterator();
454   TObject* obj = 0;
455   while ((obj = iter->Next()))
456   {
457         TObjString* objStr = dynamic_cast<TObjString*> (obj);
458         if (objStr)
459         {
460                 if (objStr->String().BeginsWith(key))
461                 {
462                         Bool_t found = kFALSE;
463                 
464                         TPair* sourceListPair = dynamic_cast<TPair*> (fInputFiles->FindObject(objStr->String().Data()));
465                         TMap* sourceList = dynamic_cast<TMap*> (sourceListPair->Value());
466         
467                         TIterator* iter2 = sourceList->GetTable()->MakeIterator();
468                         TObject* obj2 = 0;
469                         while ((obj2 = iter2->Next()))
470                         {
471                                 TPair* pair = dynamic_cast<TPair*> (obj2);
472                                 if (pair)
473                                 {
474                                         if (strcmp(pair->Key()->GetName(), source) == 0)
475                                                 found = kTRUE;
476                                 }
477                         }
478                         
479                         delete iter2;
480                         
481                         if (found)
482                         {
483                                 TObjArray* tokens = objStr->String().Tokenize("-");
484                                 if (tokens->GetEntries() == 3)
485                                 {
486                                         TObjString* id = dynamic_cast<TObjString*> (tokens->At(2));
487                                         if (id && !list->FindObject(id->String()))
488                                                 list->Add(new TObjString(id->String()));
489                                 }
490                                 
491                                 delete tokens;
492         
493                         }
494                 }
495         }
496   }
497   
498   if (list->GetEntries() == 0)
499     AliInfo(Form("Could not find any file in %s with source %s (%s)", fkSystemNames[system], source, key.Data()));
500   
501   return list;
502 }
503
504 //______________________________________________________________________________________________
505 void AliTestShuttle::Log(const char* detector, const char* message, UInt_t level)
506 {
507   // test implementation of Log
508   // just prints to the screen
509
510   TString fullMessage = detector;
511   fullMessage.Append(Form(": %s",message));
512   AliLog::Message(level, fullMessage, MODULENAME(), ClassName(), FUNCTIONNAME(), __FILE__, __LINE__);
513 }
514
515 //______________________________________________________________________________________________
516 void AliTestShuttle::AddInputFile(Int_t system, const char* detector, const char* id, const char* source, const char* fileName)
517 {
518   //
519   // This function adds a file to the list of input files
520   // the list is stored in fInputFiles 
521   // fInputFiles: TMap (key -> value)
522   //    <system>-<detector>-<id> -> TMap (key -> value)
523   //                                <source> -> <filename>
524   //  
525   
526   TString key;
527   key.Form("%s-%s-%s", fkSystemNames[system], detector, id);
528   TPair* sourceListPair = dynamic_cast<TPair*> (fInputFiles->FindObject(key.Data()));
529   TMap* sourceList = 0;
530   if (sourceListPair)
531     sourceList = dynamic_cast<TMap*> (sourceListPair->Value());
532   if (!sourceList)
533   {
534     sourceList = new TMap;
535     fInputFiles->Add(new TObjString(key), sourceList);
536   }
537
538   sourceList->Add(new TObjString(source), new TObjString(fileName));
539 }
540
541 //______________________________________________________________________________________________
542 Bool_t AliTestShuttle::AddInputCDBEntry(AliCDBEntry* entry)
543 {
544   // This function adds an object in the OCDB to be later retrieved with GetFromOCDB
545
546         AliCDBStorage *sto = AliCDBManager::Instance()->GetStorage(fgkMainCDB);
547         if (!sto)
548         {
549                 Log("SHUTTLE", "GetFromOCDB - Cannot activate main OCDB for query!");
550                 return 0;
551         }
552
553         return sto->Put(entry);
554 }
555
556 //______________________________________________________________________________________________
557 AliCDBEntry* AliTestShuttle::GetFromOCDB(const char* detector, const AliCDBPath& path)
558 {
559 // returns obiect from OCDB valid for current run
560
561         AliCDBStorage *sto = AliCDBManager::Instance()->GetStorage(fgkMainCDB);
562         if (!sto)
563         {
564                 Log("SHUTTLE", "GetFromOCDB - Cannot activate main OCDB for query!");
565                 return 0;
566         }
567
568         return (AliCDBEntry*) sto->Get(path, fRun);
569 }
570
571 //______________________________________________________________________________________________
572 void AliTestShuttle::Process()
573 {
574   // This function tests all preprocessors that are registered to it
575   // All preprocessors get the same dcs alias map and have access to the same list of files.
576
577   for (Int_t i=0; i<fPreprocessors->GetEntries(); ++i)
578   {
579     AliPreprocessor* preprocessor = dynamic_cast<AliPreprocessor*> (fPreprocessors->At(i));
580     if (preprocessor)
581     {
582       if (preprocessor->ProcessRunType())
583               {
584                       preprocessor->Initialize(fRun, fStartTime, fEndTime);
585                       preprocessor->Process(fDcsAliasMap);
586               }
587       
588     }
589   }
590 }
591
592 //______________________________________________________________________________________________
593 void AliTestShuttle::RegisterPreprocessor(AliPreprocessor* preprocessor)
594 {
595   // registers a preprocessor
596
597         const char* detName = preprocessor->GetName();
598         if(strcmp("DET", detName) != 0) {
599                 if(GetDetPos(detName) < 0)
600                         AliFatal(Form("********** !!!!! Invalid detector name: %s !!!!! **********", detName));
601         }
602
603         fPreprocessors->Add(preprocessor);
604 }
605
606 //______________________________________________________________________________________________
607 void AliTestShuttle::AddInputRunParameter(const char* key, const char* value){
608 // set a run parameter (in reality it will be read from the DAQ logbook)
609
610         TObjString* keyObj = new TObjString(key);
611         if (fRunParameters->Contains(key)) {
612                 AliWarning(Form("Parameter %s already existing and it will be replaced.", key));
613                 delete fRunParameters->Remove(keyObj);
614
615         }
616         fRunParameters->Add(keyObj, new TObjString(value));
617         AliDebug(2, Form("Number of parameters: %d", fRunParameters->
618         GetEntries()));
619 }
620
621 //______________________________________________________________________________________________
622 const char* AliTestShuttle::GetRunType()
623 {
624         //
625         // get a run parameter
626         //
627
628         return fRunType.Data();
629 }
630
631 //______________________________________________________________________________________________
632 const char* AliTestShuttle::GetRunParameter(const char* key){
633 // get a run parameter
634
635         TObjString* value = dynamic_cast<TObjString*> (fRunParameters->GetValue(key));
636         if(!value) {
637                 AliError(Form("No such parameter: %s", key));
638                 return 0;
639         }
640         return value->GetName();
641 }
642
643 //______________________________________________________________________________________________
644 void AliTestShuttle::SetShuttleTempDir(const char* tmpDir)
645 {
646 // sets Shuttle temp directory
647
648         fgkShuttleTempDir = gSystem->ExpandPathName(tmpDir);
649 }
650
651 //______________________________________________________________________________________________
652 void AliTestShuttle::SetShuttleLogDir(const char* logDir)
653 {
654 // sets Shuttle log directory
655
656         fgkShuttleLogDir = gSystem->ExpandPathName(logDir);
657 }
658
659 //______________________________________________________________________________________________
660 const char* AliTestShuttle::GetTriggerConfiguration()
661 {
662         //returns trigger configuration
663         if (fTriggerConfiguration.Length()>0){
664                 return fTriggerConfiguration;
665         }
666         return NULL;
667 }
668 //______________________________________________________________________________________________
669 const char* AliTestShuttle::GetCTPTimeParams()
670 {
671         //returns trigger configuration
672         if (fCTPtiming.Length()>0){
673                 return fCTPtiming;
674         }
675         return NULL;
676 }
677 //______________________________________________________________________________________________
678 const char* AliTestShuttle::GetTriggerDetectorMask()
679 {
680         //returns trigger detector mask
681         if (fTriggerDetectorMask.Length()>0){
682                 return fTriggerDetectorMask;
683         }
684         return NULL;
685 }
686 //______________________________________________________________________________________________
687 UInt_t AliTestShuttle::GetStartTimeDCSQuery()
688 {
689         // Return Start Time for the DCS query
690         //
691         // The call is delegated to AliShuttleInterface
692
693         return fTimeCreated-fDCSQueryOffset;
694 }
695 //______________________________________________________________________________________________
696 UInt_t AliTestShuttle::GetEndTimeDCSQuery()
697 {
698         // Return End Time for the DCS query
699         //
700         // The call is delegated to AliShuttleInterface
701
702         return fEndTime+fDCSQueryOffset;
703 }