4 // Main authors: Matevz Tadel & Alja Mrak-Tadel: 2006, 2007 *
5 // Author: Jochen Thaeder <thaeder@kip.uni-heidelberg.de> *
6 // Author: 2010 Svein Lindal <slindal@fys.uio.no> *
7 // for The ALICE HLT Project. *
11 /** @file AliEveHOMERManager.cxx
12 @author Jochen Thaeder, Svein Lindal <slindal@fys.uio.no>
14 @brief Manager for HOMER online
22 #include "TEveManager.h"
24 #include "TEveScene.h"
25 #include "TEveProjectionManager.h"
26 #include "TEveBrowser.h"
28 #include "AliEveHOMERManager.h"
29 #include "AliHLTHOMERBlockDesc.h"
30 #include "AliHLTHOMERManager.h"
31 #include "AliHLTTriggerDecision.h"
32 #include "AliHLTEvePhos.h"
33 #include "AliHLTEveEmcal.h"
34 #include "AliHLTEveTPC.h"
35 #include "AliHLTEveHLT.h"
36 #include "AliHLTEveITS.h"
37 #include "AliHLTEveISPD.h"
38 #include "AliHLTEveISSD.h"
39 #include "AliHLTEveISDD.h"
40 #include "AliHLTEveTRD.h"
41 #include "AliHLTEveMuon.h"
42 #include "AliHLTEveAny.h"
43 #include "AliEveHOMERSourceList.h"
47 ClassImp(AliEveHOMERManager)
50 * ---------------------------------------------------------------------------------
51 * Constructor / Destructor
52 * ---------------------------------------------------------------------------------
55 //##################################################################################
56 AliEveHOMERManager::AliEveHOMERManager() :
57 TEveElementList("Homer Manager"),
66 fRPhiEventScene(NULL),
67 fRhoZEventScene(NULL),
69 // fSourceListTimer(NULL),
81 fEventLoopStarted(kFALSE),
82 fCenterProjectionsAtPrimaryVertex(kFALSE),
86 // see header file for class documentation
88 // refer to README to build package
90 // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
92 fTimer = new TTimer();
93 fTimer->Connect("Timeout()", "AliEveHOMERManager", this, "NextHOMEREvent()" );
95 //fSourceListTimer = new TTimer();
97 fPhosElement = new AliHLTEvePhos();
98 fPhosElement->SetEventManager(this);
100 fEmcalElement = new AliHLTEveEmcal();
101 fEmcalElement->SetEventManager(this);
103 fTPCElement = new AliHLTEveTPC();
104 fTPCElement->SetEventManager(this);
106 fHLTElement = new AliHLTEveHLT();
107 fHLTElement->SetEventManager(this);
109 fITSElement = new AliHLTEveITS();
110 fITSElement->SetEventManager(this);
112 fISPDElement = new AliHLTEveISPD();
113 fISPDElement->SetEventManager(this);
115 fISDDElement = new AliHLTEveISDD();
116 fISDDElement->SetEventManager(this);
118 fISSDElement = new AliHLTEveISSD();
119 fISSDElement->SetEventManager(this);
121 fTRDElement = new AliHLTEveTRD();
122 fTRDElement->SetEventManager(this);
126 //##################################################################################
127 AliEveHOMERManager::~AliEveHOMERManager() {
128 // see header file for class documentation
131 DestroyDetectorElements();
137 void AliEveHOMERManager::DestroyDetectorElements(){
138 //See header file for documentation
148 delete fEmcalElement;
149 fEmcalElement = NULL;
193 * ---------------------------------------------------------------------------------
195 * ---------------------------------------------------------------------------------
198 //##################################################################################
199 Int_t AliEveHOMERManager::CreateEveSourcesList() {
200 // see header file for class documentation
204 Int_t iResult = CreateSourcesList();
206 // fStateHasChanged = kTRUE;
208 HLTDebug(Form("iResult XXX %d", iResult));
213 HLTDebug(Form("iResult %d", iResult));
215 HLTInfo(Form("delete source list", iResult));
220 HLTInfo(Form("cleared source list", iResult));
224 // -- Create new AliEVE sources list
226 HLTInfo(Form("no source list", iResult));
227 fSrcList = new AliEveHOMERSourceList("HLT Sources");
228 fSrcList->SetManager(this);
230 AddElement(fSrcList);
233 //HLTInfo(Form("createbytype", iResult));
234 fSrcList->CreateByDet();
236 HLTDebug(Form("Done createing source list %d", iResult));
243 //##################################################################################
244 Int_t AliEveHOMERManager::CreateEveSourcesListLoop() {
245 // see header file for class documentation
249 for ( Int_t retry = 0; retry < fRetryCount ; retry++ ) {
251 iResult = CreateEveSourcesList();
254 HLTInfo("Source list successfully created.");
257 else if (iResult == 1) {
258 HLTWarning( Form("Couldn't find active services, sleeping %d s before making attempt %d out of %d", fRetrySleeptime, retry, fRetryCount) ) ;
260 else if (iResult == 2) {
261 HLTWarning( Form("Services List empty, sleeping %d s before making new attempt.", fRetrySleeptime) ) ;
264 HLTError( Form("Other problem ... \n") );
268 //fSourceListTimer->Start(fRetrySleeptime, kFALSE);
269 sleep(fRetrySleeptime);
274 HLTWarning( Form("Couldn't find active services.") );
281 //##################################################################################
282 Int_t AliEveHOMERManager::ConnectEVEtoHOMER( TString detector ) {
283 // see header file for class documentation
286 fStateHasChanged = fSrcList->GetSelectedSources();
287 HLTInfo(Form("has state changed % d", fStateHasChanged));
288 return ConnectHOMER(detector);
292 //##################################################################################
293 Int_t AliEveHOMERManager::ReConnectHOMER( TString detector ){
294 // see header file for class documentation
299 iResult = CreateEveSourcesListLoop();
300 HLTInfo("Created new source list, reconnect to HOMER");
301 iResult = ConnectEVEtoHOMER();
303 HLTError(Form("Error reconnecting."));
310 //_____________________________________________________________________________________
311 Int_t AliEveHOMERManager::NextHOMEREvent() {
312 //See header file for documentation
317 AliHLTHOMERBlockDesc * block = NULL;
321 HLTInfo("Failed getting next event, trying to reconnect");
322 iResult = ReConnectHOMER();
323 return NextHOMEREvent();
327 //We have a new event, reset display items (need to check if there really is anything interesting in event before resetting. ie not just histos)
330 //Process the SYNCED block list
331 if ( GetBlockList() == NULL) {
332 printf ("onlineDisplay: No regular BlockList ... \n");
338 if (GetBlockList()->IsEmpty() ) {
339 printf ("onlineDisplay: No Sync Blocks in list ... \n");
345 TIter next(GetBlockList());
347 while ((block = (AliHLTHOMERBlockDesc*)next())) {
354 //Read out histograms and elements from detectors outside physics 1 partition
355 TIter anext(GetAsyncBlockList());
357 while ( (block = (AliHLTHOMERBlockDesc*)anext()) ) {
367 void AliEveHOMERManager::UpdateDisplay() {
368 //See header file for documentation
369 fPhosElement->UpdateElements();
370 fEmcalElement->UpdateElements();
371 fTPCElement->UpdateElements();
372 fHLTElement->UpdateElements();
373 fITSElement->UpdateElements();
374 fISSDElement->UpdateElements();
375 fISDDElement->UpdateElements();
376 fISPDElement->UpdateElements();
377 fTRDElement->UpdateElements();
378 if(fAnyElement) fAnyElement->UpdateElements();
379 if(fMuonElement) fMuonElement->UpdateElements();
382 // -- Set EventID in Window Title
383 TString winTitle("Eve Main Window -- Event ID : ");
384 winTitle += Form("0x%016X ", GetEventID() );
385 GetEveManager()->GetBrowser()->SetWindowName(winTitle);
387 //==============================================================================
388 // -- Import global scene into projection scenes
389 //==============================================================================
391 // XXX Primary vertex ... to be retrieved from the ESD
392 Double_t x[3] = { 0, 0, 0 };
394 TEveElement* top = GetEveManager()->GetCurrentEvent();
396 if (fRPhiManager && top) {
397 fRPhiEventScene->DestroyElements();
398 if (fCenterProjectionsAtPrimaryVertex)
399 fRPhiManager->SetCenter(x[0], x[1], x[2]);
400 fRPhiManager->ImportElements(top, fRPhiEventScene);
403 if (fRhoZManager && top) {
404 fRhoZEventScene->DestroyElements();
405 if (fCenterProjectionsAtPrimaryVertex)
406 fRhoZManager->SetCenter(x[0], x[1], x[2]);
407 fRhoZManager->ImportElements(top, fRhoZEventScene);
412 GetEveManager()->Redraw3D(0,1); // (0, 1)
413 GetEveManager()->EnableRedraw();
417 void AliEveHOMERManager::ProcessBlock(AliHLTHOMERBlockDesc * block) {
418 //See header file for documentation
421 printf( "------------------- xxxxxxxxxxxxxxx ----------------------\n");
422 printf( "Detector : %s\n", block->GetDetector().Data() );
423 printf( "Datatype : %s\n", block->GetDataType().Data() );
424 if (block->IsTObject() )
425 printf( "Is TObject of class: %s\n", block->GetClassName().Data() );
426 printf( "------------------- xxxxxxxxxxxxxxx ----------------------\n");
432 if ( ! block->GetDetector().CompareTo("PHOS") )
433 fPhosElement->ProcessBlock(block);
435 else if ( ! block->GetDetector().CompareTo("EMCA") )
436 fEmcalElement->ProcessBlock(block);
438 else if ( ! block->GetDetector().CompareTo("TPC") )
439 fTPCElement->ProcessBlock(block);
441 else if ( ! block->GetDetector().CompareTo("HLT") )
442 fHLTElement->ProcessBlock(block);
444 else if ( ! block->GetDetector().CompareTo("ITS") )
445 fITSElement->ProcessBlock(block);
447 else if ( ! block->GetDetector().CompareTo("ISDD") )
448 fISDDElement->ProcessBlock(block);
450 else if ( ! block->GetDetector().CompareTo("ISPD") )
451 fISPDElement->ProcessBlock(block);
453 else if ( ! block->GetDetector().CompareTo("ISSD") )
454 fISSDElement->ProcessBlock(block);
456 else if ( ! block->GetDetector().CompareTo("TRD") )
457 fTRDElement->ProcessBlock(block);
459 else if ( ! block->GetDetector().CompareTo("MUON") ) {
465 fAnyElement = new AliHLTEveAny();
466 fAnyElement->SetEventManager(this);
468 fAnyElement->ProcessBlock(block);
475 if ( ! block->GetDetector().CompareTo("MUON") ) {
477 fMuonElement = new AliHLTEveMuon();
478 fMuonElement->SetEventManager(this);
480 fMuonElement->ProcessBlock(block);
486 void AliEveHOMERManager::ResetDisplay () {
487 //See header file for documentation
490 fPhosElement->ResetElements();
493 fEmcalElement->ResetElements();
496 fTPCElement->ResetElements();
499 fHLTElement->ResetElements();
502 fITSElement->ResetElements();
505 fISPDElement->ResetElements();
508 fISDDElement->ResetElements();
511 fISSDElement->ResetElements();
514 fTRDElement->ResetElements();
517 fAnyElement->ResetElements();
520 fMuonElement->ResetElements();
525 void AliEveHOMERManager::StartLoop() {
526 //See header file for documentation
527 //fTimer->SetCommand("NextEvent()", "AliEveHOMERManager", this);
528 SetEventLoopStarted(kTRUE);
532 void AliEveHOMERManager::StopLoop() {
533 //See header file for documentation
535 SetEventLoopStarted(kFALSE);
538 // void AliEveHOMERManager::TimeOut(Int_t sec) {
540 // TTimer t(sec*1000, kFALSE);
542 // cout << "Start timer for " << sec << " seconds" << endl;
544 // while (!t.CheckTimer(gSystem->Now()))
545 // gSystem->Sleep(100); // 100 ms sleep
547 // cout << "Timed out." << endl;