Minor bugfixes and extensions for the onlineDiplay Interface
[u/mrichter/AliRoot.git] / EVE / EveHLT / AliEveHOMERManager.cxx
index f773b6b24239175b301506c1d96e453d8a01ae04..55c02e8ce3b44b9a455696187e626a9f981fc1e1 100644 (file)
@@ -1,25 +1,11 @@
+//-*- Mode: C++ -*-
+
 // $Id$
 // Main authors: Matevz Tadel & Alja Mrak-Tadel: 2006, 2007
+// Author: Jochen Thaeder <thaeder@kip.uni-heidelberg.de>                *
+//         for The ALICE HLT Project.                                    *
+
 
-/**************************************************************************
- * Copyright(c) 1998-2008, ALICE Experiment at CERN, all rights reserved. *
- * See http://aliceinfo.cern.ch/Offline/AliRoot/License.html for          *
- * full copyright notice.                                                 *
- **************************************************************************/
-/**************************************************************************
- * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
- *                                                                        *
- * Authors: Jochen Thaeder <thaeder@kip.uni-heidelberg.de>                *
- *          for The ALICE HLT Project.                                    *
- *                                                                        *
- * Permission to use, copy, modify and distribute this software and its   *
- * documentation strictly for non-commercial purposes is hereby granted   *
- * without fee, provided that the above copyright notice appears in all   *
- * copies and that both the copyright notice and this permission notice   *
- * appear in the supporting documentation. The authors make no claims     *
- * about the suitability of this software for any purpose. It is          *
- * provided "as is" without express or implied warranty.                  *
- **************************************************************************/
 
 /** @file   AliEveHOMERManager.cxx
     @author Jochen Thaeder
    using namespace std;
 #endif
 
-#include "AliEveHOMERManager.h"
-
-#define use_aliroot
-#define use_root
-#define ROWHOUGHPARAMS
-#define use_reconstruction
-#define use_newio
-#define ROOTVERSION    "unchecked"
-#define ALIROOTVERSION "unchecked"
-#define __ROOT__
-#define USE_ALILOG
-#define LINUX
+#include "unistd.h"
 
-#include "AliHLTHOMERLibManager.h"
-
-#include "AliHLTHOMERSourceDesc.h"
-#include "AliHLTHOMERBlockDesc.h"
-
-#include "AliEveHOMERSource.h"
-
-#include "AliLog.h"
+#include "AliEveHOMERManager.h"
 
-#include "TString.h"
-#include <TApplication.h>
-#include "Riostream.h"
-#include "TXMLAttr.h"
-#include "TCollection.h"
-#include "TList.h"
-#include "TObjString.h"
-#include "TObjArray.h"
 
-// ------------
-#include "AliTPCCalibPedestal.h"
-#include "AliTPCCalibPulser.h"
-#include "AliTPCCalibCE.h"
-#include "AliTPCPreprocessorOnline.h"
-#include "AliTPCCalROC.h"
-// ------------
 ClassImp(AliEveHOMERManager)
-
+  
 /*
  * ---------------------------------------------------------------------------------
  *                            Constructor / Destructor
  * ---------------------------------------------------------------------------------
  */
-
+  
 //##################################################################################
