MONITOR without ZEROMQ

[u/mrichter/AliRoot.git] / MONITOR / alistoragemanager / AliDIMListenerThread.cxx

diff --git a/MONITOR/alistoragemanager/AliDIMListenerThread.cxx b/MONITOR/alistoragemanager/AliDIMListenerThread.cxx
deleted file mode 100644 (file)
index 1ad3da6..0000000
--- a/MONITOR/alistoragemanager/AliDIMListenerThread.cxx
+++ /dev/null
@@ -1,116 +0,0 @@
-#include "AliDIMListenerThread.h"
-#include "AliStorageTypes.h"
-
-#include <iostream>
-#include <sstream>
-#include <fstream>
-
-using namespace std;
-
-AliDIMListenerThread::AliDIMListenerThread() : 
-  fDimSORListener(0),
-  fDimEORListener(0),
-  fOnlineReconstructionHostname(""),
-  fOnlineReconstructionUsername("")
-{    
-    ifstream configFile (GetConfigFilePath());
-    
-    if (configFile.is_open())
-    {
-        string line;
-        int from,to;
-        while(configFile.good())
-        {
-            getline(configFile,line);
-            from = line.find("\"")+1;
-            to = line.find_last_of("\"");
-            if(line.find("EVENT_SERVER=")==0){fOnlineReconstructionHostname=line.substr(from,to-from);}
-            else if(line.find("EVENT_SERVER_USER=")==0){fOnlineReconstructionUsername=line.substr(from,to-from);}
-        }
-        if(configFile.eof()){configFile.clear();}
-        configFile.close();
-    }
-    else{cout<<"AliDIMListenerThread -- Unable to open config file"<<endl;}
-
-    InitDIMListeners();
-
-#ifdef ALI_DATE
-    // check if there is a run in partition PHYSICS_1
-    DimCurrentInfo SORrunNumber("/LOGBOOK/SUBSCRIBE/DAQ_SOR_PHYSICS_1",-1);
-    DimCurrentInfo EORrunNumber("/LOGBOOK/SUBSCRIBE/DAQ_EOR_PHYSICS_1",-1);
-
-    if(SORrunNumber.getData() && EORrunNumber.getData())
-    {
-        cout<<"DIM Listener -- current SOR signal:"<<SORrunNumber.getInt()<<endl;
-        cout<<"DIM Listener -- current EOR signal:"<<EORrunNumber.getInt()<<endl;
-        
-        if(SORrunNumber.getInt() != EORrunNumber.getInt()){StartOfRun(SORrunNumber.getInt());}
-    }
-    else{cout<<"AliDIMListenerThread -- no data received from dim server"<<endl;}
-#endif
-}
-
-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];
-        if(fDimEORListener[i]) delete fDimEORListener[i];
-        
-        fDimSORListener[i] = 0;
-        fDimEORListener[i] = 0;
-       }*/
-  cout<<"OK"<<endl;
-}
-
-void AliDIMListenerThread::InitDIMListeners()
-{
-
-#ifdef ALI_DATE
-  /*
-  for (int i = 0; i < 5; ++i)
-  {
-  
-  if (i == 0)
-        {
-            fDimSORListener[i] = new AliDimIntNotifier("/LOGBOOK/SUBSCRIBE/DAQ_SOR_PHYSICS");
-            fDimEORListener[i] = new AliDimIntNotifier("/LOGBOOK/SUBSCRIBE/DAQ_EOR_PHYSICS");
-        }
-        else
-        {
-            fDimSORListener[i] = new AliDimIntNotifier(Form("/LOGBOOK/SUBSCRIBE/DAQ_SOR_PHYSICS_%d", i));
-            fDimEORListener[i] = new AliDimIntNotifier(Form("/LOGBOOK/SUBSCRIBE/DAQ_EOR_PHYSICS_%d", i));
-        }
-        fDimSORListener[i]->Connect("DimMessage(int)", "AliDIMListenerThread", this, "StartOfRun(int)");
-        fDimEORListener[i]->Connect("DimMessage(int)", "AliDIMListenerThread", this, "EndOfRun(int)");
-}
-  */
-  fDimSORListener = new AliDimIntNotifier("/LOGBOOK/SUBSCRIBE/DAQ_SOR_PHYSICS_1");
-  fDimEORListener = new AliDimIntNotifier("/LOGBOOK/SUBSCRIBE/DAQ_EOR_PHYSICS_1");
-  fDimSORListener->Connect("DimMessage(int)", "AliDIMListenerThread", this, "StartOfRun(int)");
-  fDimEORListener->Connect("DimMessage(int)", "AliDIMListenerThread", this, "EndOfRun(int)");
-#endif
-}
-
-void AliDIMListenerThread::StartOfRun(int run)
-{
-    cout<<"AliDIMListenerThread -- SOR signal received for run:"<<run<<endl;
-   
-    // Kill reconstruction and start new one
-    gSystem->Exec(Form("ssh -n -f %s@%s \". ~/EventServerTesting/setEnv.sh;killall alionlinereco;alionlinereco %d\"",fOnlineReconstructionUsername.c_str(),fOnlineReconstructionHostname.c_str(),run));
-}
-
-void AliDIMListenerThread::EndOfRun(int run)
-{
-    cout<<"AliDIMListenerThread -- EOR signal received for run:"<<run<<endl;
-
-    // kill all running reconstructions (to be changed later)
-    gSystem->Exec(Form("ssh -n -f %s@%s \"killall alionlinereco\"",fOnlineReconstructionUsername.c_str(),fOnlineReconstructionHostname.c_str()));
-}