]> git.uio.no Git - u/mrichter/AliRoot.git/commitdiff
Kill all reco processes when storage manager goes down
authorjniedzie <jeremi.niedziela@cern.ch>
Tue, 11 Nov 2014 11:02:09 +0000 (12:02 +0100)
committerjniedzie <jeremi.niedziela@cern.ch>
Tue, 2 Dec 2014 10:58:05 +0000 (11:58 +0100)
MONITOR/alistoragemanager/AliDIMListenerThread.cxx
MONITOR/alistoragemanager/AliStorageClientThread.cxx

index be58af381e0e14ff1381328bed23101586906437..1ad3da6c8585f212e9f6c33ecd259337014540bf 100644 (file)
@@ -52,9 +52,13 @@ AliDIMListenerThread::AliDIMListenerThread() :
 
 AliDIMListenerThread::~AliDIMListenerThread()
 {
+  cout<<"AliDIMListenerThread -- destructor called...";
   if(fDimSORListener){delete fDimSORListener;fDimSORListener = 0;}
   if(fDimEORListener){delete fDimEORListener;fDimEORListener = 0;}
 
+  // kill all running reconstructions (to be changed later)
+    gSystem->Exec(Form("ssh -n -f %s@%s \"killall alionlinereco\"",fOnlineReconstructionUsername.c_str(),fOnlineReconstructionHostname.c_str()));
+
   /*
     for (int i = 0; i < 5; ++i){
         if(fDimSORListener[i]) delete fDimSORListener[i];
@@ -63,6 +67,7 @@ AliDIMListenerThread::~AliDIMListenerThread()
         fDimSORListener[i] = 0;
         fDimEORListener[i] = 0;
        }*/
+  cout<<"OK"<<endl;
 }
 
 void AliDIMListenerThread::InitDIMListeners()
index 25ff3f86fa9f5064510362990ef6a5812f8e28c9..766822690e04d87ac0163b417b890e044c24370e 100644 (file)
@@ -72,6 +72,7 @@ fRemoveEventsPercentage(0)
 AliStorageClientThread::~AliStorageClientThread()
 {
     while(!gClientQuit){sleep(1);}
+    if(fDIMListenerThread){delete fDIMListenerThread;}
     fEventsCollectorThread->Kill();
     fCommunicationThread->Kill();
-}
\ No newline at end of file
+}