From 36100d03bdf629a75817731c29eb1c7393c7b3fa Mon Sep 17 00:00:00 2001
From: jniedzie <jeremi.niedziela@cern.ch>
Date: Tue, 11 Nov 2014 12:02:09 +0100
Subject: [PATCH] Kill all reco processes when storage manager goes down

---
 MONITOR/alistoragemanager/AliDIMListenerThread.cxx   | 5 +++++
 MONITOR/alistoragemanager/AliStorageClientThread.cxx | 3 ++-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/MONITOR/alistoragemanager/AliDIMListenerThread.cxx b/MONITOR/alistoragemanager/AliDIMListenerThread.cxx
index be58af381e0..1ad3da6c858 100644
--- a/MONITOR/alistoragemanager/AliDIMListenerThread.cxx
+++ b/MONITOR/alistoragemanager/AliDIMListenerThread.cxx
@@ -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()
diff --git a/MONITOR/alistoragemanager/AliStorageClientThread.cxx b/MONITOR/alistoragemanager/AliStorageClientThread.cxx
index 25ff3f86fa9..766822690e0 100644
--- a/MONITOR/alistoragemanager/AliStorageClientThread.cxx
+++ b/MONITOR/alistoragemanager/AliStorageClientThread.cxx
@@ -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
+}
-- 
2.43.0