-AliEveHOMERManager::AliEveHOMERManager( TString xmlFile ) :
-  TEveElementList("AliEveHOMERManager"),
-
-  fLibManager(new AliHLTHOMERLibManager),
-  fXMLFile(xmlFile),
-  fXMLParser(NULL),
-  fRootNode(NULL),
-  fSourceList(NULL),
-  fReader(NULL),
-  fBlockList(NULL),
-  fNBlks(0),
-  fEventID(0),
-  fCurrentBlk(0),
-  fConnected(kFALSE),
-  fStateHasChanged(kTRUE),
-  fTPCPre(NULL) {
+AliEveHOMERManager::AliEveHOMERManager() :
+  AliHLTHOMERManager(), 
+  TEveElementList("Homer Manager"),
+  fSrcList(NULL),
+  fRetryCount(1),
+  fRetrySleeptime(10) {
   // see header file for class documentation
   // or
   // refer to README to build package
@@ -101,1113 +44,87 @@ AliEveHOMERManager::AliEveHOMERManager( TString xmlFile ) :
   // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
 }
 
-//##################################################################################
-AliEveHOMERManager::AliEveHOMERManager( const AliEveHOMERManager& m) :
-  TEveElementList(m.GetName(), m.GetTitle())
-{
-  // see header file for class documentation
-
-  AliError( Form( "copy constructor to be tested." ) );
-}
-
-//##################################################################################
-AliEveHOMERManager& AliEveHOMERManager::operator=( const AliEveHOMERManager& ) {
-  // see header file for class documentation
-
-  AliError( Form( "assignment constructor to be tested." ) );
-  return *this;
-}
-
 //##################################################################################
 AliEveHOMERManager::~AliEveHOMERManager() {
-  // see header file for class documentation
+ // see header file for class documentation 
 
-  if ( fLibManager ) {
-    if ( fReader )
-      fLibManager->DeleteReader(fReader);
-    delete fLibManager;
-    fLibManager = NULL;
-    fReader = NULL;
-  }
-
-  if ( fXMLParser )
-    delete fXMLParser;
-  fXMLParser = NULL;
-
-  if ( fSourceList != NULL )
-    delete fSourceList;
-  fSourceList = NULL;
-
-  if ( fBlockList != NULL )
-    delete fBlockList;
-  fBlockList = NULL;
-
-  if ( fTPCPre != NULL )
-    delete fTPCPre;
-  fTPCPre = NULL;
+  if (fSrcList)
+    delete fSrcList;
+  fSrcList = NULL;
 }
 
 /*
  * ---------------------------------------------------------------------------------
- *                            Source Handling
+ *                                 Source Handling
  * ---------------------------------------------------------------------------------
  */
 
 //##################################################################################
-Int_t AliEveHOMERManager::CreateHOMERSourcesList() {
+Int_t AliEveHOMERManager::CreateEveSourcesList() {
   // see header file for class documentation
 
-  // -- Initialize XML parser
-  if ( fXMLParser != NULL )
-    delete fXMLParser;
-  fXMLParser = NULL;
-
-  fXMLParser = new TDOMParser();
-  fXMLParser->SetValidate( kFALSE );
-
-  Int_t iResult = fXMLParser->ParseFile( fXMLFile );
-  if ( iResult < 0 ) {
-    iResult = 1;
-    AliError( Form("Parsing file with error: %s", fXMLParser->GetParseCodeMessage( fXMLParser->GetParseCode() )) );
-    return iResult;
-  }
-
-  // -- Initialize sources list
   DestroyElements();
-  if ( fSourceList != NULL )
-    delete fSourceList;
-  fSourceList = NULL;
-
-  fSourceList = new TList();
-  fSourceList->SetOwner( kTRUE );
-
-  // -- Set ROOT node
-  fRootNode = fXMLParser->GetXMLDocument()->GetRootNode();
-
-  TXMLNode * node = NULL;
-  TXMLNode * prevNode = fRootNode->GetChildren();
-
-  // -- Loop over all nodes
-  while ( ( node = prevNode->GetNextNode() ) ) {
-    prevNode = node;
-
-    // -- Find only "Process" nodes, otherwise continue to next node
-    if ( strcmp( node->GetNodeName(), "Proc" ) != 0 )
-      continue;
-
-    // -- Get Attributes of current node
-    TList *attrList = node->GetAttributes();
-    TXMLAttr *attr = 0;
-    TIter next(attrList);
-
-    while ( ( attr = (TXMLAttr*)next() ) ) {
-
-      // -- Find "ID" attribute, otherwise continue to next attribute
-      if ( strcmp( attr->GetName(), "ID" ) != 0 )
-       continue;
-
-      TString nodeId( attr->GetValue() );
-
-      // -- Find only TDS processes
-      TObjArray * nodeIdTok = nodeId.Tokenize("_");
-
-      for ( Int_t ii=0 ; ii < nodeIdTok->GetEntries() ; ii++ ) {
-       if ( ! ( (TObjString*) nodeIdTok->At(ii) )->GetString().CompareTo("TDS") ) {
-         iResult = GetTDSAttributes( node->GetChildren() );
-         if ( iResult ) {
-           AliError( Form("Error processing TDS process : %s", nodeId.Data()) );
-         }
-       }
-      }
-    } // while ( ( attr = (TXMLAttr*)next() ) ) {
 
-  } // while ( ( node = prevNode->GetNextNode() ) ) {
-
-  // -- New SourceList has been created --> All Sources are new --> State has changed
+  Int_t iResult = CreateSourcesList();
+  
   fStateHasChanged = kTRUE;
-
-  TIter next(fSourceList);
-  AliHLTHOMERSourceDesc* src = 0;
-  while ((src = (AliHLTHOMERSourceDesc*) next())) {
-    AliEveHOMERSource* re = new AliEveHOMERSource
-      (src,
-       Form("%s-%s-%s %s", src->GetDetector().Data(), src->GetSubDetector().Data(),
-           src->GetSubSubDetector().Data(), src->GetDataType().Data()),
-       "Title?\nNot.");
-    AddElement(re);
-  }
-
-  if ( iResult ) {
-    AliWarning( Form("There have been errors, while creating the sources list.") );
-  }
-  else {
-    AliInfo( Form("New sources list created.") );
-  }
-
-  return iResult;
-}
-
-//##################################################################################
-void AliEveHOMERManager::SetSourceState( AliHLTHOMERSourceDesc * source, Bool_t state ) {
-  // see header file for class documentation
-
-  if ( source->IsSelected() != state ) {
-    source->SetState( state );
-    fStateHasChanged = kTRUE;
-  }
-
-  return;
-}
-
-//##################################################################################
-Int_t AliEveHOMERManager::GetTDSAttributes( TXMLNode * xmlNode ) {
-  // see header file for class documentation
-
-  Int_t iResult = 0;
-
-  TXMLNode * attrNode = NULL;
-  TXMLNode * prevNode = xmlNode;
-
-  TString xmlHostname = 0;
-  TString xmlPort = 0;
-
-  TString hostname = 0;
-  Int_t port = 0;
-
-  // -- Get hostname and port from TDS node out of XML
-  while ( ( attrNode = prevNode->GetNextNode() ) ) {
-    prevNode = attrNode;
-
-    // -- Get port out of the commandline
-    if ( strcmp( attrNode->GetNodeName(), "Cmd" ) == 0 ) {
-      TString cmd( attrNode->GetText() );
-
-      TObjArray * cmdTok = cmd.Tokenize(" ");
-      xmlPort = ((TObjString*) cmdTok->At(2))->GetString();
-    }
-    // -- Get hostname
-    else if ( strcmp( attrNode->GetNodeName(), "Node" ) == 0 )
-      xmlHostname = attrNode->GetText();
-
-  } // while ( ( attrNode = prevNode->GetNextNode() ) ) {
-
-  // -- Resolve hostname and port information
-  iResult = ResolveHostPortInformation ( xmlHostname, xmlPort, hostname, port );
-  if ( iResult == 1 ) {
-    AliError( Form("Error resolving hostname : %s", xmlHostname.Data()) );
-    return iResult;
-  }
-  else if ( iResult == 2 ) {AliInfo( Form("Connection established") );
-    AliError( Form("Error resolving port : %s", xmlPort.Data()) );
-    return iResult;
-  }
-
-  // -- Reset loop to TDS node
-  prevNode = xmlNode;
-
-  // -- Get Sources out of XML, resolve sources, add to sources ListxmlHostname.Data()
-  while ( ( attrNode = prevNode->GetNextNode() ) ) {
-    prevNode = attrNode;
-
-    // Find only "Parent" tags, otherwise continue to next tag
-    if ( strcmp( attrNode->GetNodeName(), "Parent" ) != 0 )
-      continue;
-
-    TString xmlParent = attrNode->GetText();
-
-    AliHLTHOMERSourceDesc * source = new AliHLTHOMERSourceDesc( hostname, port );
-
-    if ( ResolveSourceInformation( xmlParent, source ) ) {
-      iResult = 3;
-      AliError( Form("Error resolving source : %s", xmlParent.Data()) );
-
-      delete source;
-    }
-    else {
-      fSourceList->Add( source );
-      AliInfo( Form("New Source added : %s", xmlParent.Data()) );
-    }
-
-  } // while ( ( attrNode = prevNode->GetNextNode() ) ) {
-
-  return iResult;
-}
-
-//##################################################################################
-Int_t AliEveHOMERManager::ResolveHostPortInformation ( TString xmlHostname, TString xmlPort, TString &hostname, Int_t &port ) {
-  // see header file for class documentation
-
-  Int_t iResult = 1;
-
-  // *** Resolve hostname
-
-  TXMLNode * node = NULL;
-  TXMLNode * prevNode = fRootNode->GetChildren();
-  TString nodeName = 0;
-  while ( ( node = prevNode->GetNextNode() ) && iResult == 1 ) {
-    prevNode = node;
-
-    // -- Find only "Node" nodes, otherwise continue
-    if ( strcmp( node->GetNodeName(), "Node" ) != 0 )
-      continue;
-
-    // -- Get Attributes of current node
-    TList *attrList = node->GetAttributes();
-    TXMLAttr *attr = 0;
-    TIter next(attrList);
-
-    TString nodeId = 0;
-    //    TString nodeName = 0;
-
-    // Get "nodeID" and "nodeName" of this "Node" node
-    while ( ( attr = (TXMLAttr*)next() ) ) {
-      if ( strcmp( attr->GetName(), "ID" ) == 0 )
-       nodeId = attr->GetValue();
-      else if ( strcmp( attr->GetName(), "hostname" ) == 0 )
-       nodeName = attr->GetValue();
-    }
-
-    // -- if this is not the correct nodeID continue
-    if ( nodeId != xmlHostname )
-      continue;
-
-    // -- Set hostname
-
-    // TEMP FIX
-    //    hostname = nodeName;
-    hostname = "alihlt-dcs0";
-
-    iResult = 0;
-
-    break;
-
-  } // while ( ( node = prevNode->GetNextNode() ) ) {
-
-  if ( iResult ) {
-    AliError( Form("Error resolving hostname : %s", xmlHostname.Data()) );
-    return iResult;
-  }
-
-  // *** Resolve port
-
-  if ( xmlPort.IsDigit() ) {
-
-    if ( nodeName.CompareTo("feptriggerdet") ==0 ){
-      if ( xmlPort.CompareTo("49152") == 0 ){
-       port = 58140;
-      } else if ( xmlPort.CompareTo("49153") == 0 ){
-       port = 58141;
-      }
-    } else if ( nodeName.CompareTo("fepfmdaccorde") == 0 ){
-      if ( xmlPort.CompareTo("49152") == 0 ){
-       port = 58144;
-      } else if ( xmlPort.CompareTo("49153") == 0 ){
-       port = 58145;
-      }
-    } else if ( nodeName.CompareTo("feptpcao15") == 0 ){
-      if ( xmlPort.CompareTo("49152") == 0 ){
-       port = 50340;
-      } else if ( xmlPort.CompareTo("49153") == 0 ){
-       port = 50341;
-      }
-    } else if ( nodeName.CompareTo("alihlt-dcs0") == 0 ){
-      port = xmlPort.Atoi();
-    }
-  }
-  else {
-    AliError ( Form("Error resolving port : %s", xmlPort.Data()) );
-    iResult = 2;
-  }
-
-  // *** Summary
-
-  if ( !iResult ) {
-    AliInfo( Form("%s:%i resolved out of %s:%s", hostname.Data(), port, xmlHostname.Data(), xmlPort.Data()) );
-  }
-
-  return iResult;
-}
-
-//##################################################################################
-Int_t AliEveHOMERManager::ResolveSourceInformation( TString xmlParent, AliHLTHOMERSourceDesc *source ) {
-  // see header file for class documentation
-
-  Int_t iResult = 0;
-
-  if ( ! xmlParent.Contains( "_" ) ) {
-    AliError( Form("Source %s could not be resolved", xmlParent.Data() ) );
-    iResult = 1;
-
+  
+  if ( iResult )
     return iResult;
-  }
-
-  TObjArray * parentTokens = xmlParent.Tokenize("_");
-
-  Int_t nEntries = parentTokens->GetEntries();
-
-  TString detector = ((TObjString*) parentTokens->At(0) )->GetString();
-  TString subDetector = "";
-  TString subSubDetector = "";
-  TString dataType = "";
-  ULong_t specification = 0;
-
-  TString name = ((TObjString*) parentTokens->At(1) )->GetString();
-  TString objName = "";
-
-  if ( nEntries == 3 )
-    subDetector = ((TObjString*) parentTokens->At(2) )->GetString();
-  else if ( nEntries == 4 ) {
-    subDetector = ((TObjString*) parentTokens->At(2) )->GetString();
-    subSubDetector = ((TObjString*) parentTokens->At(3) )->GetString();
-  }
-
-  // -- Corecct TPC subdetector, because in we have somtimes "A","C"
-  if ( ! detector.CompareTo("TPC") ) {
-    if ( subDetector.BeginsWith('A') ) {
-      subDetector.Remove( TString::kLeading, 'A' );
-    }
-    else if ( subDetector.BeginsWith('C') ) {
-      subDetector.Remove( TString::kLeading, 'C' );
-      Int_t tmp = subDetector.Atoi() + 18;
-      subDetector = "";
-      subDetector += tmp;
-    }
-  }
-
-  // -- Remove Leading '0' in sub detector and subsubdetector
-  subDetector.Remove( TString::kLeading, '0' );
-  subSubDetector.Remove( TString::kLeading, '0' );
-
-  // -- Set Object Names
-
-  // **** General ****
-  if ( name == "RP" || name == "FP" || name == "Relay" ) {
-    objName = "";
-    dataType = "DDL_RAW";
-    specification = 0;
-  }
-
-  // **** TPC ****
-  else if ( detector == "TPC" ) {
-
-    if ( name == "CalibPedestal" ) {
-      objName = "AliTPCCalibPedestal";
-      dataType = "HIS_CAL";
-      specification = 0;
-    }
-    else if ( name == "CalibPulser" ) {
-      objName = "AliTPCCalibPulser";
-      dataType = "HIS_CAL";
-      specification = 0;
-    }
-    else if ( name == "CF" || name == "RelayCF" ) {
-      objName = "AliHLTTPCClusterDataFormat";
-      dataType = "CLUSTERS";
-      specification = 0;
-    }
-    else if ( name == "ESDConv" ) {
-      objName = "AliESDEvent";
-      dataType = "ESD_TREE";
-      specification = 0;
-    }
-
-  } // if ( detector == "TPC" ) {
-
-  // **** TRD ****
-  else if ( detector == "TRD" ) {
-
-    if ( name == "foo" ) {
-      objName = "bar";
-      dataType = "FOO_BAR";
-      specification = 0;
-    }
-  } // else if ( detector == "TRD" ) {
-
-  // **** PHOS ****
-  else if ( detector == "PHOS" ) {
-
-  } // else if ( detector == "PHOS" ) {
-
-  // **** DIMU ****
-  else if ( detector == "MUON" ) {
-
-  } // else if ( detector == "MUON" ) {
-
-  // -- Fill object
-  source->SetSourceName( name, objName );
-  source->SetSourceType( specification, dataType );
-  source->SetDetectors( detector, subDetector, subSubDetector );
-
-
-  AliInfo( Form("Set Source %s , Type %s, ClassName %s .", name.Data(), dataType.Data(), objName.Data()) );
-  AliInfo( Form("    Detector %s , SubDetector : %s, SubSubDetector %s .",
-               detector.Data(), subDetector.Data(), subSubDetector.Data()) );
 
+  if (fSrcList)
+    delete fSrcList;
+  fSrcList = NULL;
+
+  // -- Create new AliEVE sources list 
+  fSrcList = new AliEveHOMERSourceList("HLT Sources");
+  fSrcList->SetManager(this);
+    
+  AddElement(fSrcList);
+  fSrcList->CreateByType();
+    
   return iResult;
 }
 
-/*
- * ---------------------------------------------------------------------------------
- *                            Connection Handling
- * ---------------------------------------------------------------------------------
- */
-
 //##################################################################################
-Int_t AliEveHOMERManager::ConnectHOMER(){
+Int_t AliEveHOMERManager::CreateEveSourcesListLoop() {
   // see header file for class documentation
 
   Int_t iResult = 0;
 
-  // -- Check if already connected and state has not changed
-  if ( fStateHasChanged == kFALSE && IsConnected() ) {
-    AliInfo( Form("No need for reconnection.") );
-    return iResult;
-  }
-
-  // -- If already connected, disconnect before connect
-  if ( IsConnected() )
-    DisconnectHOMER();
-
-  // *** Create the Readoutlist
-
-  UShort_t* sourcePorts = new UShort_t [fSourceList->GetEntries()];
-  const char ** sourceHostnames = new const char* [fSourceList->GetEntries()];
-  UInt_t sourceCount = 0;
-
-  CreateReadoutList( sourceHostnames, sourcePorts, sourceCount );
-
-  if ( sourceCount == 0 ) {
-    AliError(Form("No sources selected, aborting.") );
-    return iResult;
-  }
-
-  // *** Connect to data sources
-
-  if ( !fReader ) {
-    if ( fLibManager )
-      fReader = fLibManager->OpenReader( sourceCount, sourceHostnames, sourcePorts );
-  }
-
-  iResult = fReader->GetConnectionStatus();
-
-  if ( iResult ) {
-    // -- Connection failed
-
-    UInt_t ndx = fReader->GetErrorConnectionNdx();
-
-    if ( ndx < sourceCount ) {
-      AliError( Form("Error : Error establishing connection to TCP source %s:%hu: %s (%d)",
-                    sourceHostnames[ndx], sourcePorts[ndx], strerror(iResult), iResult) );
+  for ( Int_t retry = 0; retry < fRetryCount ; retry++ ) {
+  
+    iResult = CreateEveSourcesList();
+    if (!iResult) 
+      break;
+    
+    else if (iResult == 1) {
+      HLTWarning( Form("Couldn't find active services, sleeping %d s", fRetryCount) ) ;
+    }   
+    else if (iResult == 2) {
+      HLTWarning( Form("Services List empty, sleeping %d s", fRetryCount) ) ;
     }
     else {
-      AliError( Form("Error : Error establishing connection to unknown source with index %d: %s (%d)",
-                    ndx, strerror(iResult), iResult) );
-    }
-
-    if ( fReader )
-      fLibManager->DeleteReader( fReader );
-    fReader = NULL;
-
+      HLTError( Form("Other problem ... \n") ); 
+      return iResult;
+    } 
+    
+    sleep(fRetrySleeptime);
   }
-  else {
-    // -- Connection ok - set reader
-    fConnected = kTRUE;
-
-    AliInfo( Form("Connection established") );
-  }
-
-  delete[] sourceHostnames;
-  delete[] sourcePorts;
-
-
-  // -- Get next event
-  if ( ! iResult )
-    NextEvent();
-
-  return iResult;
-}
-
-//##################################################################################
-void AliEveHOMERManager::DisconnectHOMER(){
-  // see header file for class documentation
-
-  if ( ! IsConnected() )
-    return;
-
-  if ( fReader )
-    fLibManager->DeleteReader( fReader );
-  fReader = NULL;
-
-  fStateHasChanged = kTRUE;
-  fConnected = kFALSE;
-
-  AliInfo( Form("Connection closed") );
-
-  return;
-}
-
-//##################################################################################
-Int_t AliEveHOMERManager::ReconnectHOMER(){
-  // see header file for class documentation
 
-  Int_t iResult = 0;
-
-  if ( IsConnected() )
-    DisconnectHOMER();
-
-  iResult = ConnectHOMER();
   if ( iResult ) {
-    AliError( Form("Error connecting.") );
-  }
-
-  return iResult;
-}
-
-
-//##################################################################################
-void AliEveHOMERManager::CreateReadoutList( const char** sourceHostnames, UShort_t *sourcePorts, UInt_t &sourceCount ){
-  // see header file for class documentation
-
-  AliHLTHOMERSourceDesc * source= NULL;
-
-  // -- Read all sources and check if they should be read out
-  TIter next( fSourceList );
-  while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
-
-    if ( ! source->IsSelected() )
-      continue;
-
-    Bool_t exists = kFALSE;
-
-    // -- Loop over existing entries and check if entry is already in readout list
-    for ( UInt_t ii = 0; ii < sourceCount; ii++ ){
-      if ( !strcmp( sourceHostnames[ii], source->GetHostname().Data() ) &&  sourcePorts[ii] == source->GetPort() ) {
-       exists = kTRUE;
-       break;
-      }
-    }
-
-    // -- Add new entires to readout list
-    if ( ! exists ) {
-      sourcePorts[sourceCount] = source->GetPort();
-      sourceHostnames[sourceCount] = source->GetHostname().Data();
-      sourceCount++;
-    }
-
-  } // while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
-
-  fStateHasChanged = kFALSE;
-
-  return;
-}
-
-/*
- * ---------------------------------------------------------------------------------
- *                            AliEveEventManager Handling
- * ---------------------------------------------------------------------------------
- */
-
-//##################################################################################
-Int_t AliEveHOMERManager::NextEvent(){
-  // see header file for class documentation
-
-  Int_t iResult = 0;
-
-  if ( !fReader || ! IsConnected() ) {
-    AliWarning( Form( "Not connected yet." ) );
-    return 1;
-  }
-
-  // -- Read next event data and error handling for HOMER (error codes and empty blocks)
-  while( 1 ) {
-    iResult = fReader->ReadNextEvent( 20000000 /*timeout in us*/);
-
-    if ( iResult == 111 || iResult == 32 || iResult == 6 ) {
-      Int_t ndx = fReader->GetErrorConnectionNdx();
-      AliError( Form("Error, No Connection to source %d: %s (%d)", ndx, strerror(iResult), iResult) );
-
-     return 2;
-    }
-    else if ( iResult == 110 ) {
-      Int_t ndx = fReader->GetErrorConnectionNdx();
-      AliError( Form("Timout occured, reading event from source %d: %s (%d)", ndx, strerror(iResult), iResult) );
-      return 3;
-    }
-    else if ( iResult == 56) {
-      Int_t ndx = fReader->GetErrorConnectionNdx();
-      AliError( Form("Error reading event from source %d: %s (%d) -- IRESULTRY", ndx, strerror(iResult), iResult) );
-      continue;
-    }
-    else if ( iResult ) {
-      Int_t ndx = fReader->GetErrorConnectionNdx();
-      AliError( Form("General Error reading event from source %d: %s (%d)", ndx, strerror(iResult), iResult) );
-      return 2;
-    }
-    else {
-      break;
-    }
-  } // while( 1 ) {
-
-  if ( iResult )
-    return iResult;
-
-
-  // -- Get blockCnt and eventID
-  fNBlks = (ULong_t) fReader->GetBlockCnt();
-  fEventID = (ULong64_t) fReader->GetEventID();
-  fCurrentBlk = 0;
-
-  AliInfo( Form("AliEveEventManager 0x%016LX (%Lu) with %lu blocks", fEventID, fEventID, fNBlks) );
-
-#if 1
-
-  // Loop for Debug only
-  for ( ULong_t i = 0; i < fNBlks; i++ ) {
-    Char_t tmp1[9], tmp2[5];
-    memset( tmp1, 0, 9 );
-    memset( tmp2, 0, 5 );
-    void *tmp11 = tmp1;
-    ULong64_t* tmp12 = (ULong64_t*)tmp11;
-    *tmp12 = fReader->GetBlockDataType( i );
-    void *tmp21 = tmp2;
-    ULong_t* tmp22 = (ULong_t*)tmp21;
-    *tmp22 = fReader->GetBlockDataOrigin( i );
-    AliInfo( Form("Block %lu length: %lu - type: %s - origin: %s",i, fReader->GetBlockDataLength( i ), tmp1, tmp2) );
-  } // end for ( ULong_t i = 0; i < fNBlks; i++ ) {
-
-#endif
-
-  // -- Create BlockList
-  CreateBlockList();
-
+    HLTWarning( Form("Couldn't find active services.") );
     return iResult;
-}
-
-//##################################################################################
-Int_t AliEveHOMERManager::CreateBlockList() {
-  // see header file for class documentation
-
-  Int_t iResult = 0;
-
-  // -- Initialize block list
-  if ( fBlockList != NULL )
-    delete fBlockList;
-  fBlockList = NULL;
-
-  fBlockList = new TList();
-  fBlockList->SetOwner( kTRUE );
-
-  void* iter = GetFirstBlk();
-
-  // -- Fill block list
-  while ( iter != NULL ){
-
-    // -- Create new block
-    AliHLTHOMERBlockDesc * block = new AliHLTHOMERBlockDesc( GetBlk(), GetBlkSize(), GetBlkOrigin(),
-                                                            GetBlkType(), GetBlkSpecification() );
-
-    // -- Check sources list if block is requested
-    if ( CheckIfRequested( block ) )
-      fBlockList->Add( block );
-    else
-      delete block;
-
-    iter = GetNextBlk();
-
-  } // while ( iter != NULL ){
-
+  } 
+  
   return iResult;
 }
 
-/*
- * ---------------------------------------------------------------------------------
- *                            BlockHandling
- * ---------------------------------------------------------------------------------
- */
-
-//##################################################################################
-void* AliEveHOMERManager::GetBlk( Int_t ndx ) {
-  // see header file for class documentation
-
-  void* data = NULL;
-
-  if ( !fReader || ! IsConnected() ) {
-    AliError( Form("Not connected yet.") );
-  }
-  else {
-    if ( ( ndx ) < (Int_t) fNBlks )
-      data = (void*) fReader->GetBlockData( ndx );
-  }
-
-  return data;
-}
-
-//##################################################################################
-ULong_t AliEveHOMERManager::GetBlkSize( Int_t ndx ) {
-  // see header file for class documentation
-
-  ULong_t length = 0;
-
-  if ( !fReader || ! IsConnected() ) {
-    AliError( Form("Not connected yet.") );
-  }
-  else {
-    if ( ( ndx ) < (Int_t) fNBlks )
-      length = (ULong_t) fReader->GetBlockDataLength( ndx );
-  }
-
-  return length;
-}
-
-//##################################################################################
-TString AliEveHOMERManager::GetBlkOrigin( Int_t ndx ) {
-  // see header file for class documentation
-
-  TString origin = "";
-
-  // -- Check for Connection
-  if ( !fReader || ! IsConnected() ) {
-    AliError( Form("Not connected yet.") );
-    return origin;
-  }
-
-  // -- Check block index
-  if ( ( ndx ) >= (Int_t) fNBlks ) {
-    AliError( Form("Block index %d out of range.", ndx ) );
-    return origin;
-  }
-
-  // -- Get origin
-  union{
-    UInt_t data;
-    Char_t array[4];
-  } reverseOrigin;
-
-  reverseOrigin.data = (UInt_t) fReader->GetBlockDataOrigin( ndx );
-
-  // -- Reverse the order
-  for (Int_t ii = 3; ii >= 0; ii-- )
-    if ( reverseOrigin.array[ii] != ' ')
-      origin.Append( reverseOrigin.array[ii] );
-
-  return origin;
-}
-
-//##################################################################################
-TString AliEveHOMERManager:: GetBlkType( Int_t ndx ) {
-  // see header file for class documentation
-
-  TString type = "";
-
-  // -- Check for Connection
-  if ( !fReader || ! IsConnected() ) {
-    AliError( Form("Not connected yet.") );
-    return type;
-  }
-
-  // -- Check blockk index
-  if ( ( ndx ) >= (Int_t) fNBlks ) {
-    AliError( Form("Block index %d out of range.", ndx ) );
-    return type;
-  }
-
-  // -- Get type
-  union{
-    ULong64_t data;
-    Char_t array[8];
-  } reverseType;
-
-  reverseType.data = (ULong64_t) fReader->GetBlockDataType( ndx );
-
-  // -- Reverse the order
-  for (Int_t ii = 7; ii >= 0; ii-- )
-    if ( reverseType.array[ii] != ' ')
-      type.Append( reverseType.array[ii] );
-
-  return type;
-}
-
-
 //##################################################################################
-ULong_t AliEveHOMERManager:: GetBlkSpecification( Int_t ndx ) {
+Int_t AliEveHOMERManager::ConnectEVEtoHOMER( TString detector ) {
   // see header file for class documentation
 
-  ULong_t spec = 0;
-
-
-  // -- Check for Connection
-  if ( !fReader || ! IsConnected() ) {
-    AliError( Form("Not connected yet.") );
-    return spec;
-  }
-
-  // -- Check blockk index
-  if ( ( ndx ) >= (Int_t) fNBlks ) {
-    AliError( Form("Block index %d out of range.", ndx ) );
-    return spec;
-  }
-
-  spec = (ULong_t) fReader->GetBlockDataSpec( ndx );
-
-  return spec;
-}
-
-//##################################################################################
-Bool_t AliEveHOMERManager::CheckIfRequested( AliHLTHOMERBlockDesc * block ) {
-  // see header file for class documentation
-
-  Bool_t requested = kFALSE;
-
-  AliHLTHOMERSourceDesc * source= NULL;
-
-  // -- Read all sources and check if they should be read out
-  TIter next( fSourceList );
-  while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
-
-    if ( ! source->IsSelected() )
-      continue;
-
-    if ( source->GetDetector().CompareTo( block->GetDetector() ) )
-      continue;
-
-    if ( source->GetDataType().CompareTo( block->GetDataType() ) )
-      continue;
-
-    if ( ! block->HasSubDetectorRange() ) {
-
-      if ( source->GetSubDetector().Atoi() != block->GetSubDetector().Atoi() )
-       continue;
-
-      if ( ! block->HasSubSubDetectorRange() ) {
-
-       //      if ( source->GetSubSubDetector().Atoi() != block->GetSubSubDetector().Atoi() )
-       //   continue;
-
-      } // if ( ! block->HasSubSubDetectorRange ) {
-    } //  if ( ! block->HasSubDetectorRange ) {
-
-    requested = kTRUE;
-
-  } // while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
-
-  if ( requested) {
-    AliInfo( Form("Block requested : %s - %s : %s/%s -> %s ", block->GetDetector().Data(), block->GetDataType().Data(),
-                 block->GetSubDetector().Data(), block->GetSubSubDetector().Data(), block->GetClassName().Data() ) );
-  }
-  else
-    AliInfo( Form("Block NOT requested : %s - %s : %s/%s -> %s ", block->GetDetector().Data(), block->GetDataType().Data(),              block->GetSubDetector().Data(), block->GetSubSubDetector().Data(), block->GetClassName().Data() ) );
-
-  return requested;
-}
-
-//##################################################################################
-void AliEveHOMERManager::TestSelect() {
-  // see header file for class documentation
-
-  for (Int_t ii =0; ii < fSourceList->GetEntries() ; ii++ ) {
-    if ( (ii%2) == 0 )
-      ((AliHLTHOMERSourceDesc*) fSourceList->At(ii))->Select();
-  }
-}
-
-//##################################################################################
-void AliEveHOMERManager::TestSelectClass( TString objectName ) {
-  // see header file for class documentation
-
-  TList* srcList = GetSourceList();
-
-  AliHLTHOMERSourceDesc *desc = 0;
-
-  TIter next(srcList);
-
-  while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
-    if ( ! desc->GetClassName().CompareTo( objectName ) )
-      desc->Select();
-  }
-}
-
-//##################################################################################
-void AliEveHOMERManager::SelectRawTPC() {
-  // see header file for class documentation
-
-  TList* srcList = GetSourceList();
-
-  AliHLTHOMERSourceDesc *desc = 0;
-
-  TIter next(srcList);
-
-  while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
-    if ( ! desc->GetDataType().CompareTo( "DDL_RAW" ) ) {
-      desc->Select();
-    }
-  }
-}
-
-//##################################################################################
-void AliEveHOMERManager::SelectClusterTPC() {
-  // see header file for class documentation
-
-  TList* srcList = GetSourceList();
-
-  AliHLTHOMERSourceDesc *desc = 0;
-
-  TIter next(srcList);
-
-  while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
-    if ( ! desc->GetDataType().CompareTo( "CLUSTERS" ) ) {
-      desc->Select();
-    }
-  }
-}
-
-//##################################################################################
-void AliEveHOMERManager::SelectESDTPC() {
-  // see header file for class documentation
-
-  TList* srcList = GetSourceList();
-
-  AliHLTHOMERSourceDesc *desc = 0;
-
-  TIter next(srcList);
-
-  while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
-    if ( ! desc->GetDataType().CompareTo( "ESD_TREE" ) ) {
-      desc->Select();
-    }
-  }
-}
-//##################################################################################
-void AliEveHOMERManager::DumpTPCCalib(TString objectName, Bool_t dumpToFile) {
-  // see header file for class documentation
-
-  if ( fTPCPre != NULL )
-    delete fTPCPre;
-
-  fTPCPre = new AliTPCPreprocessorOnline();
-
-  TList* blockList = GetBlockList();
-
-  AliHLTHOMERBlockDesc *desc = 0;
-
-  TIter next(blockList);
-
-  while ( ( desc = (AliHLTHOMERBlockDesc*)next() ) ) {
-    if ( ! desc->IsTObject() )
-      continue;
-
-    Int_t sectorTPC = 0;
-
-    if ( desc->GetSubSubDetector().Atoi() <= 1 ) {
-      sectorTPC = desc->GetSubDetector().Atoi();
-    }
-    else {
-      sectorTPC = 36 + desc->GetSubDetector().Atoi();
-    }
-
-    if ( ! objectName.CompareTo( desc->GetClassName() ) ){
-
-      //
-      // AliTPCCalibPedestal
-      //
-
-      if ( ! objectName.CompareTo( "AliTPCCalibPedestal" ) ) {
-       AliTPCCalROC* calROC = NULL;
-
-       AliTPCCalibPedestal * cal = (AliTPCCalibPedestal*) desc->GetTObject();
-       if ( cal == NULL ) {
-         cout << "error 1" << endl;
-         continue;
-       }
-
-       cal->Analyse();
-
-       calROC = cal->GetCalRocRMS(sectorTPC);
-       if ( calROC == NULL ) {
-         cout << "error 2" << endl;
-         continue;
-       }
-
-       calROC->SetName(Form("RMS_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocPedestal(sectorTPC);
-       if ( calROC == NULL ) {
-         cout << "error 3" << endl;
-         continue;
-       }
-
-
-       calROC->SetName(Form("Pedestal_ROC%d", sectorTPC));
-       cout << "added" << endl;
-       fTPCPre->AddComponent((TObject*) calROC );
-      }
-
-      //
-      // AliTPCCalibPulser
-      //
-      /*
-      else if ( ! objectName.CompareTo( "AliTPCCalibPulser" ) ) {
-       AliTPCCalROC* calROC = NULL;
-
-       AliTPCCalibPulser * cal = (AliTPCCalibPulser*) desc->GetTObject();
-
-       cal->Analyse();
-
-       calROC = cal->GetCalRocT0(sectorTPC);
-       calROC->SetName(Form("T0_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocQ(sectorTPC);
-       calROC->SetName(Form("Q_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocRMS(sectorTPC);
-       calROC->SetName(Form("RMS_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocOutliers(sectorTPC);
-       calROC->SetName(Form("Outliers_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-      }
-
-*/
-      //
-      // AliTPCCalibCE
-      //
-      /*
-      else if ( ! objectName.CompareTo( "AliTPCCalibCE" ) ) {
-       AliTPCCalROC* calROC = NULL;
-
-       AliTPCCalibPulser * cal = (AliTPCCalibPulser*) desc->GetTObject();
-
-       cal->Analyse();
-
-       calROC = cal->GetCalRocT0(sectorTPC);
-       calROC->SetName(Form("T0_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocQ(sectorTPC);
-       calROC->SetName(Form("Q_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocRMS(sectorTPC);
-       calROC->SetName(Form("RMS_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-
-       calROC = cal->GetCalRocOutliers(sectorTPC);
-       calROC->SetName(Form("Outliers_ROC%d", sectorTPC));
-       fTPCPre->AddComponent((TObject*) calROC );
-      }
-      */
-    } // if ( ! objectName.CompareTo( desc->GetClassName() ) ) {
-
-  } // while ( ( desc = (AliHLTHOMERBlockDesc*)next() ) ) {
-
-  if ( dumpToFile ) {
-
-    fTPCPre->DumpToFile("pedestals.root");
-    cout << "DUMP" << endl;
-  }
-
-
+  fStateHasChanged = fSrcList->GetSelectedSources();
+  
+  return ConnectHOMER(detector);
 }