make the buffer size check a bit less strict in order to workaround a bug/feature...

[u/mrichter/AliRoot.git] / SHUTTLE / AliShuttleTrigger.cxx

diff --git a/SHUTTLE/AliShuttleTrigger.cxx b/SHUTTLE/AliShuttleTrigger.cxx
index 8599c4b76e79867d84f1ad23b191a329512c0129..18730e00f19b69b8a92cc9432bdd27163ecb55d8 100644 (file)
--- a/SHUTTLE/AliShuttleTrigger.cxx
+++ b/SHUTTLE/AliShuttleTrigger.cxx
@@ -15,6 +15,9 @@
 
 /*
  $Log$
+ Revision 1.15  2007/12/10 18:29:23  acolla
+ Some log added to the listen mode
+
  Revision 1.14  2007/12/07 19:14:36  acolla
  in AliShuttleTrigger:
 
@@ -126,8 +129,7 @@ Bool_t TerminateSignalHandler::Notify()
 }
 
 //______________________________________________________________________________________________
-AliShuttleTrigger::AliShuttleTrigger(const AliShuttleConfig* config,
-               UInt_t timeout, Int_t retries):
+AliShuttleTrigger::AliShuttleTrigger(const AliShuttleConfig* config):
        fConfig(config), fShuttle(NULL),
        fNotified(kFALSE), fTerminate(kFALSE),
        fMutex(), fCondition(&fMutex),
@@ -142,10 +144,12 @@ AliShuttleTrigger::AliShuttleTrigger(const AliShuttleConfig* config,
        //
 
        if (!fConfig->IsValid()) AliFatal("********** !!!!! Invalid configuration !!!!! **********");
+       UInt_t timeout = fConfig->GetDCSTimeOut();
+       Int_t retries = fConfig->GetDCSRetries();
        fShuttle = new AliShuttle(config, timeout, retries);
 
-       TerminateSignalHandler* fQuitSignalHandler = new TerminateSignalHandler(this, kSigQuit);
-       TerminateSignalHandler* fInterruptSignalHandler = new TerminateSignalHandler(this, kSigInterrupt);
+       fQuitSignalHandler = new TerminateSignalHandler(this, kSigQuit);
+       fInterruptSignalHandler = new TerminateSignalHandler(this, kSigInterrupt);
 
        gSystem->AddSignalHandler(fQuitSignalHandler);
        gSystem->AddSignalHandler(fInterruptSignalHandler);
@@ -208,7 +212,7 @@ void AliShuttleTrigger::Run() {
 
        fTerminate = kFALSE;
 
-       DATENotifier* notifier = new DATENotifier(this, "/DATE/LOGBOOK/UPDATE");
+       DATENotifier* notifier = new DATENotifier(this, "/LOGBOOK/SUBSCRIBE/ECS_EOR");
 
        Int_t nTry=0; 
        Int_t nMaxTry = fConfig->GetMaxRetries()+1;
@@ -246,10 +250,11 @@ void AliShuttleTrigger::Run() {
                        break;
                }
                
+               nTry++;
+               AliInfo(Form("Received %d triggers so far", nTry));
+               
                if (fConfig->GetRunMode() == AliShuttleConfig::kTest)
                {
-                       nTry++;
-                       AliInfo(Form("Received %d triggers so far", nTry));
                        if(nTry>=nMaxTry)
                        {
                                AliInfo(Form("Collect() ran more than %d times -> Exiting!",