EVE/EveDet/AliEveHOMERManager.cxx

   1 // $Id$
   2 // Main authors: Matevz Tadel & Alja Mrak-Tadel: 2006, 2007
   3
   4 /**************************************************************************
   5  * Copyright(c) 1998-2008, ALICE Experiment at CERN, all rights reserved. *
   6  * See http://aliceinfo.cern.ch/Offline/AliRoot/License.html for          *
   7  * full copyright notice.                                                 *
   8  **************************************************************************/
   9 /**************************************************************************
  10  * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
  11  *                                                                        *
  12  * Authors: Jochen Thaeder <thaeder@kip.uni-heidelberg.de>                *
  13  *          for The ALICE HLT Project.                                    *
  14  *                                                                        *
  15  * Permission to use, copy, modify and distribute this software and its   *
  16  * documentation strictly for non-commercial purposes is hereby granted   *
  17  * without fee, provided that the above copyright notice appears in all   *
  18  * copies and that both the copyright notice and this permission notice   *
  19  * appear in the supporting documentation. The authors make no claims     *
  20  * about the suitability of this software for any purpose. It is          *
  21  * provided "as is" without express or implied warranty.                  *
  22  **************************************************************************/
  23
  24 /** @file   AliEveHOMERManager.cxx
  25     @author Jochen Thaeder
  26     @date
  27     @brief  Manger for HOMER in offline
  28 */
  29
  30 #if __GNUC__>= 3
  31    using namespace std;
  32 #endif
  33
  34 #include "AliEveHOMERManager.h"
  35
  36 #define use_aliroot
  37 #define use_root
  38 #define ROWHOUGHPARAMS
  39 #define use_reconstruction
  40 #define use_newio
  41 #define ROOTVERSION    "unchecked"
  42 #define ALIROOTVERSION "unchecked"
  43 #define __ROOT__
  44 #define USE_ALILOG
  45 #define LINUX
  46
  47 #include "AliHLTHOMERLibManager.h"
  48
  49 #include "AliHLTHOMERSourceDesc.h"
  50 #include "AliHLTHOMERBlockDesc.h"
  51
  52 #include "AliEveHOMERSource.h"
  53
  54 #include "AliLog.h"
  55
  56 #include "TString.h"
  57 #include <TApplication.h>
  58 #include "Riostream.h"
  59 #include "TXMLAttr.h"
  60 #include "TCollection.h"
  61 #include "TList.h"
  62 #include "TObjString.h"
  63 #include "TObjArray.h"
  64
  65 // ------------
  66 #include "AliTPCCalibPedestal.h"
  67 #include "AliTPCCalibPulser.h"
  68 #include "AliTPCCalibCE.h"
  69 #include "AliTPCPreprocessorOnline.h"
  70 #include "AliTPCCalROC.h"
  71 // ------------
  72 ClassImp(AliEveHOMERManager)
  73
  74 /*
  75  * ---------------------------------------------------------------------------------
  76  *                            Constructor / Destructor
  77  * ---------------------------------------------------------------------------------
  78  */
  79
  80 //##################################################################################
  81 AliEveHOMERManager::AliEveHOMERManager( TString xmlFile ) :
  82   TEveElementList("AliEveHOMERManager"),
  83
  84   fLibManager(new AliHLTHOMERLibManager),
  85   fXMLFile(xmlFile),
  86   fXMLParser(NULL),
  87   fRootNode(NULL),
  88   fSourceList(NULL),
  89   fReader(NULL),
  90   fBlockList(NULL),
  91   fNBlks(0),
  92   fEventID(0),
  93   fCurrentBlk(0),
  94   fConnected(kFALSE),
  95   fStateHasChanged(kTRUE),
  96   fTPCPre(NULL) {
  97   // see header file for class documentation
  98   // or
  99   // refer to README to build package
 100   // or
 101   // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
 102 }
 103
 104 //##################################################################################
 105 AliEveHOMERManager::AliEveHOMERManager( const AliEveHOMERManager& m) :
 106   TEveElementList(m.GetName(), m.GetTitle())
 107 {
 108   // see header file for class documentation
 109
 110   AliError( Form( "copy constructor to be tested." ) );
 111 }
 112
 113 //##################################################################################
 114 AliEveHOMERManager& AliEveHOMERManager::operator=( const AliEveHOMERManager& ) {
 115   // see header file for class documentation
 116
 117   AliError( Form( "assignment constructor to be tested." ) );
 118   return *this;
 119 }
 120
 121 //##################################################################################
 122 AliEveHOMERManager::~AliEveHOMERManager() {
 123   // see header file for class documentation
 124
 125   if ( fLibManager ) {
 126     if ( fReader )
 127       fLibManager->DeleteReader(fReader);
 128     delete fLibManager;
 129     fLibManager = NULL;
 130     fReader = NULL;
 131   }
 132
 133   if ( fXMLParser )
 134     delete fXMLParser;
 135   fXMLParser = NULL;
 136
 137   if ( fSourceList != NULL )
 138     delete fSourceList;
 139   fSourceList = NULL;
 140
 141   if ( fBlockList != NULL )
 142     delete fBlockList;
 143   fBlockList = NULL;
 144
 145   if ( fTPCPre != NULL )
 146     delete fTPCPre;
 147   fTPCPre = NULL;
 148 }
 149
 150 /*
 151  * ---------------------------------------------------------------------------------
 152  *                            Source Handling
 153  * ---------------------------------------------------------------------------------
 154  */
 155
 156 //##################################################################################
 157 Int_t AliEveHOMERManager::CreateHOMERSourcesList() {
 158   // see header file for class documentation
 159
 160   // -- Initialize XML parser
 161   if ( fXMLParser != NULL )
 162     delete fXMLParser;
 163   fXMLParser = NULL;
 164
 165   fXMLParser = new TDOMParser();
 166   fXMLParser->SetValidate( kFALSE );
 167
 168   Int_t iResult = fXMLParser->ParseFile( fXMLFile );
 169   if ( iResult < 0 ) {
 170     iResult = 1;
 171     AliError( Form("Parsing file with error: %s", fXMLParser->GetParseCodeMessage( fXMLParser->GetParseCode() )) );
 172     return iResult;
 173   }
 174
 175   // -- Initialize sources list
 176   DestroyElements();
 177   if ( fSourceList != NULL )
 178     delete fSourceList;
 179   fSourceList = NULL;
 180
 181   fSourceList = new TList();
 182   fSourceList->SetOwner( kTRUE );
 183
 184   // -- Set ROOT node
 185   fRootNode = fXMLParser->GetXMLDocument()->GetRootNode();
 186
 187   TXMLNode * node = NULL;
 188   TXMLNode * prevNode = fRootNode->GetChildren();
 189
 190   // -- Loop over all nodes
 191   while ( ( node = prevNode->GetNextNode() ) ) {
 192     prevNode = node;
 193
 194     // -- Find only "Process" nodes, otherwise continue to next node
 195     if ( strcmp( node->GetNodeName(), "Proc" ) != 0 )
 196       continue;
 197
 198     // -- Get Attributes of current node
 199     TList *attrList = node->GetAttributes();
 200     TXMLAttr *attr = 0;
 201     TIter next(attrList);
 202
 203     while ( ( attr = (TXMLAttr*)next() ) ) {
 204
 205       // -- Find "ID" attribute, otherwise continue to next attribute
 206       if ( strcmp( attr->GetName(), "ID" ) != 0 )
 207         continue;
 208
 209       TString nodeId( attr->GetValue() );
 210
 211       // -- Find only TDS processes
 212       TObjArray * nodeIdTok = nodeId.Tokenize("_");
 213
 214       for ( Int_t ii=0 ; ii < nodeIdTok->GetEntries() ; ii++ ) {
 215         if ( ! ( (TObjString*) nodeIdTok->At(ii) )->GetString().CompareTo("TDS") ) {
 216           iResult = GetTDSAttributes( node->GetChildren() );
 217           if ( iResult ) {
 218             AliError( Form("Error processing TDS process : %s", nodeId.Data()) );
 219           }
 220         }
 221       }
 222     } // while ( ( attr = (TXMLAttr*)next() ) ) {
 223
 224   } // while ( ( node = prevNode->GetNextNode() ) ) {
 225
 226   // -- New SourceList has been created --> All Sources are new --> State has changed
 227   fStateHasChanged = kTRUE;
 228
 229   TIter next(fSourceList);
 230   AliHLTHOMERSourceDesc* src = 0;
 231   while ((src = (AliHLTHOMERSourceDesc*) next())) {
 232     AliEveHOMERSource* re = new AliEveHOMERSource
 233       (src,
 234        Form("%s-%s-%s %s", src->GetDetector().Data(), src->GetSubDetector().Data(),
 235             src->GetSubSubDetector().Data(), src->GetDataType().Data()),
 236        "Title?\nNot.");
 237     AddElement(re);
 238   }
 239
 240   if ( iResult ) {
 241     AliWarning( Form("There have been errors, while creating the sources list.") );
 242   }
 243   else {
 244     AliInfo( Form("New sources list created.") );
 245   }
 246
 247   return iResult;
 248 }
 249
 250 //##################################################################################
 251 void AliEveHOMERManager::SetSourceState( AliHLTHOMERSourceDesc * source, Bool_t state ) {
 252   // see header file for class documentation
 253
 254   if ( source->IsSelected() != state ) {
 255     source->SetState( state );
 256     fStateHasChanged = kTRUE;
 257   }
 258
 259   return;
 260 }
 261
 262 //##################################################################################
 263 Int_t AliEveHOMERManager::GetTDSAttributes( TXMLNode * xmlNode ) {
 264   // see header file for class documentation
 265
 266   Int_t iResult = 0;
 267
 268   TXMLNode * attrNode = NULL;
 269   TXMLNode * prevNode = xmlNode;
 270
 271   TString xmlHostname = 0;
 272   TString xmlPort = 0;
 273
 274   TString hostname = 0;
 275   Int_t port = 0;
 276
 277   // -- Get hostname and port from TDS node out of XML
 278   while ( ( attrNode = prevNode->GetNextNode() ) ) {
 279     prevNode = attrNode;
 280
 281     // -- Get port out of the commandline
 282     if ( strcmp( attrNode->GetNodeName(), "Cmd" ) == 0 ) {
 283       TString cmd( attrNode->GetText() );
 284
 285       TObjArray * cmdTok = cmd.Tokenize(" ");
 286       xmlPort = ((TObjString*) cmdTok->At(2))->GetString();
 287     }
 288     // -- Get hostname
 289     else if ( strcmp( attrNode->GetNodeName(), "Node" ) == 0 )
 290       xmlHostname = attrNode->GetText();
 291
 292   } // while ( ( attrNode = prevNode->GetNextNode() ) ) {
 293
 294   // -- Resolve hostname and port information
 295   iResult = ResolveHostPortInformation ( xmlHostname, xmlPort, hostname, port );
 296   if ( iResult == 1 ) {
 297     AliError( Form("Error resolving hostname : %s", xmlHostname.Data()) );
 298     return iResult;
 299   }
 300   else if ( iResult == 2 ) {AliInfo( Form("Connection established") );
 301     AliError( Form("Error resolving port : %s", xmlPort.Data()) );
 302     return iResult;
 303   }
 304
 305   // -- Reset loop to TDS node
 306   prevNode = xmlNode;
 307
 308   // -- Get Sources out of XML, resolve sources, add to sources ListxmlHostname.Data()
 309   while ( ( attrNode = prevNode->GetNextNode() ) ) {
 310     prevNode = attrNode;
 311
 312     // Find only "Parent" tags, otherwise continue to next tag
 313     if ( strcmp( attrNode->GetNodeName(), "Parent" ) != 0 )
 314       continue;
 315
 316     TString xmlParent = attrNode->GetText();
 317
 318     AliHLTHOMERSourceDesc * source = new AliHLTHOMERSourceDesc( hostname, port );
 319
 320     if ( ResolveSourceInformation( xmlParent, source ) ) {
 321       iResult = 3;
 322       AliError( Form("Error resolving source : %s", xmlParent.Data()) );
 323
 324       delete source;
 325     }
 326     else {
 327       fSourceList->Add( source );
 328       AliInfo( Form("New Source added : %s", xmlParent.Data()) );
 329     }
 330
 331   } // while ( ( attrNode = prevNode->GetNextNode() ) ) {
 332
 333   return iResult;
 334 }
 335
 336 //##################################################################################
 337 Int_t AliEveHOMERManager::ResolveHostPortInformation ( TString xmlHostname, TString xmlPort, TString &hostname, Int_t &port ) {
 338   // see header file for class documentation
 339
 340   Int_t iResult = 1;
 341
 342   // *** Resolve hostname
 343
 344   TXMLNode * node = NULL;
 345   TXMLNode * prevNode = fRootNode->GetChildren();
 346   TString nodeName = 0;
 347   while ( ( node = prevNode->GetNextNode() ) && iResult == 1 ) {
 348     prevNode = node;
 349
 350     // -- Find only "Node" nodes, otherwise continue
 351     if ( strcmp( node->GetNodeName(), "Node" ) != 0 )
 352       continue;
 353
 354     // -- Get Attributes of current node
 355     TList *attrList = node->GetAttributes();
 356     TXMLAttr *attr = 0;
 357     TIter next(attrList);
 358
 359     TString nodeId = 0;
 360     //    TString nodeName = 0;
 361
 362     // Get "nodeID" and "nodeName" of this "Node" node
 363     while ( ( attr = (TXMLAttr*)next() ) ) {
 364       if ( strcmp( attr->GetName(), "ID" ) == 0 )
 365         nodeId = attr->GetValue();
 366       else if ( strcmp( attr->GetName(), "hostname" ) == 0 )
 367         nodeName = attr->GetValue();
 368     }
 369
 370     // -- if this is not the correct nodeID continue
 371     if ( nodeId != xmlHostname )
 372       continue;
 373
 374     // -- Set hostname
 375
 376     // TEMP FIX
 377     //    hostname = nodeName;
 378     hostname = "alihlt-dcs0";
 379
 380     iResult = 0;
 381
 382     break;
 383
 384   } // while ( ( node = prevNode->GetNextNode() ) ) {
 385
 386   if ( iResult ) {
 387     AliError( Form("Error resolving hostname : %s", xmlHostname.Data()) );
 388     return iResult;
 389   }
 390
 391   // *** Resolve port
 392
 393   if ( xmlPort.IsDigit() ) {
 394
 395     if ( nodeName.CompareTo("feptriggerdet") ==0 ){
 396       if ( xmlPort.CompareTo("49152") == 0 ){
 397         port = 58140;
 398       } else if ( xmlPort.CompareTo("49153") == 0 ){
 399         port = 58141;
 400       }
 401     } else if ( nodeName.CompareTo("fepfmdaccorde") == 0 ){
 402       if ( xmlPort.CompareTo("49152") == 0 ){
 403         port = 58144;
 404       } else if ( xmlPort.CompareTo("49153") == 0 ){
 405         port = 58145;
 406       }
 407     } else if ( nodeName.CompareTo("feptpcao15") == 0 ){
 408       if ( xmlPort.CompareTo("49152") == 0 ){
 409         port = 50340;
 410       } else if ( xmlPort.CompareTo("49153") == 0 ){
 411         port = 50341;
 412       }
 413     } else if ( nodeName.CompareTo("alihlt-dcs0") == 0 ){
 414       port = xmlPort.Atoi();
 415     }
 416   }
 417   else {
 418     AliError ( Form("Error resolving port : %s", xmlPort.Data()) );
 419     iResult = 2;
 420   }
 421
 422   // *** Summary
 423
 424   if ( !iResult ) {
 425     AliInfo( Form("%s:%i resolved out of %s:%s", hostname.Data(), port, xmlHostname.Data(), xmlPort.Data()) );
 426   }
 427
 428   return iResult;
 429 }
 430
 431 //##################################################################################
 432 Int_t AliEveHOMERManager::ResolveSourceInformation( TString xmlParent, AliHLTHOMERSourceDesc *source ) {
 433   // see header file for class documentation
 434
 435   Int_t iResult = 0;
 436
 437   if ( ! xmlParent.Contains( "_" ) ) {
 438     AliError( Form("Source %s could not be resolved", xmlParent.Data() ) );
 439     iResult = 1;
 440
 441     return iResult;
 442   }
 443
 444   TObjArray * parentTokens = xmlParent.Tokenize("_");
 445
 446   Int_t nEntries = parentTokens->GetEntries();
 447
 448   TString detector = ((TObjString*) parentTokens->At(0) )->GetString();
 449   TString subDetector = "";
 450   TString subSubDetector = "";
 451   TString dataType = "";
 452   ULong_t specification = 0;
 453
 454   TString name = ((TObjString*) parentTokens->At(1) )->GetString();
 455   TString objName = "";
 456
 457   if ( nEntries == 3 )
 458     subDetector = ((TObjString*) parentTokens->At(2) )->GetString();
 459   else if ( nEntries == 4 ) {
 460     subDetector = ((TObjString*) parentTokens->At(2) )->GetString();
 461     subSubDetector = ((TObjString*) parentTokens->At(3) )->GetString();
 462   }
 463
 464   // -- Corecct TPC subdetector, because in we have somtimes "A","C"
 465   if ( ! detector.CompareTo("TPC") ) {
 466     if ( subDetector.BeginsWith('A') ) {
 467       subDetector.Remove( TString::kLeading, 'A' );
 468     }
 469     else if ( subDetector.BeginsWith('C') ) {
 470       subDetector.Remove( TString::kLeading, 'C' );
 471       Int_t tmp = subDetector.Atoi() + 18;
 472       subDetector = "";
 473       subDetector += tmp;
 474     }
 475   }
 476
 477   // -- Remove Leading '0' in sub detector and subsubdetector
 478   subDetector.Remove( TString::kLeading, '0' );
 479   subSubDetector.Remove( TString::kLeading, '0' );
 480
 481   // -- Set Object Names
 482
 483   // **** General ****
 484   if ( name == "RP" || name == "FP" || name == "Relay" ) {
 485     objName = "";
 486     dataType = "DDL_RAW";
 487     specification = 0;
 488   }
 489
 490   // **** TPC ****
 491   else if ( detector == "TPC" ) {
 492
 493     if ( name == "CalibPedestal" ) {
 494       objName = "AliTPCCalibPedestal";
 495       dataType = "HIS_CAL";
 496       specification = 0;
 497     }
 498     else if ( name == "CalibPulser" ) {
 499       objName = "AliTPCCalibPulser";
 500       dataType = "HIS_CAL";
 501       specification = 0;
 502     }
 503     else if ( name == "CF" || name == "RelayCF" ) {
 504       objName = "AliHLTTPCClusterDataFormat";
 505       dataType = "CLUSTERS";
 506       specification = 0;
 507     }
 508     else if ( name == "ESDConv" ) {
 509       objName = "AliESDEvent";
 510       dataType = "ESD_TREE";
 511       specification = 0;
 512     }
 513
 514   } // if ( detector == "TPC" ) {
 515
 516   // **** TRD ****
 517   else if ( detector == "TRD" ) {
 518
 519     if ( name == "foo" ) {
 520       objName = "bar";
 521       dataType = "FOO_BAR";
 522       specification = 0;
 523     }
 524   } // else if ( detector == "TRD" ) {
 525
 526   // **** PHOS ****
 527   else if ( detector == "PHOS" ) {
 528
 529   } // else if ( detector == "PHOS" ) {
 530
 531   // **** DIMU ****
 532   else if ( detector == "MUON" ) {
 533
 534   } // else if ( detector == "MUON" ) {
 535
 536   // -- Fill object
 537   source->SetSourceName( name, objName );
 538   source->SetSourceType( specification, dataType );
 539   source->SetDetectors( detector, subDetector, subSubDetector );
 540
 541
 542   AliInfo( Form("Set Source %s , Type %s, ClassName %s .", name.Data(), dataType.Data(), objName.Data()) );
 543   AliInfo( Form("    Detector %s , SubDetector : %s, SubSubDetector %s .",
 544                 detector.Data(), subDetector.Data(), subSubDetector.Data()) );
 545
 546   return iResult;
 547 }
 548
 549 /*
 550  * ---------------------------------------------------------------------------------
 551  *                            Connection Handling
 552  * ---------------------------------------------------------------------------------
 553  */
 554
 555 //##################################################################################
 556 Int_t AliEveHOMERManager::ConnectHOMER(){
 557   // see header file for class documentation
 558
 559   Int_t iResult = 0;
 560
 561   // -- Check if already connected and state has not changed
 562   if ( fStateHasChanged == kFALSE && IsConnected() ) {
 563     AliInfo( Form("No need for reconnection.") );
 564     return iResult;
 565   }
 566
 567   // -- If already connected, disconnect before connect
 568   if ( IsConnected() )
 569     DisconnectHOMER();
 570
 571   // *** Create the Readoutlist
 572
 573   UShort_t* sourcePorts = new UShort_t [fSourceList->GetEntries()];
 574   const char ** sourceHostnames = new const char* [fSourceList->GetEntries()];
 575   UInt_t sourceCount = 0;
 576
 577   CreateReadoutList( sourceHostnames, sourcePorts, sourceCount );
 578
 579   if ( sourceCount == 0 ) {
 580     AliError(Form("No sources selected, aborting.") );
 581     return iResult;
 582   }
 583
 584   // *** Connect to data sources
 585
 586   if ( !fReader ) {
 587     if ( fLibManager )
 588       fReader = fLibManager->OpenReader( sourceCount, sourceHostnames, sourcePorts );
 589   }
 590
 591   iResult = fReader->GetConnectionStatus();
 592
 593   if ( iResult ) {
 594     // -- Connection failed
 595
 596     UInt_t ndx = fReader->GetErrorConnectionNdx();
 597
 598     if ( ndx < sourceCount ) {
 599       AliError( Form("Error : Error establishing connection to TCP source %s:%hu: %s (%d)",
 600                      sourceHostnames[ndx], sourcePorts[ndx], strerror(iResult), iResult) );
 601     }
 602     else {
 603       AliError( Form("Error : Error establishing connection to unknown source with index %d: %s (%d)",
 604                      ndx, strerror(iResult), iResult) );
 605     }
 606
 607     if ( fReader )
 608       fLibManager->DeleteReader( fReader );
 609     fReader = NULL;
 610
 611   }
 612   else {
 613     // -- Connection ok - set reader
 614     fConnected = kTRUE;
 615
 616     AliInfo( Form("Connection established") );
 617   }
 618
 619   delete[] sourceHostnames;
 620   delete[] sourcePorts;
 621
 622
 623   // -- Get next event
 624   if ( ! iResult )
 625     NextEvent();
 626
 627   return iResult;
 628 }
 629
 630 //##################################################################################
 631 void AliEveHOMERManager::DisconnectHOMER(){
 632   // see header file for class documentation
 633
 634   if ( ! IsConnected() )
 635     return;
 636
 637   if ( fReader )
 638     fLibManager->DeleteReader( fReader );
 639   fReader = NULL;
 640
 641   fStateHasChanged = kTRUE;
 642   fConnected = kFALSE;
 643
 644   AliInfo( Form("Connection closed") );
 645
 646   return;
 647 }
 648
 649 //##################################################################################
 650 Int_t AliEveHOMERManager::ReconnectHOMER(){
 651   // see header file for class documentation
 652
 653   Int_t iResult = 0;
 654
 655   if ( IsConnected() )
 656     DisconnectHOMER();
 657
 658   iResult = ConnectHOMER();
 659   if ( iResult ) {
 660     AliError( Form("Error connecting.") );
 661   }
 662
 663   return iResult;
 664 }
 665
 666
 667 //##################################################################################
 668 void AliEveHOMERManager::CreateReadoutList( const char** sourceHostnames, UShort_t *sourcePorts, UInt_t &sourceCount ){
 669   // see header file for class documentation
 670
 671   AliHLTHOMERSourceDesc * source= NULL;
 672
 673   // -- Read all sources and check if they should be read out
 674   TIter next( fSourceList );
 675   while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
 676
 677     if ( ! source->IsSelected() )
 678       continue;
 679
 680     Bool_t exists = kFALSE;
 681
 682     // -- Loop over existing entries and check if entry is already in readout list
 683     for ( UInt_t ii = 0; ii < sourceCount; ii++ ){
 684       if ( !strcmp( sourceHostnames[ii], source->GetHostname().Data() ) &&  sourcePorts[ii] == source->GetPort() ) {
 685         exists = kTRUE;
 686         break;
 687       }
 688     }
 689
 690     // -- Add new entires to readout list
 691     if ( ! exists ) {
 692       sourcePorts[sourceCount] = source->GetPort();
 693       sourceHostnames[sourceCount] = source->GetHostname().Data();
 694       sourceCount++;
 695     }
 696
 697   } // while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
 698
 699   fStateHasChanged = kFALSE;
 700
 701   return;
 702 }
 703
 704 /*
 705  * ---------------------------------------------------------------------------------
 706  *                            AliEveEventManager Handling
 707  * ---------------------------------------------------------------------------------
 708  */
 709
 710 //##################################################################################
 711 Int_t AliEveHOMERManager::NextEvent(){
 712   // see header file for class documentation
 713
 714   Int_t iResult = 0;
 715
 716   if ( !fReader || ! IsConnected() ) {
 717     AliWarning( Form( "Not connected yet." ) );
 718     return 1;
 719   }
 720
 721   // -- Read next event data and error handling for HOMER (error codes and empty blocks)
 722   while( 1 ) {
 723     iResult = fReader->ReadNextEvent( 20000000 /*timeout in us*/);
 724
 725     if ( iResult == 111 || iResult == 32 || iResult == 6 ) {
 726       Int_t ndx = fReader->GetErrorConnectionNdx();
 727       AliError( Form("Error, No Connection to source %d: %s (%d)", ndx, strerror(iResult), iResult) );
 728
 729      return 2;
 730     }
 731     else if ( iResult == 110 ) {
 732       Int_t ndx = fReader->GetErrorConnectionNdx();
 733       AliError( Form("Timout occured, reading event from source %d: %s (%d)", ndx, strerror(iResult), iResult) );
 734       return 3;
 735     }
 736     else if ( iResult == 56) {
 737       Int_t ndx = fReader->GetErrorConnectionNdx();
 738       AliError( Form("Error reading event from source %d: %s (%d) -- IRESULTRY", ndx, strerror(iResult), iResult) );
 739       continue;
 740     }
 741     else if ( iResult ) {
 742       Int_t ndx = fReader->GetErrorConnectionNdx();
 743       AliError( Form("General Error reading event from source %d: %s (%d)", ndx, strerror(iResult), iResult) );
 744       return 2;
 745     }
 746     else {
 747       break;
 748     }
 749   } // while( 1 ) {
 750
 751   if ( iResult )
 752     return iResult;
 753
 754
 755   // -- Get blockCnt and eventID
 756   fNBlks = (ULong_t) fReader->GetBlockCnt();
 757   fEventID = (ULong64_t) fReader->GetEventID();
 758   fCurrentBlk = 0;
 759
 760   AliInfo( Form("AliEveEventManager 0x%016LX (%Lu) with %lu blocks", fEventID, fEventID, fNBlks) );
 761
 762 #if 1
 763
 764   // Loop for Debug only
 765   for ( ULong_t i = 0; i < fNBlks; i++ ) {
 766     Char_t tmp1[9], tmp2[5];
 767     memset( tmp1, 0, 9 );
 768     memset( tmp2, 0, 5 );
 769     void *tmp11 = tmp1;
 770     ULong64_t* tmp12 = (ULong64_t*)tmp11;
 771     *tmp12 = fReader->GetBlockDataType( i );
 772     void *tmp21 = tmp2;
 773     ULong_t* tmp22 = (ULong_t*)tmp21;
 774     *tmp22 = fReader->GetBlockDataOrigin( i );
 775     AliInfo( Form("Block %lu length: %lu - type: %s - origin: %s",i, fReader->GetBlockDataLength( i ), tmp1, tmp2) );
 776   } // end for ( ULong_t i = 0; i < fNBlks; i++ ) {
 777
 778 #endif
 779
 780   // -- Create BlockList
 781   CreateBlockList();
 782
 783     return iResult;
 784 }
 785
 786 //##################################################################################
 787 Int_t AliEveHOMERManager::CreateBlockList() {
 788   // see header file for class documentation
 789
 790   Int_t iResult = 0;
 791
 792   // -- Initialize block list
 793   if ( fBlockList != NULL )
 794     delete fBlockList;
 795   fBlockList = NULL;
 796
 797   fBlockList = new TList();
 798   fBlockList->SetOwner( kTRUE );
 799
 800   void* iter = GetFirstBlk();
 801
 802   // -- Fill block list
 803   while ( iter != NULL ){
 804
 805     // -- Create new block
 806     AliHLTHOMERBlockDesc * block = new AliHLTHOMERBlockDesc( GetBlk(), GetBlkSize(), GetBlkOrigin(),
 807                                                              GetBlkType(), GetBlkSpecification() );
 808
 809     // -- Check sources list if block is requested
 810     if ( CheckIfRequested( block ) )
 811       fBlockList->Add( block );
 812     else
 813       delete block;
 814
 815     iter = GetNextBlk();
 816
 817   } // while ( iter != NULL ){
 818
 819   return iResult;
 820 }
 821
 822 /*
 823  * ---------------------------------------------------------------------------------
 824  *                            BlockHandling
 825  * ---------------------------------------------------------------------------------
 826  */
 827
 828 //##################################################################################
 829 void* AliEveHOMERManager::GetBlk( Int_t ndx ) {
 830   // see header file for class documentation
 831
 832   void* data = NULL;
 833
 834   if ( !fReader || ! IsConnected() ) {
 835     AliError( Form("Not connected yet.") );
 836   }
 837   else {
 838     if ( ( ndx ) < (Int_t) fNBlks )
 839       data = (void*) fReader->GetBlockData( ndx );
 840   }
 841
 842   return data;
 843 }
 844
 845 //##################################################################################
 846 ULong_t AliEveHOMERManager::GetBlkSize( Int_t ndx ) {
 847   // see header file for class documentation
 848
 849   ULong_t length = 0;
 850
 851   if ( !fReader || ! IsConnected() ) {
 852     AliError( Form("Not connected yet.") );
 853   }
 854   else {
 855     if ( ( ndx ) < (Int_t) fNBlks )
 856       length = (ULong_t) fReader->GetBlockDataLength( ndx );
 857   }
 858
 859   return length;
 860 }
 861
 862 //##################################################################################
 863 TString AliEveHOMERManager::GetBlkOrigin( Int_t ndx ) {
 864   // see header file for class documentation
 865
 866   TString origin = "";
 867
 868   // -- Check for Connection
 869   if ( !fReader || ! IsConnected() ) {
 870     AliError( Form("Not connected yet.") );
 871     return origin;
 872   }
 873
 874   // -- Check block index
 875   if ( ( ndx ) >= (Int_t) fNBlks ) {
 876     AliError( Form("Block index %d out of range.", ndx ) );
 877     return origin;
 878   }
 879
 880   // -- Get origin
 881   union{
 882     UInt_t data;
 883     Char_t array[4];
 884   } reverseOrigin;
 885
 886   reverseOrigin.data = (UInt_t) fReader->GetBlockDataOrigin( ndx );
 887
 888   // -- Reverse the order
 889   for (Int_t ii = 3; ii >= 0; ii-- )
 890     if ( reverseOrigin.array[ii] != ' ')
 891       origin.Append( reverseOrigin.array[ii] );
 892
 893   return origin;
 894 }
 895
 896 //##################################################################################
 897 TString AliEveHOMERManager:: GetBlkType( Int_t ndx ) {
 898   // see header file for class documentation
 899
 900   TString type = "";
 901
 902   // -- Check for Connection
 903   if ( !fReader || ! IsConnected() ) {
 904     AliError( Form("Not connected yet.") );
 905     return type;
 906   }
 907
 908   // -- Check blockk index
 909   if ( ( ndx ) >= (Int_t) fNBlks ) {
 910     AliError( Form("Block index %d out of range.", ndx ) );
 911     return type;
 912   }
 913
 914   // -- Get type
 915   union{
 916     ULong64_t data;
 917     Char_t array[8];
 918   } reverseType;
 919
 920   reverseType.data = (ULong64_t) fReader->GetBlockDataType( ndx );
 921
 922   // -- Reverse the order
 923   for (Int_t ii = 7; ii >= 0; ii-- )
 924     if ( reverseType.array[ii] != ' ')
 925       type.Append( reverseType.array[ii] );
 926
 927   return type;
 928 }
 929
 930
 931 //##################################################################################
 932 ULong_t AliEveHOMERManager:: GetBlkSpecification( Int_t ndx ) {
 933   // see header file for class documentation
 934
 935   ULong_t spec = 0;
 936
 937
 938   // -- Check for Connection
 939   if ( !fReader || ! IsConnected() ) {
 940     AliError( Form("Not connected yet.") );
 941     return spec;
 942   }
 943
 944   // -- Check blockk index
 945   if ( ( ndx ) >= (Int_t) fNBlks ) {
 946     AliError( Form("Block index %d out of range.", ndx ) );
 947     return spec;
 948   }
 949
 950   spec = (ULong_t) fReader->GetBlockDataSpec( ndx );
 951
 952   return spec;
 953 }
 954
 955 //##################################################################################
 956 Bool_t AliEveHOMERManager::CheckIfRequested( AliHLTHOMERBlockDesc * block ) {
 957   // see header file for class documentation
 958
 959   Bool_t requested = kFALSE;
 960
 961   AliHLTHOMERSourceDesc * source= NULL;
 962
 963   // -- Read all sources and check if they should be read out
 964   TIter next( fSourceList );
 965   while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
 966
 967     if ( ! source->IsSelected() )
 968       continue;
 969
 970     if ( source->GetDetector().CompareTo( block->GetDetector() ) )
 971       continue;
 972
 973     if ( source->GetDataType().CompareTo( block->GetDataType() ) )
 974       continue;
 975
 976     if ( ! block->HasSubDetectorRange() ) {
 977
 978       if ( source->GetSubDetector().Atoi() != block->GetSubDetector().Atoi() )
 979         continue;
 980
 981       if ( ! block->HasSubSubDetectorRange() ) {
 982
 983         //      if ( source->GetSubSubDetector().Atoi() != block->GetSubSubDetector().Atoi() )
 984         //   continue;
 985
 986       } // if ( ! block->HasSubSubDetectorRange ) {
 987     } //  if ( ! block->HasSubDetectorRange ) {
 988
 989     requested = kTRUE;
 990
 991   } // while ( ( source = (AliHLTHOMERSourceDesc*)next() ) ) {
 992
 993   if ( requested) {
 994     AliInfo( Form("Block requested : %s - %s : %s/%s -> %s ", block->GetDetector().Data(), block->GetDataType().Data(),
 995                   block->GetSubDetector().Data(), block->GetSubSubDetector().Data(), block->GetClassName().Data() ) );
 996   }
 997   else
 998     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() ) );
 999
