// Author: Jochen Thaeder <thaeder@kip.uni-heidelberg.de> *
// for The ALICE HLT Project. *
+//-*- Mode: C++ -*-
+
/** @file AliEveHOMERManager.cxx
@author Jochen Thaeder
@date
#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
-
+#define EVE_DEBUG 1
+// -- -- -- -- -- -- --
#include "AliHLTHOMERLibManager.h"
-
#include "AliHLTHOMERSourceDesc.h"
#include "AliHLTHOMERBlockDesc.h"
-
+// -- -- -- -- -- -- --
#include "AliEveHOMERSource.h"
-
-#include "AliLog.h"
-
+// -- -- -- -- -- -- --
#include "TString.h"
#include <TApplication.h>
#include "Riostream.h"
#include "TList.h"
#include "TObjString.h"
#include "TObjArray.h"
+// -- -- -- -- -- -- --
+#include "AliLog.h"
+
+//______________________________________________________________________________
+//
+// Manage connections to HLT data-sources.
-// ------------
-#include "AliTPCCalibPedestal.h"
-#include "AliTPCCalibPulser.h"
-#include "AliTPCCalibCE.h"
-#include "AliTPCPreprocessorOnline.h"
-#include "AliTPCCalROC.h"
-// ------------
ClassImp(AliEveHOMERManager)
/*
//##################################################################################
AliEveHOMERManager::AliEveHOMERManager( TString xmlFile ) :
TEveElementList("AliEveHOMERManager"),
-
fLibManager(new AliHLTHOMERLibManager),
- fXMLFile(xmlFile),
- fXMLParser(NULL),
- fRootNode(NULL),
+ fXMLHandler( new AliEveHOMERXMLHandler( xmlFile ) ),
fSourceList(NULL),
fReader(NULL),
fBlockList(NULL),
fCurrentBlk(0),
fConnected(kFALSE),
fStateHasChanged(kTRUE),
- fTPCPre(NULL) {
- // see header file for class documentation
- // or
- // refer to README to build package
- // or
- // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+ fSrcList(NULL) {
+ // This Class should handle the communication
+ // from the HLT to AliEVE. The HLT sends data via
+ // the HOMER interface on several TCP ports of nodes
+ // in the CERN GPN and DCS network.
+ // All this communication is hidden from the user.
+ //
+ // Right now, a xml file ( SCC1 ) is used to get the
+ // configuration, this will/ has to change to a proxy
+ // running on dedicated nodes.
+
}
//##################################################################################
AliEveHOMERManager::~AliEveHOMERManager() {
- // see header file for class documentation
+ // The destructor
if ( fLibManager ) {
if ( fReader )
fReader = NULL;
}
- if ( fXMLParser )
- delete fXMLParser;
- fXMLParser = NULL;
+ if ( fXMLHandler != NULL )
+ delete fXMLHandler;
+ fXMLHandler = NULL;
if ( fSourceList != NULL )
delete fSourceList;
delete fBlockList;
fBlockList = NULL;
- if ( fTPCPre != NULL )
- delete fTPCPre;
- fTPCPre = NULL;
+ if ( fSrcList != NULL )
+ delete fSrcList;
+ fSrcList = NULL;
}
/*
* ---------------------------------------------------------------------------------
- * Source Handling
+ * Source Handling
* ---------------------------------------------------------------------------------
*/
//##################################################################################
Int_t AliEveHOMERManager::CreateHOMERSourcesList() {
- // see header file for class documentation
-
- // -- Initialize XML parser
- if ( fXMLParser != NULL )
- delete fXMLParser;
- fXMLParser = NULL;
-
- fXMLParser = new TDOMParser();
- fXMLParser->SetValidate( kFALSE );
+ // Create Sources List from HOMER-Proxy
- Int_t iResult = fXMLParser->ParseFile( fXMLFile );
- if ( iResult < 0 ) {
- iResult = 1;
- AliError( Form("Parsing file with error: %s", fXMLParser->GetParseCodeMessage( fXMLParser->GetParseCode() )) );
- return iResult;
- }
+ Int_t iResult = 0;
// -- Initialize sources list
DestroyElements();
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
- 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);
- }
+ iResult = fXMLHandler->FillSourceList( fSourceList );
if ( iResult ) {
AliWarning( Form("There have been errors, while creating the sources list.") );
}
else {
AliInfo( Form("New sources list created.") );
+
+ // -- New SourceList has been created --> All Sources are new --> State has changed
+ fStateHasChanged = kTRUE;
+
+ if ( fSrcList )
+ delete fSrcList;
+
+ // -- Create new AliEVE sources list
+ fSrcList = new AliEveHOMERSourceList("HLT Sources");
+ fSrcList->SetManager(this);
+
+ AddElement(fSrcList);
+ fSrcList->CreateByType();
}
return iResult;
//##################################################################################
void AliEveHOMERManager::SetSourceState( AliHLTHOMERSourceDesc * source, Bool_t state ) {
- // see header file for class documentation
-
+ // Set state of a source
+ // * param source Pointer to AliHLTHOMERSourceDesc object.
+ // * param state New (selected/not selected) state.
+
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;
-
- 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()) );
-
- return iResult;
-}
-
/*
* ---------------------------------------------------------------------------------
* Connection Handling
//##################################################################################
Int_t AliEveHOMERManager::ConnectHOMER(){
- // see header file for class documentation
+ // Connect to HOMER sources, out of Readout List, which gets created when state has changed
+ // * return 0 on sucess, "HOMER" errors on error
Int_t iResult = 0;
+ fStateHasChanged = fSrcList->GetSelectedSources();
+
// -- Check if already connected and state has not changed
if ( fStateHasChanged == kFALSE && IsConnected() ) {
AliInfo( Form("No need for reconnection.") );
delete[] sourceHostnames;
delete[] sourcePorts;
-
- // -- Get next event
- if ( ! iResult )
- NextEvent();
-
return iResult;
}
//##################################################################################
void AliEveHOMERManager::DisconnectHOMER(){
- // see header file for class documentation
+ // Disconnect from HOMER sources
if ( ! IsConnected() )
return;
//##################################################################################
Int_t AliEveHOMERManager::ReconnectHOMER(){
- // see header file for class documentation
+ // Reconnect from HOMER sources
+ // * return 0 on sucess, "ConnectHOMER()" errors on error
Int_t iResult = 0;
return iResult;
}
-
//##################################################################################
void AliEveHOMERManager::CreateReadoutList( const char** sourceHostnames, UShort_t *sourcePorts, UInt_t &sourceCount ){
- // see header file for class documentation
+ // Create a readout list for Hostname and ports
+ // * param socurceHostnames Array of selected hostnames
+ // * param socurcePorts Array of selected ports
+ // * param socurceCount Number of selected hostname:port
AliHLTHOMERSourceDesc * source= NULL;
/*
* ---------------------------------------------------------------------------------
- * AliEveEventManager Handling
+ * Event Handling
* ---------------------------------------------------------------------------------
*/
//##################################################################################
Int_t AliEveHOMERManager::NextEvent(){
- // see header file for class documentation
+ // Loads the next Event, after being connected
+ // * return 0 on sucess, "HOMER" errors on error
Int_t iResult = 0;
+ Int_t iRetryCount = 0;
if ( !fReader || ! IsConnected() ) {
AliWarning( Form( "Not connected yet." ) );
return 1;
}
+ // fReader->SetEventRequestAdvanceTime( 20000000 /*timeout in us*/ );
+
// -- Read next event data and error handling for HOMER (error codes and empty blocks)
while( 1 ) {
- iResult = fReader->ReadNextEvent( 20000000 /*timeout in us*/);
+
+ iResult = fReader->ReadNextEvent( 40000000 /*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;
+ 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) );
+ 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;
+
+ ++iRetryCount;
+
+ if ( iRetryCount >= 20 ) {
+ AliError( Form("Retry Failed: Error reading event from source %d: %s (%d)",
+ ndx, strerror(iResult), iResult) );
+ return 4;
+ }
+ else {
+ AliError( Form("Retry: Error reading event from source %d: %s (%d)",
+ 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) );
+ AliError( Form("General Error reading event from source %d: %s (%d)",
+ ndx, strerror(iResult), iResult) );
+ fConnected = kFALSE;
return 2;
}
else {
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
+ AliInfo( Form("Event 0x%016LX (%Lu) with %lu blocks", fEventID, fEventID, fNBlks) );
+#if EVE_DEBUG
// Loop for Debug only
for ( ULong_t i = 0; i < fNBlks; i++ ) {
Char_t tmp1[9], tmp2[5];
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) );
+ 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();
+ AliInfo( Form("Create Block List") );
+ iResult = CreateBlockList();
- return iResult;
+ return iResult;
}
//##################################################################################
Int_t AliEveHOMERManager::CreateBlockList() {
- // see header file for class documentation
+ // Create a TList of blocks, which have been readout
- Int_t iResult = 0;
+ Int_t iResult = 0;
+#if 0
// -- Initialize block list
if ( fBlockList != NULL )
delete fBlockList;
// -- Check sources list if block is requested
if ( CheckIfRequested( block ) )
fBlockList->Add( block );
- else
- delete block;
-
+ else {
+ //The Following 2 line commented out and the previous is added.
+ // delete block;
+ // block = NULL;
+ fBlockList->Add( block );
+ }
iter = GetNextBlk();
} // while ( iter != NULL ){
-
+#endif
return iResult;
}
//##################################################################################
void* AliEveHOMERManager::GetBlk( Int_t ndx ) {
- // see header file for class documentation
-
+ // Get pointer to current block in current event
+ // * param ndx Block index
+ // * return returns pointer to blk, NULL if no block present
+
void* data = NULL;
if ( !fReader || ! IsConnected() ) {
//##################################################################################
ULong_t AliEveHOMERManager::GetBlkSize( Int_t ndx ) {
- // see header file for class documentation
-
+ // Get size of block ndx
+ // * param ndx Block index
+ // * return returns pointer to blk, 0 if no block present
+
ULong_t length = 0;
if ( !fReader || ! IsConnected() ) {
//##################################################################################
TString AliEveHOMERManager::GetBlkOrigin( Int_t ndx ) {
- // see header file for class documentation
+ // Get origin of block ndx
+ // * param ndx Block index
+ // * return origin of block
TString origin = "";
}
//##################################################################################
-TString AliEveHOMERManager:: GetBlkType( Int_t ndx ) {
- // see header file for class documentation
+TString AliEveHOMERManager::GetBlkType( Int_t ndx ) {
+ // Get type of block ndx
+ // * param ndx Block index
+ // * return type of block
TString type = "";
return type;
}
-
//##################################################################################
-ULong_t AliEveHOMERManager:: GetBlkSpecification( Int_t ndx ) {
- // see header file for class documentation
+ULong_t AliEveHOMERManager::GetBlkSpecification( Int_t ndx ) {
+ // Get specification of block ndx
+ // * param ndx Block index
+ // * return specification of block
ULong_t spec = 0;
-
// -- Check for Connection
if ( !fReader || ! IsConnected() ) {
AliError( Form("Not connected yet.") );
}
//##################################################################################
-Bool_t AliEveHOMERManager::CheckIfRequested( AliHLTHOMERBlockDesc * block ) {
- // see header file for class documentation
+Bool_t AliEveHOMERManager::CheckIfRequested( AliHLTHOMERBlockDesc */* block*/ ) {
+ // Checks if current Block should was requested
+ // * return returns kTRUE, if block should was requested
Bool_t requested = kFALSE;
-
+#if 0
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 ( !( block->GetDetector().CompareTo( "*** " ) && block->GetDetector().CompareTo( "***" ) ) ) {
+ // if not any detector
+ if ( source->GetDetector().CompareTo( block->GetDetector() ) )
+ continue;
+ }
- if ( source->GetDataType().CompareTo( block->GetDataType() ) )
- continue;
+ if ( ! ( block->GetDataType().CompareTo( "******* " ) && block->GetDataType().CompareTo( "******* " ) ) ) {
+ 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 ( source->GetSubSubDetector().Atoi() != block->GetSubSubDetector().Atoi() )
+ continue;
} // if ( ! block->HasSubSubDetectorRange ) {
} // if ( ! block->HasSubDetectorRange ) {
requested = kTRUE;
+ break;
} // while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
+
+#if EVE_DEBUG
- 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();
- }
+ if ( block->GetDataType().CompareTo("CLUSTERS") ) {
+ if ( requested ) {
+ AliError( Form("Block requested : %s - %s : %s/%s -> %s ", block->GetDetector().Data(), block->GetDataType().Data(),
+ block->GetSubDetector().Data(), block->GetSubSubDetector().Data(), block->GetClassName().Data() ) );
}
-}
-
-//##################################################################################
-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();
- }
+ else {
+ AliError( Form("Block NOT requested : %s - %s : %s/%s -> %s ", block->GetDetector().Data(), block->GetDataType().Data(),
+ block->GetSubDetector().Data(), block->GetSubSubDetector().Data(), block->GetClassName().Data() ) );
}
-}
-
-//##################################################################################
-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();
- }
}
+#endif
+#endif
+ return requested;
}
-//##################################################################################
-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;
- }
-
-
-}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff