SHUTTLE/AliShuttleTrigger.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.15  2007/12/10 18:29:23  acolla
  19  Some log added to the listen mode
  20
  21  Revision 1.14  2007/12/07 19:14:36  acolla
  22  in AliShuttleTrigger:
  23
  24  Added automatic collection of new runs on a regular time basis (settable from the configuration)
  25
  26  in AliShuttleConfig: new members
  27
  28  - triggerWait: time to wait for DIM trigger (s) before starting automatic collection of new runs
  29  - mode: run mode (test, prod) -> used to build log folder (logs or logs_PROD)
  30
  31  in AliShuttle:
  32
  33  - logs now stored in logs/#RUN/DET_#RUN.log
  34
  35  Revision 1.13  2006/11/16 16:16:48  jgrosseo
  36  introducing strict run ordering flag
  37  removed giving preprocessor name to preprocessor, they have to know their name themselves ;-)
  38
  39  Revision 1.12  2006/10/20 15:22:59  jgrosseo
  40  o) Adding time out to the execution of the preprocessors: The Shuttle forks and the parent process monitors the child
  41  o) Merging Collect, CollectAll, CollectNew function
  42  o) Removing implementation of empty copy constructors (declaration still there!)
  43
  44  Revision 1.11  2006/10/02 16:38:39  jgrosseo
  45  update (alberto):
  46  fixed memory leaks
  47  storing of objects that failed to be stored to the grid before
  48  interfacing of shuttle status table in daq system
  49
  50  Revision 1.10  2006/08/15 10:50:00  jgrosseo
  51  effc++ corrections (alberto)
  52
  53  Revision 1.9  2006/08/08 14:19:29  jgrosseo
  54  Update to shuttle classes (Alberto)
  55
  56  - Possibility to set the full object's path in the Preprocessor's and
  57  Shuttle's  Store functions
  58  - Possibility to extend the object's run validity in the same classes
  59  ("startValidity" and "validityInfinite" parameters)
  60  - Implementation of the StoreReferenceData function to store reference
  61  data in a dedicated CDB storage.
  62
  63  Revision 1.8  2006/07/21 07:37:20  jgrosseo
  64  last run is stored after each run
  65
  66  Revision 1.7  2006/07/20 09:54:40  jgrosseo
  67  introducing status management: The processing per subdetector is divided into several steps,
  68  after each step the status is stored on disk. If the system crashes in any of the steps the Shuttle
  69  can keep track of the number of failures and skips further processing after a certain threshold is
  70  exceeded. These thresholds can be configured in LDAP.
  71
  72  Revision 1.6  2006/07/19 10:09:55  jgrosseo
  73  new configuration, accesst to DAQ FES (Alberto)
  74
  75  Revision 1.5  2006/07/10 13:01:41  jgrosseo
  76  enhanced storing of last sucessfully processed run (alberto)
  77
  78  Revision 1.4  2006/07/04 14:59:57  jgrosseo
  79  revision of AliDCSValue: Removed wrapper classes, reduced storage size per value by factor 2
  80
  81  Revision 1.3  2006/06/12 09:11:16  jgrosseo
  82  coding conventions (Alberto)
  83
  84  Revision 1.2  2006/06/06 14:26:40  jgrosseo
  85  o) removed files that were moved to STEER
  86  o) shuttle updated to follow the new interface (Alberto)
  87
  88  Revision 1.1  2006/03/07 07:52:34  hristov
  89  New version (B.Yordanov)
  90
  91  Revision 1.5  2005/11/21 09:03:48  byordano
  92  one more print added
  93
  94  Revision 1.4  2005/11/20 10:12:37  byordano
  95  comments added to AliShuttleTrigger
  96
  97  */
  98
  99
 100 //
 101 // This class is to deal with DAQ LogBook and DAQ "end of run" notification.
 102 // It has severeal two modes:
 103 //      1) synchronized - Collect()
 104 //      2) asynchronized - Run() - starts listening for DAQ "end of run"
 105 //              notification by DIM service.
 106 //
 107
 108 #include "AliShuttleTrigger.h"
 109
 110 #include <TSystem.h>
 111
 112 #include "AliLog.h"
 113 #include "AliShuttleConfig.h"
 114 #include "AliShuttle.h"
 115 #include "DATENotifier.h"
 116
 117 ClassImp(TerminateSignalHandler)
 118 ClassImp(AliShuttleTrigger)
 119
 120 //______________________________________________________________________________________________
 121 Bool_t TerminateSignalHandler::Notify()
 122 {
 123 // Sentd terminate command to the Shuttle trigger
 124
 125         AliInfo("Terminate signal received ...");
 126         fTrigger->Terminate();
 127
 128         return kTRUE;
 129 }
 130
 131 //______________________________________________________________________________________________
 132 AliShuttleTrigger::AliShuttleTrigger(const AliShuttleConfig* config,
 133                 UInt_t timeout, Int_t retries):
 134         fConfig(config), fShuttle(NULL),
 135         fNotified(kFALSE), fTerminate(kFALSE),
 136         fMutex(), fCondition(&fMutex),
 137         fQuitSignalHandler(0),
 138         fInterruptSignalHandler(0)
 139 {
 140         //
 141         // config - pointer to the AliShuttleConfig object which represents
 142         // the configuration
 143         // mainStorage - pointer to AliCDBStorage for the undelying CDBStorage
 144         // localStorage (local) CDB storage to be used if mainStorage is unavailable
 145         //
 146
 147         if (!fConfig->IsValid()) AliFatal("********** !!!!! Invalid configuration !!!!! **********");
 148         fShuttle = new AliShuttle(config, timeout, retries);
 149
 150         TerminateSignalHandler* fQuitSignalHandler = new TerminateSignalHandler(this, kSigQuit);
 151         TerminateSignalHandler* fInterruptSignalHandler = new TerminateSignalHandler(this, kSigInterrupt);
 152
 153         gSystem->AddSignalHandler(fQuitSignalHandler);
 154         gSystem->AddSignalHandler(fInterruptSignalHandler);
 155
 156 }
 157
 158 //______________________________________________________________________________________________
 159 AliShuttleTrigger::~AliShuttleTrigger()
 160 {
 161   // destructor
 162
 163         gSystem->RemoveSignalHandler(fQuitSignalHandler);
 164         gSystem->RemoveSignalHandler(fInterruptSignalHandler);
 165
 166         delete fShuttle;
 167
 168   delete fQuitSignalHandler;
 169   fQuitSignalHandler = 0;
 170
 171   delete fInterruptSignalHandler;
 172   fInterruptSignalHandler = 0;
 173 }
 174
 175 //______________________________________________________________________________________________
 176 Bool_t AliShuttleTrigger::Notify() {
 177         //
 178         // Trigger Collect() methods in asynchronized (listen) mode.
 179         // Usually called automaticly by DATENotifier on "end of run"
 180         // notification event.
 181         //
 182
 183         fMutex.Lock();
 184
 185         fNotified = kTRUE;
 186         fCondition.Signal();
 187
 188         fMutex.UnLock();
 189
 190         return kTRUE;
 191 }
 192
 193 //______________________________________________________________________________________________
 194 void AliShuttleTrigger::Terminate() {
 195         //
 196         // Stop triggers listen mode and exist from Run()
 197         // Usually called automaticly by TerminateSignalHandler.
 198         //
 199
 200         fTerminate = kTRUE;
 201         fCondition.Signal();
 202 }
 203
 204 //______________________________________________________________________________________________
 205 void AliShuttleTrigger::Run() {
 206         //
 207         // AliShuttleTrigger main loop for asynchronized (listen) mode.
 208         // It spawns DIM service listener and waits for DAQ "end of run"
 209         // notification. Calls Collect() on notification.
 210         //
 211
 212         fTerminate = kFALSE;
 213
 214         DATENotifier* notifier = new DATENotifier(this, "/DATE/LOGBOOK/UPDATE");
 215
 216         Int_t nTry=0;
 217         Int_t nMaxTry = fConfig->GetMaxRetries()+1;
 218         Int_t received=0;
 219
 220         AliInfo("Listening for ECS trigger");
 221
 222         while (1) {
 223
 224                 fMutex.Lock();
 225
 226                 while (!(fNotified || fTerminate)) {
 227                         received=fCondition.TimedWaitRelative(1000*fConfig->GetTriggerWait());
 228                         if (received==1) break; // 1 = timeout
 229                 }
 230
 231                 fNotified = kFALSE;
 232
 233                 fMutex.UnLock();
 234
 235                 if (fTerminate) {
 236                         AliInfo("Terminated.");
 237                         break;
 238                 }
 239
 240                 if (received == 0)
 241                 {
 242                         AliInfo("Trigger from ECS received!");
 243                 } else if (received == 1) {
 244                         AliInfo(Form("Timeout (%d s) waiting for trigger. "
 245                                 "Starting collection of new runs!",
 246                                         fConfig->GetTriggerWait()));
 247                 } else {
 248                         AliInfo("Error receiving trigger from ECS!");
 249                         break;
 250                 }
 251
 252                 nTry++;
 253                 AliInfo(Form("Received %d triggers so far", nTry));
 254
 255                 if (fConfig->GetRunMode() == AliShuttleConfig::kTest)
 256                 {
 257                         if(nTry>=nMaxTry)
 258                         {
 259                                 AliInfo(Form("Collect() ran more than %d times -> Exiting!",
 260                                                 nMaxTry));
 261                                 break;
 262                         }
 263                 }
 264
 265                 Collect();
 266         }
 267
 268         delete notifier;
 269 }
 270
 271 //______________________________________________________________________________________________
 272 Bool_t AliShuttleTrigger::Collect(Int_t run)
 273 {
 274         //
 275         // this function creates a thread that runs the shuttle
 276         // then it checks if the shuttle is still running by checking the monitoring functions of the shuttle
 277         //
 278
 279   return fShuttle->Collect(run);
 280 }