1000   return requested;
1001 }
1002
1003 //##################################################################################
1004 void AliEveHOMERManager::TestSelect() {
1005   // see header file for class documentation
1006
1007   for (Int_t ii =0; ii < fSourceList->GetEntries() ; ii++ ) {
1008     if ( (ii%2) == 0 )
1009       ((AliHLTHOMERSourceDesc*) fSourceList->At(ii))->Select();
1010   }
1011 }
1012
1013 //##################################################################################
1014 void AliEveHOMERManager::TestSelectClass( TString objectName ) {
1015   // see header file for class documentation
1016
1017   TList* srcList = GetSourceList();
1018
1019   AliHLTHOMERSourceDesc *desc = 0;
1020
1021   TIter next(srcList);
1022
1023   while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
1024     if ( ! desc->GetClassName().CompareTo( objectName ) )
1025       desc->Select();
1026   }
1027 }
1028
1029 //##################################################################################
1030 void AliEveHOMERManager::SelectRawTPC() {
1031   // see header file for class documentation
1032
1033   TList* srcList = GetSourceList();
1034
1035   AliHLTHOMERSourceDesc *desc = 0;
1036
1037   TIter next(srcList);
1038
1039   while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
1040     if ( ! desc->GetDataType().CompareTo( "DDL_RAW" ) ) {
1041       desc->Select();
1042     }
1043   }
1044 }
1045
1046 //##################################################################################
1047 void AliEveHOMERManager::SelectClusterTPC() {
1048   // see header file for class documentation
1049
1050   TList* srcList = GetSourceList();
1051
1052   AliHLTHOMERSourceDesc *desc = 0;
1053
1054   TIter next(srcList);
1055
1056   while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
1057     if ( ! desc->GetDataType().CompareTo( "CLUSTERS" ) ) {
1058       desc->Select();
1059     }
1060   }
1061 }
1062
1063 //##################################################################################
1064 void AliEveHOMERManager::SelectESDTPC() {
1065   // see header file for class documentation
1066
1067   TList* srcList = GetSourceList();
1068
1069   AliHLTHOMERSourceDesc *desc = 0;
1070
1071   TIter next(srcList);
1072
1073   while ( ( desc = (AliHLTHOMERSourceDesc*)next() ) ) {
1074     if ( ! desc->GetDataType().CompareTo( "ESD_TREE" ) ) {
1075       desc->Select();
1076     }
1077   }
1078 }
1079 //##################################################################################
1080 void AliEveHOMERManager::DumpTPCCalib(TString objectName, Bool_t dumpToFile) {
1081   // see header file for class documentation
1082
1083   if ( fTPCPre != NULL )
1084     delete fTPCPre;
1085
1086   fTPCPre = new AliTPCPreprocessorOnline();
1087
1088   TList* blockList = GetBlockList();
1089
1090   AliHLTHOMERBlockDesc *desc = 0;
1091
1092   TIter next(blockList);
1093
1094   while ( ( desc = (AliHLTHOMERBlockDesc*)next() ) ) {
1095     if ( ! desc->IsTObject() )
1096       continue;
1097
1098     Int_t sectorTPC = 0;
1099
1100     if ( desc->GetSubSubDetector().Atoi() <= 1 ) {
1101       sectorTPC = desc->GetSubDetector().Atoi();
1102     }
1103     else {
1104       sectorTPC = 36 + desc->GetSubDetector().Atoi();
1105     }
1106
1107     if ( ! objectName.CompareTo( desc->GetClassName() ) ){
1108
1109       //
1110       // AliTPCCalibPedestal
1111       //
1112
1113       if ( ! objectName.CompareTo( "AliTPCCalibPedestal" ) ) {
1114         AliTPCCalROC* calROC = NULL;
1115
1116         AliTPCCalibPedestal * cal = (AliTPCCalibPedestal*) desc->GetTObject();
1117         if ( cal == NULL ) {
1118           cout << "error 1" << endl;
1119           continue;
1120         }
1121
1122         cal->Analyse();
1123
1124         calROC = cal->GetCalRocRMS(sectorTPC);
1125         if ( calROC == NULL ) {
1126           cout << "error 2" << endl;
1127           continue;
1128         }
1129
1130         calROC->SetName(Form("RMS_ROC%d", sectorTPC));
1131         fTPCPre->AddComponent((TObject*) calROC );
1132
1133         calROC = cal->GetCalRocPedestal(sectorTPC);
1134         if ( calROC == NULL ) {
1135           cout << "error 3" << endl;
1136           continue;
1137         }
1138
1139
1140         calROC->SetName(Form("Pedestal_ROC%d", sectorTPC));
1141         cout << "added" << endl;
1142         fTPCPre->AddComponent((TObject*) calROC );
1143       }
1144
1145       //
1146       // AliTPCCalibPulser
1147       //
1148       /*
1149       else if ( ! objectName.CompareTo( "AliTPCCalibPulser" ) ) {
1150         AliTPCCalROC* calROC = NULL;
1151
1152         AliTPCCalibPulser * cal = (AliTPCCalibPulser*) desc->GetTObject();
1153
1154         cal->Analyse();
1155
1156         calROC = cal->GetCalRocT0(sectorTPC);
1157         calROC->SetName(Form("T0_ROC%d", sectorTPC));
1158         fTPCPre->AddComponent((TObject*) calROC );
1159
1160         calROC = cal->GetCalRocQ(sectorTPC);
1161         calROC->SetName(Form("Q_ROC%d", sectorTPC));
1162         fTPCPre->AddComponent((TObject*) calROC );
1163
1164         calROC = cal->GetCalRocRMS(sectorTPC);
1165         calROC->SetName(Form("RMS_ROC%d", sectorTPC));
1166         fTPCPre->AddComponent((TObject*) calROC );
1167
1168         calROC = cal->GetCalRocOutliers(sectorTPC);
1169         calROC->SetName(Form("Outliers_ROC%d", sectorTPC));
1170         fTPCPre->AddComponent((TObject*) calROC );
1171       }
1172
1173 */
1174       //
1175       // AliTPCCalibCE
1176       //
1177       /*
1178       else if ( ! objectName.CompareTo( "AliTPCCalibCE" ) ) {
1179         AliTPCCalROC* calROC = NULL;
1180
1181         AliTPCCalibPulser * cal = (AliTPCCalibPulser*) desc->GetTObject();
1182
1183         cal->Analyse();
1184
1185         calROC = cal->GetCalRocT0(sectorTPC);
1186         calROC->SetName(Form("T0_ROC%d", sectorTPC));
1187         fTPCPre->AddComponent((TObject*) calROC );
1188
1189         calROC = cal->GetCalRocQ(sectorTPC);
1190         calROC->SetName(Form("Q_ROC%d", sectorTPC));
1191         fTPCPre->AddComponent((TObject*) calROC );
1192
1193         calROC = cal->GetCalRocRMS(sectorTPC);
1194         calROC->SetName(Form("RMS_ROC%d", sectorTPC));
1195         fTPCPre->AddComponent((TObject*) calROC );
1196
1197         calROC = cal->GetCalRocOutliers(sectorTPC);
1198         calROC->SetName(Form("Outliers_ROC%d", sectorTPC));
1199         fTPCPre->AddComponent((TObject*) calROC );
1200       }
1201       */
1202     } // if ( ! objectName.CompareTo( desc->GetClassName() ) ) {
1203
1204   } // while ( ( desc = (AliHLTHOMERBlockDesc*)next() ) ) {
1205
1206   if ( dumpToFile ) {
1207
1208     fTPCPre->DumpToFile("pedestals.root");
1209     cout << "DUMP" << endl;
1210   }
1211
1212
1213 }