2 /**************************************************************************
3 * This file is property of and copyright by the ALICE HLT Project *
4 * ALICE Experiment at CERN, All rights reserved. *
6 * Primary Authors: Artur Szostak <artursz@iafrica.com> *
7 * for The ALICE HLT Project. *
9 * Permission to use, copy, modify and distribute this software and its *
10 * documentation strictly for non-commercial purposes is hereby granted *
11 * without fee, provided that the above copyright notice appears in all *
12 * copies and that both the copyright notice and this permission notice *
13 * appear in the supporting documentation. The authors make no claims *
14 * about the suitability of this software for any purpose. It is *
15 * provided "as is" without express or implied warranty. *
16 **************************************************************************/
18 /// @file AliHLTGlobalTriggerComponent.cxx
19 /// @author Artur Szostak <artursz@iafrica.com>
21 /// @brief Implementation of the AliHLTGlobalTriggerComponent component class.
23 /// The AliHLTGlobalTriggerComponent class applies the global HLT trigger to all
24 /// trigger information produced by components deriving from AliHLTTrigger.
26 #include "AliHLTGlobalTriggerComponent.h"
27 #include "AliHLTGlobalTriggerDecision.h"
28 #include "AliHLTGlobalTrigger.h"
29 #include "AliHLTGlobalTriggerConfig.h"
30 #include "AliHLTTriggerMenu.h"
31 #include "AliHLTCTPData.h"
32 #include "AliCDBManager.h"
33 #include "AliCDBStorage.h"
34 #include "AliCDBEntry.h"
35 #include "AliRawDataHeader.h"
40 #include "TClonesArray.h"
41 #include "TObjString.h"
43 #include "TInterpreter.h"
54 ClassImp(AliHLTGlobalTriggerComponent)
56 const char* AliHLTGlobalTriggerComponent::fgkTriggerMenuCDBPath = "HLT/ConfigHLT/HLTGlobalTrigger";
62 * This method is used as a comparison functor with the STL sort routines.
64 bool AliHLTDescendingNumbers(UInt_t a, UInt_t b)
71 AliHLTGlobalTriggerComponent::AliHLTGlobalTriggerComponent() :
75 fRuntimeCompile(true),
76 fDeleteCodeFile(false),
77 fMakeSoftwareTriggers(true),
81 fBufferSizeConst(2*(sizeof(AliHLTGlobalTriggerDecision) + sizeof(AliHLTReadoutList))),
82 fBufferSizeMultiplier(1.),
83 fIncludePaths(TObjString::Class()),
84 fIncludeFiles(TObjString::Class()),
87 fDataEventsOnly(true),
90 fSoftwareTrigger(true, "SOFTWARE"),
91 fTotalEventCounter(0),
94 // Default constructor.
96 ClearInfoForNewEvent(false);
100 AliHLTGlobalTriggerComponent::~AliHLTGlobalTriggerComponent()
102 // Default destructor.
104 if (fTrigger != NULL) delete fTrigger;
107 fCTPDecisions->Delete();
108 delete fCTPDecisions;
113 void AliHLTGlobalTriggerComponent::GetOutputDataTypes(AliHLTComponentDataTypeList& list) const
115 // Returns the kAliHLTDataTypeGlobalTrigger type as output.
116 list.push_back(kAliHLTDataTypeGlobalTrigger);
120 void AliHLTGlobalTriggerComponent::GetOutputDataSize(unsigned long& constBase, double& inputMultiplier)
122 // Returns the output data size estimate.
124 constBase = fBufferSizeConst;
125 inputMultiplier = fBufferSizeMultiplier;
129 Int_t AliHLTGlobalTriggerComponent::DoInit(int argc, const char** argv)
131 // Initialises the global trigger component.
136 fDeleteCodeFile = false;
137 fMakeSoftwareTriggers = true;
138 const char* configFileName = NULL;
139 const char* codeFileName = NULL;
140 fIncludePaths.Clear();
141 fIncludeFiles.Clear();
142 SetBit(kIncludeInput);
143 fDataEventsOnly = true;
144 UInt_t randomSeed = 0;
145 bool randomSeedSet = false;
148 for (int i = 0; i < argc; i++)
150 if (strcmp(argv[i], "-config") == 0)
152 if (configFileName != NULL)
154 HLTWarning("Trigger configuration macro was already specified."
155 " Will replace previous value given by -config."
160 HLTError("The trigger configuration macro filename was not specified." );
163 configFileName = argv[i+1];
168 if (strcmp(argv[i], "-includepath") == 0)
172 HLTError("The include path was not specified." );
177 new (fIncludePaths[fIncludePaths.GetEntriesFast()]) TObjString(argv[i+1]);
179 catch (const std::bad_alloc&)
181 HLTError("Could not allocate more memory for the fIncludePaths array.");
188 if (strcmp(argv[i], "-include") == 0)
192 HLTError("The include file name was not specified." );
197 new (fIncludeFiles[fIncludeFiles.GetEntriesFast()]) TObjString(argv[i+1]);
199 catch (const std::bad_alloc&)
201 HLTError("Could not allocate more memory for the fIncludeFiles array.");
208 if (strcmp(argv[i], "-debug") == 0)
210 if (fDebugMode == true)
212 HLTWarning("The debug flag was already specified. Ignoring this instance.");
218 if (strcmp(argv[i], "-cint") == 0)
220 fRuntimeCompile = false;
224 if (strcmp(argv[i], "-usecode") == 0)
226 if (codeFileName != NULL)
228 HLTWarning("Custom trigger code file was already specified."
229 " Will replace previous value given by -usecode."
234 HLTError("The custom trigger code filename was not specified." );
237 codeFileName = argv[i+1];
240 HLTError("The custom trigger class name was not specified." );
243 fClassName = argv[i+2];
248 if (strcmp(argv[i], "-skipctp") == 0)
250 HLTInfo("Skipping CTP counters in trigger decision");
255 if (strcmp(argv[i], "-forward-input") == 0)
257 HLTInfo("Forwarding input objects and trigger decisions");
258 SetBit(kForwardInput);
259 SetBit(kIncludeShort);
260 SetBit(kIncludeInput, false);
264 if (strstr(argv[i], "-include-input") == argv[i])
266 SetBit(kForwardInput,false);
267 TString param=argv[i];
268 param.ReplaceAll("-include-input", "");
269 if (param.CompareTo("=none")==0)
271 HLTInfo("skipping objects and trigger decisions");
272 SetBit(kIncludeShort, false);
273 SetBit(kIncludeInput, false);
275 else if (param.CompareTo("=short")==0)
277 HLTInfo("including short info on objects and trigger decisions");
278 SetBit(kIncludeShort);
279 SetBit(kIncludeInput, false);
281 else if (param.CompareTo("=both")==0)
283 HLTInfo("including input objects, trigger decisions and short info");
284 SetBit(kIncludeShort);
285 SetBit(kIncludeInput);
287 else if (param.CompareTo("=objects")==0 || param.IsNull())
289 HLTInfo("including input objects and trigger decisions");
290 SetBit(kIncludeShort, false);
291 SetBit(kIncludeInput);
295 HLTError("unknown parameter '%s' for argument '-include-input'", param.Data());
300 if (strcmp(argv[i], "-process-all-events") == 0)
302 fDataEventsOnly = false;
306 if (strstr(argv[i], "-monitoring") == argv[i])
308 TString param=argv[i];
309 param.ReplaceAll("-monitoring", "");
313 // enable monitoring trigger for all events
317 // enable monitoring trigger once every n seconds
318 param.ReplaceAll("=", "");
319 if (param.IsDigit()) {
320 fMonitorPeriod=param.Atoi();
322 HLTError("expecting number as parameter for argument '-monitoring=', got %s, skipping monitoring trigger", param.Data());
328 if (strcmp(argv[i], "-dont-make-software-triggers") == 0)
330 fMakeSoftwareTriggers = false;
333 if (strcmp(argv[i], "-randomseed") == 0)
337 HLTWarning("The random seed was already specified previously with the option -randomseed."
338 "Will replace the previous value of %d with the new one.",
344 HLTError("The number to use as the seed was not specified for the -randomseed option." );
347 TString numstr = argv[i+1];
348 if (not numstr.IsDigit())
350 HLTError("The number specified in the -randomseed option is not a valid decimal integer." );
353 randomSeed = numstr.Atoi();
354 randomSeedSet = true;
359 HLTError("Unknown option '%s'.", argv[i]);
363 const AliHLTTriggerMenu* menu = NULL;
364 if (configFileName != NULL)
367 cmd += configFileName;
368 gROOT->ProcessLine(cmd);
369 menu = AliHLTGlobalTriggerConfig::Menu();
372 // Try load the trigger menu from the CDB if it is not loaded yet with the
374 int result = -ENOENT;
377 result = LoadTriggerMenu(fgkTriggerMenuCDBPath, menu);
381 HLTError("No trigger menu configuration found or specified.");
385 if (codeFileName == NULL)
387 result = GenerateTrigger(menu, fClassName, fCodeFileName, fIncludePaths, fIncludeFiles);
388 if (result == 0) fDeleteCodeFile = true;
392 result = LoadTriggerClass(codeFileName, fIncludePaths);
393 if (result == 0) fCodeFileName = codeFileName;
395 if (result != 0) return result;
399 fTrigger = AliHLTGlobalTrigger::CreateNew(fClassName.Data());
401 catch (const std::bad_alloc&)
403 HLTError("Could not allocate memory for the AliHLTGlobalTrigger instance.");
406 if (fTrigger == NULL)
408 HLTError("Could not create a new instance of '%s'.", fClassName.Data());
412 fTrigger->FillFromMenu(*menu);
413 if (fTrigger->CallFailed()) return -EPROTO;
415 // setup the CTP accounting in AliHLTComponent
418 // Set the default values from the trigger menu.
419 SetDescription(menu->DefaultDescription());
420 SetTriggerDomain(menu->DefaultTriggerDomain());
422 // Initialise the random number generator seed value.
423 // NOTE: The GenerateTrigger method called above will set the fUniqueID value
424 // with a random value based on a GUID that should be unique across the system.
425 // This is then used as the seed to the random number generator if the -randomseed
426 // option is not used.
427 if (not randomSeedSet) randomSeed = fUniqueID;
428 gRandom->SetSeed(randomSeed);
430 fTotalEventCounter = 0;
435 Int_t AliHLTGlobalTriggerComponent::DoDeinit()
437 // Cleans up the global trigger component.
439 if (fTrigger != NULL)
446 fCTPDecisions->Delete();
447 delete fCTPDecisions;
452 Int_t result = UnloadTriggerClass(fCodeFileName);
453 if (result != 0) return result;
455 if (fDeleteCodeFile and !fCodeFileName.IsNull() && gSystem->AccessPathName(fCodeFileName)==0 && !fDebugMode) {
456 fCodeFileName.ReplaceAll(".cxx", "*");
457 TString command="rm "; command+=fCodeFileName;
458 gSystem->Exec(command);
461 fDeleteCodeFile=false;
467 AliHLTComponent* AliHLTGlobalTriggerComponent::Spawn()
469 // Creates a new object instance.
470 AliHLTComponent* comp = NULL;
473 comp = new AliHLTGlobalTriggerComponent;
475 catch (const std::bad_alloc&)
477 HLTError("Could not allocate memory for a new instance of AliHLTGlobalTriggerComponent.");
484 int AliHLTGlobalTriggerComponent::DoTrigger()
486 // This method will apply the global trigger decision.
488 if (fTrigger == NULL)
490 HLTFatal("Global trigger implementation object is NULL!");
494 AliHLTUInt32_t eventType=0;
495 if (!IsDataEvent(&eventType)) {
498 if (eventType == gkAliEventTypeEndOfRun) PrintStatistics(fTrigger, kHLTLogImportant);
499 IgnoreEvent(); // dont generate any trigger decision.
504 fCDH = NULL; // have to reset this in case ExtractTriggerData fails.
505 ExtractTriggerData(*GetTriggerData(), NULL, NULL, &fCDH, NULL);
507 // Copy the trigger counters in case we need to set them back to their original
508 // value because the PushBack method fails with ENOSPC.
509 TArrayL64 originalCounters = fTrigger->GetCounters();
510 if (fTrigger->CallFailed()) return -EPROTO;
512 fTrigger->NewEvent();
513 if (fTrigger->CallFailed()) return -EPROTO;
515 // Fill in the input data.
516 const TObject* obj = GetFirstInputObject();
519 fTrigger->Add(obj, GetDataType(), GetSpecification());
520 if (fTrigger->CallFailed()) return -EPROTO;
521 obj = GetNextInputObject();
524 // add trigger decisions for every CTP class
525 const AliHLTCTPData* pCTPData=CTPData();
527 AddCTPDecisions(fTrigger, pCTPData, GetTriggerData());
530 bool softwareTriggerIsValid = FillSoftwareTrigger();
531 if (softwareTriggerIsValid)
533 fTrigger->Add(&fSoftwareTrigger, kAliHLTDataTypeTriggerDecision, kAliHLTVoidDataSpec);
536 // Calculate the global trigger result and trigger domain, then create and push
537 // back the new global trigger decision object.
539 AliHLTTriggerDomain triggerDomain;
540 bool triggerResult = false;
541 bool matchedItems = fTrigger->CalculateTriggerDecision(triggerResult, triggerDomain, description);
542 if (fTrigger->CallFailed()) return -EPROTO;
543 AliHLTGlobalTriggerDecision decision(
545 // The following will cause the decision to be generated with default values
546 // (set in fTriggerDomain and fDescription) if the trigger result is false.
547 (matchedItems == true) ? triggerDomain : GetTriggerDomain(),
548 (matchedItems == true) ? description.Data() : GetDescription()
551 decision.SetUniqueID(fUniqueID);
552 decision.SetCounters(fTrigger->GetCounters(), fTotalEventCounter+1);
553 if (fTrigger->CallFailed()) return -EPROTO;
555 TClonesArray shortInfo(TNamed::Class(), GetNumberOfInputBlocks());
557 // Add the input objects used to make the global decision.
558 obj = GetFirstInputObject();
561 const AliHLTTriggerDecision* intrig = dynamic_cast<const AliHLTTriggerDecision*>(obj);
563 if (TestBit(kForwardInput)) Forward(obj);
565 if (TestBit(kIncludeInput))
569 decision.AddTriggerInput(*intrig);
573 // The const_cast should be safe in this case because the list of inputObjects
574 // will be added to the global decision with AddInputObjectRef, which only
575 // modifies the kCanDelete bit and nothing else.
576 // This is necessary since GetFirstInputObject only returns const objects.
577 decision.AddInputObjectRef( const_cast<TObject*>(obj) );
581 if (TestBit(kIncludeShort))
583 int entries = shortInfo.GetEntriesFast();
586 new (shortInfo[entries]) TNamed(obj->GetName(), obj->GetTitle());
588 catch (const std::bad_alloc&)
590 HLTError("Could not allocate more memory for the short list of input objects.");
595 shortInfo[entries]->SetBit(BIT(16)); // indicate that this is a trigger decision
596 shortInfo[entries]->SetBit(BIT(15), intrig->Result());
600 obj = GetNextInputObject();
602 if (TestBit(kIncludeShort)) decision.AddInputObjectRef(&shortInfo);
604 // The const_cast should be safe in this case because AddInputObjectRef just
605 // modifies the kCanDelete bit and nothing else.
606 if (!TestBit(kSkipCTP) && CTPData()) decision.AddInputObjectRef(const_cast<AliHLTCTPData*>(CTPData()));
608 if (softwareTriggerIsValid and TestBit(kIncludeInput)) decision.AddTriggerInput(fSoftwareTrigger);
610 static UInt_t lastTime=0;
612 if (time.Get()-lastTime>60)
615 PrintStatistics(fTrigger, kHLTLogImportant);
617 else if (eventType==gkAliEventTypeEndOfRun)
619 PrintStatistics(fTrigger, kHLTLogImportant);
622 // add readout filter to event done data
623 CreateEventDoneReadoutFilter(decision.TriggerDomain(), 3);
625 // add monitoring filter to event done data if enabled by setting
626 // a monitoring period >=0: -1 means off, 0 means for every event
627 // configured by argument '-monitoring[=n]'
628 if (fMonitorPeriod>=0) {
629 static UInt_t lastMonitorEvent=0;
631 AliHLTTriggerDomain monitoringFilter(decision.TriggerDomain());
632 if (decision.Result() &&
633 int(time.Get()-lastMonitorEvent)>fMonitorPeriod) {
634 lastMonitorEvent=time.Get();
635 // add monitoring event command for triggered events
636 CreateEventDoneReadoutFilter(decision.TriggerDomain(), 5);
638 // empty filter list if events are not triggered
639 // or within the monitoring interval
640 monitoringFilter.Clear();
642 // add monitoring filter list
643 CreateEventDoneReadoutFilter(monitoringFilter, 4);
646 // Mask the readout list according to the CTP trigger
647 // if the classes have been initialized (mask non-zero).
648 // If we are dealing with a software trigger on the other hand then
649 // mask with the participating detector list.
650 // In both cases we must make sure that HLT is part of the readout mask.
651 AliHLTReadoutList readoutlist = decision.ReadoutList();
652 AliHLTReadoutList readoutMask;
653 if (CTPData() != NULL and CTPData()->Mask() != 0x0)
655 readoutMask = CTPData()->ReadoutList(*GetTriggerData());
656 readoutMask.Enable(AliHLTReadoutList::kHLT);
658 else if (softwareTriggerIsValid)
660 assert(fCDH != NULL);
661 UInt_t detectors = fCDH->GetSubDetectors();
662 readoutMask = AliHLTReadoutList(Int_t(detectors | AliHLTReadoutList::kHLT));
664 readoutlist.AndEq(readoutMask);
665 decision.ReadoutList(readoutlist); // override the readout list with the masked one.
667 // Also check whether the final readout list equals a full readout of detectors
668 // irrespective of HLT.
669 // Calculate the difference between the input and output list (xor)
670 // and check if any bits are set (ignoring HLT).
671 AliHLTReadoutList::EDetectorId minDetector = ( readoutlist ^ readoutMask ).GetFirstUsedDetector();
672 // Create the readout list specification word:
673 // Bit 0: Original Data Present (bit 15 of CDH status & error bit to be set)
674 // Bit 1-31: Reserved for future use
675 AliHLTUInt32_t spec = 0x0;
676 if ( AliHLTReadoutList::kNoDetector == minDetector || AliHLTReadoutList::kHLT == minDetector ) // Any bits set after XOR?
678 spec |= (AliHLTUInt32_t) 0x1;
682 spec &= ~((AliHLTUInt32_t) 0x1);
684 SetReadoutListSpecBits(spec);
686 if (TriggerEvent(&decision, kAliHLTDataTypeGlobalTrigger) == -ENOSPC)
688 // Increase the estimated buffer space required if the PushBack methods in TriggerEvent
689 // returned the "no buffer space" error code. Also remember to set the trigger counters
690 // back to what they were, otherwise triggers will be double counted when we try to reprocess
691 // this event with larger buffers.
692 fBufferSizeConst += 1024*1024;
693 fBufferSizeMultiplier *= 2.;
694 fTrigger->SetCounters(originalCounters);
695 if (fTrigger->CallFailed()) return -EPROTO;
699 ++fTotalEventCounter;
704 int AliHLTGlobalTriggerComponent::Reconfigure(const char* cdbEntry, const char* chainId)
706 // Reconfigure the component by loading the trigger menu and recreating the
707 // trigger logic class.
709 const char* path = fgkTriggerMenuCDBPath;
710 const char* id = "(unknown)";
711 if (cdbEntry != NULL) path = cdbEntry;
712 if (chainId != NULL and chainId[0] != '\0') id = chainId;
713 HLTInfo("Reconfiguring from '%s' for chain component '%s'.", path, id);
715 const AliHLTTriggerMenu* menu = NULL;
716 int result = LoadTriggerMenu(path, menu);
717 if (result != 0) return result;
720 TString codeFileName;
721 result = GenerateTrigger(menu, className, codeFileName, fIncludePaths, fIncludeFiles);
722 if (result != 0) return result;
724 AliHLTGlobalTrigger* trigger = NULL;
727 trigger = AliHLTGlobalTrigger::CreateNew(className.Data());
729 catch (const std::bad_alloc&)
731 HLTError("Could not allocate memory for the AliHLTGlobalTrigger instance.");
736 HLTError("Could not create a new instance of '%s'.", className.Data());
737 // Make sure to cleanup after the new code file.
738 UnloadTriggerClass(codeFileName);
739 if (not codeFileName.IsNull() and gSystem->AccessPathName(codeFileName)==0 and not fDebugMode)
741 codeFileName.ReplaceAll(".cxx", "*");
742 TString command="rm "; command+=codeFileName;
743 gSystem->Exec(command);
748 if (fTrigger != NULL)
755 fTrigger->FillFromMenu(*menu);
756 if (fTrigger->CallFailed()) return -EPROTO;
758 // Set the default values from the trigger menu.
759 SetDescription(menu->DefaultDescription());
760 SetTriggerDomain(menu->DefaultTriggerDomain());
762 // Cleanup the old class code.
763 UnloadTriggerClass(fCodeFileName);
764 if (fDeleteCodeFile and not fCodeFileName.IsNull() and gSystem->AccessPathName(fCodeFileName)==0 and not fDebugMode)
766 fCodeFileName.ReplaceAll(".cxx", "*");
767 TString command="rm "; command+=fCodeFileName;
768 gSystem->Exec(command);
770 fCodeFileName = codeFileName;
771 fDeleteCodeFile = true; // Since we generated a new class.
777 int AliHLTGlobalTriggerComponent::LoadTriggerMenu(const char* cdbPath, const AliHLTTriggerMenu*& menu)
779 // Loads the trigger menu object from the CDB path.
781 HLTDebug("Trying to load trigger menu from '%s'.", cdbPath);
782 TObject* obj = LoadAndExtractOCDBObject(cdbPath);
785 HLTError("Configuration object for \"%s\" is missing.", cdbPath);
788 if (obj->IsA() != AliHLTTriggerMenu::Class())
790 HLTError("Wrong type for configuration object in \"%s\". Found a %s but we expect a AliHLTTriggerMenu.",
791 cdbPath, obj->ClassName()
795 menu = static_cast<AliHLTTriggerMenu*>(obj);
800 void AliHLTGlobalTriggerComponent::GenerateFileName(TString& name, TString& filename)
802 // Creates a unique file name for the generated code.
804 TUUID guid = GenerateGUID();
811 fUniqueID = bufAsInt[0];
812 TString guidstr = guid.AsString();
813 // Replace '-' with '_' in string.
814 for (int i = 0; i < guidstr.Length(); ++i)
816 if (guidstr[i] == '-') guidstr[i] = '_';
818 name = "AliHLTGlobalTriggerImpl_";
820 filename = name + ".cxx";
822 // For good measure, check that the file names are not used. If they are then regenerate.
823 fstream file(filename.Data(), ios_base::in);
827 GenerateFileName(name, filename);
832 int AliHLTGlobalTriggerComponent::GenerateTrigger(
833 const AliHLTTriggerMenu* menu, TString& name, TString& filename,
834 const TClonesArray& includePaths, const TClonesArray& includeFiles
837 // Generates the global trigger class that will implement the specified trigger menu.
838 // See header for more details.
840 GenerateFileName(name, filename);
841 HLTDebug("Generating custom HLT trigger class named %s, in file %s, using trigger menu %p.",
842 name.Data(), filename.Data(), ((void*)menu)
845 // Open a text file to write the code and generate the new class.
846 fstream code(filename.Data(), ios_base::out | ios_base::trunc);
849 HLTError("Could not open file '%s' for writing.", filename.Data());
853 TClonesArray symbols(AliHLTTriggerMenuSymbol::Class());
854 int result = BuildSymbolList(menu, symbols);
855 if (result != 0) return result;
857 code << "#if !defined(__CINT__) || defined(__MAKECINT__)" << endl;
858 code << "#include <cstring>" << endl;
859 code << "#include \"TClass.h\"" << endl;
860 code << "#include \"TString.h\"" << endl;
861 code << "#include \"TClonesArray.h\"" << endl;
862 code << "#include \"TRandom3.h\"" << endl;
863 code << "#include \"AliHLTLogging.h\"" << endl;
864 code << "#include \"AliHLTGlobalTrigger.h\"" << endl;
865 code << "#include \"AliHLTGlobalTriggerDecision.h\"" << endl;
866 code << "#include \"AliHLTDomainEntry.h\"" << endl;
867 code << "#include \"AliHLTTriggerDomain.h\"" << endl;
868 code << "#include \"AliHLTReadoutList.h\"" << endl;
869 code << "#include \"AliHLTTriggerMenu.h\"" << endl;
870 code << "#include \"AliHLTTriggerMenuItem.h\"" << endl;
871 code << "#include \"AliHLTTriggerMenuSymbol.h\"" << endl;
873 // Add any include files that were specified on the command line.
874 for (Int_t i = 0; i < includeFiles.GetEntriesFast(); i++)
876 TString file = static_cast<TObjString*>(includeFiles.UncheckedAt(i))->String();
877 code << "#include \"" << file.Data() << "\"" << endl;
882 code << "#else" << endl;
883 code << "const char* gFunctionName = \"???\";" << endl;
884 code << "#define HLTDebug(msg) if (CheckFilter(kHLTLogDebug) && CheckGroup(Class_Name())) SendMessage(kHLTLogDebug, Class_Name(), ::gFunctionName, __FILE__, __LINE__, msg)" << endl;
886 code << "#endif" << endl;
888 code << "class " << name << " :" << endl;
889 // Add appropriate #ifdef sections since we need to prevent inheritance from
890 // AliHLTGlobalTrigger. CINT does not seem to support multiple inheritance nor
891 // multiple levels of inheritance. Neither of the following schemes worked:
893 // 1) class AliHLTGlobalTrigger : public AliHLTLogging {};
894 // class AliHLTGlobalTriggerImpl_xyz : public AliHLTGlobalTrigger {};
896 // 2) class AliHLTGlobalTrigger {};
897 // class AliHLTGlobalTriggerImpl_xyz : public AliHLTGlobalTrigger, public AliHLTLogging {};
899 // Thus, we are forced to just inherit from AliHLTLogging when running in the CINT
900 // interpreter. But we anyway have to call the global trigger implementation class
901 // through the AliHLTGlobalTriggerWrapper so this is not such a problem.
902 code << "#if !defined(__CINT__) || defined(__MAKECINT__)" << endl;
903 code << " public AliHLTGlobalTrigger," << endl;
904 code << "#endif" << endl;
905 code << " public AliHLTLogging" << endl;
907 code << "public:" << endl;
909 // Generate constructor method.
910 code << " " << name << "() :" << endl;
911 code << "#if !defined(__CINT__) || defined(__MAKECINT__)" << endl;
912 code << " AliHLTGlobalTrigger()," << endl;
913 code << "#endif" << endl;
914 code << " AliHLTLogging()";
915 // Write the symbols in the trigger menu in the initialisation list.
916 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
919 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
920 code << " " << symbol->Name() << "()," << endl;
921 if (strcmp(symbol->ObjectClass(), "AliHLTTriggerDecision") == 0)
923 code << " " << symbol->Name() << "TriggerDomain()," << endl;
925 code << " " << symbol->Name() << "DomainEntry(kAliHLTAnyDataType)";
927 for (UInt_t i = 0; i < menu->NumberOfItems(); i++)
929 code << "," << endl << " fMenuItemDescription" << i << "()";
931 code << endl << " {" << endl;
934 code << "#ifdef __CINT__" << endl;
935 code << " gFunctionName = \"" << name.Data() <<"\";" << endl;
936 code << "#endif" << endl;
937 code << " SetLocalLoggingLevel(kHLTLogAll);" << endl;
938 code << " HLTDebug(Form(\"Creating new instance at %p.\", this));" << endl;
940 code << " }" << endl;
942 code << " virtual ~" << name << "() {" << endl;
945 code << "#ifdef __CINT__" << endl;
946 code << " gFunctionName = \"~" << name.Data() << "\";" << endl;
947 code << "#endif" << endl;
948 code << " HLTDebug(Form(\"Deleting instance at %p.\", this));" << endl;
950 code << " }" << endl;
952 // Generate the FillFromMenu method.
953 code << " virtual void FillFromMenu(const AliHLTTriggerMenu& menu) {" << endl;
956 code << "#ifdef __CINT__" << endl;
957 code << " gFunctionName = \"FillFromMenu\";" << endl;
958 code << "#endif" << endl;
959 code << " HLTDebug(Form(\"Filling description entries from trigger menu for global trigger %p.\", this));" << endl;
961 code << " fCounter.Set(menu.NumberOfItems());" << endl;
962 for (UInt_t i = 0; i < menu->NumberOfItems(); i++)
964 code << " fMenuItemDescription" << i << " = (menu.Item(" << i
965 << ") != NULL) ? menu.Item(" << i << ")->Description() : \"\";" << endl;
969 code << " HLTDebug(Form(\"Finished filling description entries from trigger menu.\"));" << endl;
970 code << " HLTDebug(Form(\"Filling domain entries from trigger menu symbols for global trigger %p.\", this));" << endl;
972 code << " for (Int_t i = 0; i < menu.SymbolArray().GetEntriesFast(); i++) {" << endl;
973 // 30 Oct 2009 - CINT sometimes evaluates the dynamic_cast incorrectly.
974 // Have to use the TClass system for extra protection.
975 code << " if (menu.SymbolArray().UncheckedAt(i) == NULL) continue;" << endl;
976 code << " if (menu.SymbolArray().UncheckedAt(i)->IsA() != AliHLTTriggerMenuSymbol::Class()) continue;" << endl;
977 code << " const AliHLTTriggerMenuSymbol* symbol = dynamic_cast<const"
978 " AliHLTTriggerMenuSymbol*>(menu.SymbolArray().UncheckedAt(i));" << endl;
979 code << " if (symbol == NULL) continue;" << endl;
980 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
982 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
983 code << " if (strcmp(symbol->RealName(), \"" << symbol->RealName() << "\") == 0) {" << endl;
986 code << " HLTDebug(Form(\"Assinging domain entry value corresponding with symbol '%s' to '%s'.\","
987 " symbol->RealName(), symbol->BlockType().AsString().Data()));" << endl;
989 code << " " << symbol->Name() << "DomainEntry = symbol->BlockType();" << endl;
990 code << " continue;" << endl;
991 code << " }" << endl;
993 code << " }" << endl;
994 // The following is an optimisation where symbols without any assignment operators
995 // are treated as constant and only initialised in FillFromMenu rather than reseting
996 // them in the NewEvent method.
997 // Note: we putting this initialisation into the constructor can lead to seg faults
998 // under CINT interpretation. Thus we must put it into the FillFromMenu method instead.
999 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
1001 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
1002 if (TString(symbol->AssignExpression()) != "") continue;
1003 if (strcmp(symbol->ObjectClass(), "AliHLTTriggerDecision") == 0) continue;
1004 // CINT has problems with the implicit equals operator for complex types, so if
1005 // the type has an equals operater we need to write the operator call explicitly.
1006 TClass* clas = TClass::GetClass(symbol->Type());
1007 if (clas != NULL and clas->GetMethodAny("operator=") != NULL)
1009 code << " " << symbol->Name() << ".operator = (" << symbol->DefaultValue() << ");" << endl;
1013 code << " " << symbol->Name() << " = " << symbol->DefaultValue() << ";" << endl;
1018 code << " HLTDebug(Form(\"Finished filling domain entries from trigger menu symbols.\"));" << endl;
1020 code << " }" << endl;
1022 // Generate the NewEvent method.
1023 code << " virtual void NewEvent() {" << endl;
1026 code << "#ifdef __CINT__" << endl;
1027 code << " gFunctionName = \"NewEvent\";" << endl;
1028 code << "#endif" << endl;
1029 code << " HLTDebug(Form(\"New event for global trigger object %p, initialising variables to default values.\", this));" << endl;
1031 // Write code to initialise the symbols in the trigger menu to their default values.
1032 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
1034 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
1035 // The following is an optimisation. If the symbol does not have an assignment expression
1036 // then it is effectively a constant symbol and can be initialised earlier and only once.
1037 // In this case we initialise it in the FillFromMenu method instead.
1038 if (TString(symbol->AssignExpression()) == "") continue;
1039 // CINT has problems with the implicit equals operator for complex types, so if
1040 // the type has an equals operater we need to write the operator call explicitly.
1041 TClass* clas = TClass::GetClass(symbol->Type());
1042 if (clas != NULL and clas->GetMethodAny("operator=") != NULL)
1044 code << " " << symbol->Name() << ".operator = (" << symbol->DefaultValue() << ");" << endl;
1048 code << " " << symbol->Name() << " = " << symbol->DefaultValue() << ";" << endl;
1050 if (strcmp(symbol->ObjectClass(), "AliHLTTriggerDecision") == 0)
1052 code << " " << symbol->Name() << "TriggerDomain.Clear();" << endl;
1057 code << " HLTDebug(Form(\"Finished initialising variables.\"));" << endl;
1059 code << " }" << endl;
1061 // Generate the Add method.
1062 bool haveAssignments = false;
1063 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
1065 // First check if we have any symbols with assignment expressions.
1066 // This is needed to get rid of the on the fly compilation warning about '_object_' not being used.
1067 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
1068 TString expr = symbol->AssignExpression();
1069 if (expr == "") continue; // Skip entries that have no assignment expression.
1070 haveAssignments = true;
1073 if (haveAssignments or fDebugMode)
1075 code << " virtual void Add(const TObject* _object_, const AliHLTComponentDataType& _type_, AliHLTUInt32_t _spec_) {" << endl;
1079 code << " virtual void Add(const TObject* /*_object_*/, const AliHLTComponentDataType& _type_, AliHLTUInt32_t _spec_) {" << endl;
1083 code << "#ifdef __CINT__" << endl;
1084 code << " gFunctionName = \"Add\";" << endl;
1085 code << "#endif" << endl;
1087 code << " AliHLTDomainEntry _type_spec_(_type_, _spec_);" << endl;
1090 code << " HLTDebug(Form(\"Adding TObject %p, with class name '%s' from data block"
1091 " '%s', to global trigger object %p\", _object_, _object_->ClassName(),"
1092 " _type_spec_.AsString().Data(), this));" << endl;
1093 code << " _object_->Print();" << endl;
1094 code << " bool _object_assigned_ = false;" << endl;
1096 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
1098 // Write code to check if the block type, specification and class name is correct.
1099 // Then write code to assign the variable from the input object.
1100 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
1101 TString expr = symbol->AssignExpression();
1102 if (expr == "") continue; // Skip entries that have no assignment expression.
1103 bool isTrigDecision = strcmp(symbol->ObjectClass(), "AliHLTTriggerDecision") == 0;
1108 code << " HLTDebug(Form(\"Trying to match input object to class '"
1109 << symbol->ObjectClass() << "', trigger name '" << symbol->RealName()
1110 << "' and block type '%s'\", " << symbol->Name()
1111 << "DomainEntry.AsString().Data()));" << endl;
1115 code << " HLTDebug(Form(\"Trying to match input object to class '"
1116 << symbol->ObjectClass() << "' and block type '%s'\", "
1117 << symbol->Name() << "DomainEntry.AsString().Data()));" << endl;
1120 // 30 Oct 2009 - CINT sometimes evaluates the dynamic_cast incorrectly.
1121 // Have to use the TClass system for extra protection.
1122 code << " const " << symbol->ObjectClass() << "* " << symbol->Name() << "_object_ = NULL;" << endl;
1123 code << " if (_object_->InheritsFrom(" << symbol->ObjectClass() << "::Class())) " << symbol->Name()
1124 << "_object_ = dynamic_cast<const " << symbol->ObjectClass()
1125 << "*>(_object_);" << endl;
1126 code << " if (" << symbol->Name() << "_object_ != NULL && ";
1129 code << "strcmp(" << symbol->Name() << "_object_->Name(), \""
1130 << symbol->RealName() << "\") == 0 && ";
1132 code << symbol->Name() << "DomainEntry == _type_spec_) {" << endl;
1133 TString fullname = symbol->Name();
1134 fullname += "_object_";
1135 expr.ReplaceAll("this", fullname);
1136 code << " this->" << symbol->Name() << " = " << expr.Data() << ";" << endl;
1139 code << " this->" << symbol->Name() << "TriggerDomain = "
1140 << fullname.Data() << "->TriggerDomain();" << endl;
1144 code << " HLTDebug(Form(\"Added TObject %p with class name '%s' to variable "
1145 << symbol->Name() << "\", _object_, _object_->ClassName()));" << endl;
1146 code << " _object_assigned_ = true;" << endl;
1148 code << " }" << endl;
1152 code << " if (! _object_assigned_) {" << endl;
1153 code << " HLTDebug(Form(\"Did not assign TObject %p"
1154 " with class name '%s' to any variable.\", _object_, _object_->ClassName()));"
1156 code << " }" << endl;
1158 code << " }" << endl;
1160 // Generate the CalculateTriggerDecision method.
1161 // This requires code to be generated that checks which items in the trigger menu
1162 // have their conditions asserted and then the trigger domain is generated from
1163 // those fired items.
1164 // The processing will start from the highest priority trigger group and stop
1165 // after at least one trigger from the current priority group being processed
1166 // is positive. For each priority group all the trigger menu items are checked.
1167 // Their combined trigger condition expression must be true for the trigger priority
1168 // group to be triggered positive. The full condition expression is formed by
1169 // concatenating the individual condition expressions. If no trailing operators are
1170 // used in the individual expressions then the default condition operator is placed
1171 // between two concatenated condition expressions.
1172 // If a trigger priority group has at least one trigger fired then the trigger domain
1173 // is calculated such that it will give the same result as the concatenated trigger
1174 // domain merging expressions for all the individual trigger menu items with
1175 // positive results. Again, if no trailing operators are used in the individual
1176 // merging expressions then the default domain operator is placed between two
1177 // expression fragments.
1178 code << " virtual bool CalculateTriggerDecision(bool& _trigger_result_, AliHLTTriggerDomain& _domain_, TString& _description_) {" << endl;
1181 code << "#ifdef __CINT__" << endl;
1182 code << " gFunctionName = \"CalculateTriggerDecision\";" << endl;
1183 code << "#endif" << endl;
1184 code << " HLTDebug(Form(\"Calculating global HLT trigger result with trigger object at %p.\", this));" << endl;
1187 // Build a list of priorities used in the trigger menu.
1188 std::vector<UInt_t> priorities;
1189 for (UInt_t i = 0; i < menu->NumberOfItems(); i++)
1191 const AliHLTTriggerMenuItem* item = menu->Item(i);
1192 bool priorityNotInList = std::find(priorities.begin(), priorities.end(), item->Priority()) == priorities.end();
1193 if (priorityNotInList) priorities.push_back(item->Priority());
1195 std::sort(priorities.begin(), priorities.end(), AliHLTDescendingNumbers);
1196 // From the priority list, build the priority groups in the correct order,
1197 // i.e. highest priority first.
1198 // The priority group is a list of vectors of integers. The integers are the
1199 // index numbers into the trigger menu item list for the items which form part
1200 // of the priority group.
1201 std::vector<std::vector<Int_t> > priorityGroup;
1202 priorityGroup.insert(priorityGroup.begin(), priorities.size(), std::vector<Int_t>());
1203 for (size_t n = 0; n < priorities.size(); n++)
1205 UInt_t priority = priorities[n];
1206 for (UInt_t i = 0; i < menu->NumberOfItems(); i++)
1208 const AliHLTTriggerMenuItem* item = menu->Item(i);
1209 if (item->Priority() == priority) priorityGroup[n].push_back(i);
1213 for (size_t n = 0; n < priorityGroup.size(); n++)
1217 code << " HLTDebug(Form(\"Processing trigger priority group " << priorities[n] << "\"));" << endl;
1220 if (n == 0) code << "UInt_t ";
1221 code << "_previous_match_ = 0xFFFFFFFF;" << endl;
1223 if (n == 0) code << "bool ";
1224 code << "_trigger_matched_ = false;" << endl;
1226 if (n == 0) code << "bool ";
1227 code << "_group_result_ = false;" << endl;
1228 std::vector<TString> conditionOperator;
1229 conditionOperator.insert(conditionOperator.begin(), priorityGroup[n].size(), TString(""));
1230 std::vector<TString> domainOperator;
1231 domainOperator.insert(domainOperator.begin(), priorityGroup[n].size(), TString(""));
1232 for (size_t m = 0; m < priorityGroup[n].size(); m++)
1234 UInt_t i = priorityGroup[n][m];
1235 const AliHLTTriggerMenuItem* item = menu->Item(i);
1236 TString triggerCondition = item->TriggerCondition();
1237 TString mergeExpr = item->MergeExpression();
1238 // Replace the symbols found in the trigger condition and merging expressions
1239 // with appropriate compilable versions.
1240 for (Int_t j = 0; j < symbols.GetEntriesFast(); j++)
1242 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(j) );
1243 bool symbolNamesDifferent = strcmp(symbol->RealName(), symbol->Name()) != 0;
1244 if (strcmp(symbol->ObjectClass(), "AliHLTTriggerDecision") == 0)
1246 TString newname = symbol->Name();
1247 newname += "TriggerDomain";
1248 mergeExpr.ReplaceAll(symbol->RealName(), newname);
1252 if (symbolNamesDifferent) mergeExpr.ReplaceAll(symbol->RealName(), symbol->Name());
1254 if (symbolNamesDifferent) triggerCondition.ReplaceAll(symbol->RealName(), symbol->Name());
1256 // We allow the trigger conditions and merging expressions to have trailing operators.
1257 // Thus, we need to extract the operators and cleanup the expressions so that they will
1258 // compile. This means that we silently ignore the trailing operator if not needed.
1259 if (ExtractedOperator(triggerCondition, conditionOperator[m]))
1261 // If the trailing operator is the same as the default operator then reset
1262 // the value in the operator list so that the default is used in the generated
1263 // code. This creates more compact code.
1264 if (conditionOperator[m] == menu->DefaultConditionOperator()) conditionOperator[m] = "";
1266 if (ExtractedOperator(mergeExpr, domainOperator[m]))
1268 if (domainOperator[m] == menu->DefaultDomainOperator()) domainOperator[m] = "";
1272 code << " HLTDebug(Form(\"Trying trigger condition " << i
1273 << " (Description = '%s').\", fMenuItemDescription" << i << ".Data()));"
1277 if (n == 0 and m == 0) code << "bool ";
1278 code << "_item_result_ = false;" << endl;
1279 code << " if (" << triggerCondition << ") {" << endl;
1280 code << " ++fCounter[" << i << "];" << endl;
1281 const char* indentation = "";
1282 // Generate the code to handle the prescalar and scale-down
1283 bool havePrescalar = item->PreScalar() != 0;
1284 bool haveScaledown = item->ScaleDown() < 1;
1285 if (havePrescalar or haveScaledown)
1289 if (havePrescalar) code << "(fCounter[" << i << "] % " << item->PreScalar() << ") == 1";
1290 if (havePrescalar and haveScaledown) code << " && ";
1293 std::streamsize oldprecision = code.precision(17);
1294 code << "gRandom->Rndm() < " << item->ScaleDown();
1295 code.precision(oldprecision);
1297 code << ") {" << endl;
1299 code << indentation << " _item_result_ = true;" << endl;
1302 code << indentation << " HLTDebug(Form(\"Matched trigger condition " << i
1303 << " (Description = '%s').\", fMenuItemDescription" << i << ".Data()));" << endl;
1305 if (havePrescalar or haveScaledown)
1307 code << " }" << endl;
1309 code << " }" << endl;
1312 // Since this is the first item of the trigger group,
1313 // the generated trigger logic can be simplified a little.
1314 code << " _group_result_ = _item_result_;" << endl;
1315 code << " if (_item_result_) {" << endl;
1316 code << " _domain_ = " << mergeExpr.Data() << ";" << endl;
1317 code << " _description_ = fMenuItemDescription" << i << ";" << endl;
1318 code << " _previous_match_ = " << i << ";" << endl;
1319 code << " _trigger_matched_ = true;" << endl;
1320 code << " }" << endl;
1324 if (conditionOperator[m-1] == "")
1326 code << " _group_result_ = _group_result_ "
1327 << menu->DefaultConditionOperator() << " _item_result_;" << endl;
1331 code << " _group_result_ = _group_result_ "
1332 << conditionOperator[m-1] << " _item_result_;" << endl;
1334 code << " if (_item_result_) {" << endl;
1335 code << " if (_trigger_matched_) {" << endl;
1336 bool switchWillBeEmpty = true;
1337 for (size_t k = 0; k < m; k++)
1339 if (domainOperator[k] == "") continue;
1340 switchWillBeEmpty = false;
1342 if (switchWillBeEmpty)
1344 code << " _domain_ = _domain_ " << menu->DefaultDomainOperator() << " "
1345 << mergeExpr.Data() << ";" << endl;
1349 code << " switch(_previous_match_) {" << endl;
1350 for (size_t k = 0; k < m; k++)
1352 if (domainOperator[k] == "") continue;
1353 code << " case " << k << ": _domain_ = _domain_ "
1354 << domainOperator[k] << " " << mergeExpr.Data() << "; break;" << endl;
1356 code << " default: _domain_ = _domain_ "
1357 << menu->DefaultDomainOperator() << " " << mergeExpr.Data() << ";" << endl;
1358 code << " }" << endl;
1360 code << " _description_ += \",\";" << endl;
1361 code << " _description_ += fMenuItemDescription" << i << ";" << endl;
1362 code << " } else {" << endl;
1363 code << " _domain_ = " << mergeExpr.Data() << ";" << endl;
1364 code << " _description_ = fMenuItemDescription" << i << ";" << endl;
1365 code << " }" << endl;
1366 code << " _previous_match_ = " << i << ";" << endl;
1367 code << " _trigger_matched_ = true;" << endl;
1368 code << " }" << endl;
1371 code << " if (_group_result_) {" << endl;
1374 if (n < priorities.size() - 1)
1376 code << " HLTDebug(Form(\"Matched triggers in trigger priority group " << priorities[n]
1377 << ". Stopping processing here because all other trigger groups have lower priority.\"));" << endl;
1381 code << " HLTDebug(Form(\"Matched triggers in trigger priority group " << priorities[n] << ".\"));" << endl;
1384 bool methodReturnResult = true;
1385 if (priorityGroup[n].size() > 0)
1387 const AliHLTTriggerMenuItem* item = menu->Item(priorityGroup[n][0]);
1388 methodReturnResult = item->DefaultResult();
1390 // Check to see if the items of the group all have the same default result.
1391 // If not then warn the user since only the first item's value will be used.
1392 for (size_t m = 1; m < priorityGroup[n].size(); m++)
1394 const AliHLTTriggerMenuItem* item = menu->Item(priorityGroup[n][m]);
1395 if (item->DefaultResult() != methodReturnResult)
1397 HLTWarning("Found items with different default results set for priority group %d."
1398 "Will only use the value from the first item.",
1404 code << " _trigger_result_ = " << (methodReturnResult ? "true" : "false") << ";" << endl;
1405 code << " return true;" << endl;
1406 code << " }" << endl;
1408 code << " _domain_.Clear();" << endl;
1409 code << " _description_ = \"\";" << endl;
1410 code << " _trigger_result_ = " << (menu->DefaultResult() ? "true" : "false") << ";" << endl;
1411 code << " return false;" << endl;
1412 code << " }" << endl;
1414 // Generate getter and setter methods for the counters.
1415 code << " const TArrayL64& GetCounters() const { return fCounter; }" << endl;
1416 code << " void SetCounters(const TArrayL64& counters) { fCounter = counters; }" << endl;
1418 code << "private:" << endl;
1419 // Add the symbols in the trigger menu to the list of private variables.
1420 for (Int_t i = 0; i < symbols.GetEntriesFast(); i++)
1422 AliHLTTriggerMenuSymbol* symbol = static_cast<AliHLTTriggerMenuSymbol*>( symbols.UncheckedAt(i) );
1423 code << " " << symbol->Type() << " " << symbol->Name() << ";" << endl;
1424 if (strcmp(symbol->ObjectClass(), "AliHLTTriggerDecision") == 0)
1426 code << " AliHLTTriggerDomain " << symbol->Name() << "TriggerDomain;" << endl;
1428 code << " AliHLTDomainEntry " << symbol->Name() << "DomainEntry;" << endl;
1430 for (UInt_t i = 0; i < menu->NumberOfItems(); i++)
1432 code << " TString fMenuItemDescription" << i << ";" << endl;
1434 code << " TArrayL64 fCounter;" << endl;
1435 code << "#if !defined(__CINT__) || defined(__MAKECINT__)" << endl;
1436 code << " ClassDef(" << name.Data() << ", 0)" << endl;
1437 code << "#else" << endl;
1438 code << " virtual const char* Class_Name() const { return \"" << name.Data() << "\"; }" << endl;
1439 code << "#endif" << endl;
1440 code << "};" << endl;
1441 code << "#if !defined(__CINT__) || defined(__MAKECINT__)" << endl;
1442 code << "ClassImp(" << name.Data() << ")" << endl;
1443 code << "#endif" << endl;
1447 // Now we need to compile and load the new class.
1448 result = LoadTriggerClass(filename, includePaths);
1453 int AliHLTGlobalTriggerComponent::LoadTriggerClass(
1454 const char* filename, const TClonesArray& includePaths
1457 // Loads the code for a custom global trigger class implementation on the fly.
1459 HLTDebug("Loading HLT trigger class from file '%s'.", filename);
1461 TString compiler = gSystem->GetBuildCompilerVersion();
1462 if (fRuntimeCompile && (compiler.Contains("gcc") or compiler.Contains("icc")))
1464 TString includePath;
1465 #if defined(PKGINCLUDEDIR)
1466 // this is especially for the HLT build system where the package is installed
1467 // in a specific directory including proper treatment of include files
1468 includePath.Form("-I%s", PKGINCLUDEDIR);
1470 // the default AliRoot behavior, all include files can be found in the
1471 // $ALICE_ROOT subfolders
1472 includePath = "-I${ALICE_ROOT}/include -I${ALICE_ROOT}/HLT/BASE -I${ALICE_ROOT}/HLT/trigger";
1474 // Add any include paths that were specified on the command line.
1475 for (Int_t i = 0; i < includePaths.GetEntriesFast(); i++)
1477 TString path = static_cast<TObjString*>(includePaths.UncheckedAt(i))->String();
1478 includePath += " -I";
1479 includePath += path;
1481 HLTDebug("using include settings: %s", includePath.Data());
1482 gSystem->SetIncludePath(includePath);
1483 gSystem->SetFlagsOpt("-O3 -DNDEBUG");
1484 gSystem->SetFlagsDebug("-g3 -DDEBUG -D__DEBUG");
1489 result = gSystem->CompileMacro(filename, "g");
1493 result = gSystem->CompileMacro(filename, "O");
1495 if (result != kTRUE)
1497 HLTFatal("Could not compile and load global trigger menu implementation.");
1503 // Store the library state to be checked later in UnloadTriggerClass.
1504 fLibStateAtLoad = gSystem->GetLibraries();
1506 // If we do not support the compiler then try interpret the class instead.
1507 TString cmd = ".L ";
1509 Int_t errorcode = TInterpreter::kNoError;
1510 gROOT->ProcessLine(cmd, &errorcode);
1511 if (errorcode != TInterpreter::kNoError)
1513 HLTFatal("Could not load interpreted global trigger menu implementation"
1514 " (Interpreter error code = %d).",
1525 int AliHLTGlobalTriggerComponent::UnloadTriggerClass(const char* filename)
1527 // Unloads the code previously loaded by LoadTriggerClass.
1529 HLTDebug("Unloading HLT trigger class in file '%s'.", filename);
1531 TString compiler = gSystem->GetBuildCompilerVersion();
1532 if (fRuntimeCompile && (compiler.Contains("gcc") or compiler.Contains("icc")))
1534 // Generate the library name.
1535 TString libname = filename;
1536 Ssiz_t dotpos = libname.Last('.');
1537 if (0 <= dotpos and dotpos < libname.Length()) libname[dotpos] = '_';
1539 libname += gSystem->GetSoExt();
1541 // This is a workaround for a problem with unloading shared libraries in ROOT.
1542 // If the trigger logic library is loaded before the libAliHLTHOMER.so library
1543 // or any other library is loaded afterwards, then during the gInterpreter->UnloadFile
1544 // call all the subsequent libraries get unloded. This means that any objects created
1545 // from classes implemented in the libAliHLTHOMER.so library will generate segfaults
1546 // since the executable code has been unloaded.
1547 // We need to check if there are any more libraries loaded after the class we
1548 // are unloading and in that case don't unload the class.
1549 TString libstring = gSystem->GetLibraries();
1550 TString token, lastlib;
1552 Int_t numOfLibs = 0, posOfLib = -1;
1553 while (libstring.Tokenize(token, from, " "))
1557 if (token.Contains(libname)) posOfLib = numOfLibs;
1559 if (numOfLibs != posOfLib)
1561 HLTWarning(Form("ROOT limitation! Cannot properly cleanup and unload the shared"
1562 " library '%s' since another library '%s' was loaded afterwards. Trying to"
1563 " unload this library will remove the others and lead to serious memory faults.",
1564 libname.Data(), lastlib.Data()
1571 if ((path = gSystem->DynamicPathName(libname)) != NULL)
1573 result = gInterpreter->UnloadFile(path);
1576 if (result != TInterpreter::kNoError) return -ENOENT;
1580 // This is again a workaround for the problem with unloading files in ROOT.
1581 // If the trigger logic class is loaded before the libAliHLTHOMER.so library
1582 // or any other library is loaded afterwards, then during the gInterpreter->UnloadFile
1583 // call all the subsequent libraries get unloded.
1584 // We need to check if the list of loaded libraries has changed since the last
1585 // call to LoadTriggerClass. If it has then don't unload the class.
1586 if (fLibStateAtLoad != gSystem->GetLibraries())
1588 TString libstring = gSystem->GetLibraries();
1591 while (libstring.Tokenize(token, from, " "))
1593 if (not fLibStateAtLoad.Contains(token)) break;
1595 HLTWarning(Form("ROOT limitation! Cannot properly cleanup and unload the file"
1596 " '%s' since another library '%s' was loaded afterwards. Trying to unload"
1597 " this file will remove the other library and lead to serious memory faults.",
1598 filename, token.Data()
1603 // If we did not compile the trigger logic then remove the interpreted class.
1604 TString cmd = ".U ";
1606 Int_t errorcode = TInterpreter::kNoError;
1607 gROOT->ProcessLine(cmd, &errorcode);
1608 if (errorcode != TInterpreter::kNoError)
1610 HLTFatal("Could not unload interpreted global trigger menu implementation"
1611 " (Interpreter error code = %d).",
1622 int AliHLTGlobalTriggerComponent::FindSymbol(const char* name, const TClonesArray& list)
1624 // Searches for the named symbol in the given list.
1625 // See header for more details.
1627 for (int i = 0; i < list.GetEntriesFast(); i++)
1629 const AliHLTTriggerMenuSymbol* symbol = dynamic_cast<const AliHLTTriggerMenuSymbol*>( list.UncheckedAt(i) );
1630 if (symbol == NULL) continue;
1631 if (strcmp(symbol->Name(), name) == 0) return i;
1640 * Helper routine to compare two trigger menu symbols to see if b is a subset of a.
1641 * \returns true if b is a subset of a or they are unrelated.
1643 bool AliHLTCheckForContainment(const AliHLTTriggerMenuSymbol* a, const AliHLTTriggerMenuSymbol* b)
1645 TString bstr = b->Name();
1646 return bstr.Contains(a->Name());
1649 } // end of namespace
1652 int AliHLTGlobalTriggerComponent::BuildSymbolList(const AliHLTTriggerMenu* menu, TClonesArray& list)
1654 // Builds the list of symbols to use in the custom global trigger menu
1655 // implementation class.
1656 // See header for more details.
1658 // Note: when we build the symbol list we must use the symbol name as returned
1659 // by the Name() method and not the RealName() method when using FindSymbol.
1660 // This is so that we avoid problems with the generated code not compiling
1661 // because names like "abc-xyz" and "abc_xyz" are synonymous.
1662 // Name() returns the converted C++ symbol name as used in the generated code.
1664 for (UInt_t i = 0; i < menu->NumberOfSymbols(); i++)
1666 const AliHLTTriggerMenuSymbol* symbol = menu->Symbol(i);
1667 if (FindSymbol(symbol->Name(), list) != -1)
1669 HLTError("Multiple symbols with the name '%s' defined in the trigger menu.", symbol->Name());
1674 new (list[list.GetEntriesFast()]) AliHLTTriggerMenuSymbol(*symbol);
1676 catch (const std::bad_alloc&)
1678 HLTError("Could not allocate more memory for the symbols list when adding a trigger menu symbol.");
1682 Int_t initialEntryCount = list.GetEntriesFast();
1684 // Note: the \\. must not be the first element in the character class, otherwise
1685 // it is interpreted as an "any character" dot symbol.
1686 TRegexp exp("[_a-zA-Z][-\\._a-zA-Z0-9]*");
1687 for (UInt_t i = 0; i < menu->NumberOfItems(); i++)
1689 const AliHLTTriggerMenuItem* item = menu->Item(i);
1690 TString str = item->TriggerCondition();
1695 Ssiz_t pos = exp.Index(str, &length, start);
1696 if (pos == kNPOS) break;
1699 // Check if there is a numerical character before the found
1700 // regular expression. If so, then the symbol is not a valid one
1701 // and should be skipped.
1704 bool notValid = false;
1707 case '0': case '1': case '2': case '3': case '4':
1708 case '5': case '6': case '7': case '8': case '9':
1715 if (notValid) continue;
1717 TString s = str(pos, length);
1719 if (s == "and" or s == "and_eq" or s == "bitand" or s == "bitor" or
1720 s == "compl" or s == "not" or s == "not_eq" or s == "or" or
1721 s == "or_eq" or s == "xor" or s == "xor_eq" or s == "true" or
1725 // Ignore iso646.h and other keywords.
1729 // We need to handle the special case where the symbol contains a dot.
1730 // In C++ this is a dereferencing operator. So we need to check if the
1731 // current symbol we are handling starts with the same string as any of
1732 // the existing symbols defined manually in the symbols table.
1733 // If we do find such a case then revert to treating the dot as an operator
1734 // rather than part of the symbol name. i.e. skip adding the automatic symbol.
1735 bool dereferencedSymbol = false;
1736 for (int j = 0; j < initialEntryCount; j++)
1738 const AliHLTTriggerMenuSymbol* symbol = dynamic_cast<const AliHLTTriggerMenuSymbol*>( list.UncheckedAt(j) );
1739 if (symbol == NULL) continue;
1740 TString symstr = symbol->Name();
1742 if (s.BeginsWith(symstr))
1744 dereferencedSymbol = true;
1748 if (dereferencedSymbol) continue;
1750 // Need to create the symbols first and check if its name is in the list
1751 // before actually adding it to the symbols list.
1752 AliHLTTriggerMenuSymbol newSymbol;
1753 newSymbol.Name(s.Data());
1754 newSymbol.Type("bool");
1755 newSymbol.ObjectClass("AliHLTTriggerDecision");
1756 newSymbol.AssignExpression("this->Result()");
1757 newSymbol.DefaultValue("false");
1758 if (FindSymbol(newSymbol.Name(), list) == -1)
1762 new (list[list.GetEntriesFast()]) AliHLTTriggerMenuSymbol(newSymbol);
1764 catch (const std::bad_alloc&)
1766 HLTError("Could not allocate more memory for the symbols list when adding a trigger name symbol.");
1771 while (start < str.Length());
1774 // This last part is necessary to make sure that symbols are replaced in the
1775 // trigger condition and domain merging expressions in a greedy manner.
1776 // I.e. we need to make sure that if one symbol's string representation is
1777 // contained inside another (string subset) that the longer symbol name is
1778 // always first in the symbols list.
1779 // This will work because the symbol table is traversed from first to last
1780 // element and TString::ReplaceAll is used to replace the substrings inside
1781 // the AliHLTGlobalTriggerComponent::GenerateTrigger method.
1782 std::vector<AliHLTTriggerMenuSymbol*> orderedList;
1783 for (Int_t i = 0; i < list.GetEntriesFast(); i++)
1785 orderedList.push_back( static_cast<AliHLTTriggerMenuSymbol*>(list.UncheckedAt(i)) );
1787 std::sort(orderedList.begin(), orderedList.end(), AliHLTCheckForContainment);
1788 //std::sort(orderedList.begin(), orderedList.end());
1789 // Now swap values around according to the orderedList.
1790 for (Int_t i = 0; i < list.GetEntriesFast(); i++)
1792 AliHLTTriggerMenuSymbol* target = static_cast<AliHLTTriggerMenuSymbol*>(list.UncheckedAt(i));
1793 AliHLTTriggerMenuSymbol tmp = *target;
1794 *target = *orderedList[i];
1795 *orderedList[i] = tmp;
1802 bool AliHLTGlobalTriggerComponent::ExtractedOperator(TString& expr, TString& op)
1804 // Extracts the trailing operator from the expression.
1807 // First skip the trailing whitespace.
1808 bool whitespace = true;
1809 for (i = expr.Length()-1; i >= 0 and whitespace; i--)
1813 case ' ': case '\t': case '\r': case '\n':
1820 if (i < 0 or whitespace) return false;
1822 // Now find the first whitespace character before the trailing symbol.
1823 bool nonwhitespace = true;
1824 for (; i >= 0 and nonwhitespace; i--)
1828 case ' ': case '\t': case '\r': case '\n':
1829 nonwhitespace = false;
1832 nonwhitespace = true;
1835 if (i < 0 or nonwhitespace) return false;
1837 // Extract the last symbols and check if it is a valid operator.
1840 if (s == "and" or s == "and_eq" or s == "bitand" or s == "bitor" or
1841 s == "compl" or s == "not" or s == "not_eq" or s == "or" or
1842 s == "or_eq" or s == "xor" or s == "xor_eq" or s == "&&" or
1843 s == "&=" or s == "&" or s == "|" or s == "~" or s == "!" or
1844 s == "!=" or s == "||" or s == "|=" or s == "^" or s == "^=" or
1845 s == "==" or s == "+" or s == "-" or s == "*" or s == "/" or
1846 s == "%" or s == ">" or s == "<" or s == ">=" or s == "<="
1858 bool AliHLTGlobalTriggerComponent::FillSoftwareTrigger()
1860 // Fills the fSoftwareTrigger structure.
1862 if (fCDH == NULL) return false;
1863 UChar_t l1msg = fCDH->GetL1TriggerMessage();
1864 if ((l1msg & 0x1) == 0x0) return false; // skip physics events.
1865 // From here on everything must be a software trigger.
1866 if (((l1msg >> 2) & 0xF) == 0xE)
1868 fSoftwareTrigger.Name("START_OF_DATA");
1869 fSoftwareTrigger.Description("Generated internal start of data trigger.");
1871 else if (((l1msg >> 2) & 0xF) == 0xF)
1873 fSoftwareTrigger.Name("END_OF_DATA");
1874 fSoftwareTrigger.Description("Generated internal end of data trigger.");
1876 else if (((l1msg >> 6) & 0x1) == 0x1)
1878 fSoftwareTrigger.Name("CALIBRATION");
1879 fSoftwareTrigger.Description("Generated internal calibration trigger.");
1883 fSoftwareTrigger.Name("SOFTWARE");
1884 fSoftwareTrigger.Description("Generated internal software trigger.");
1886 UInt_t detectors = fCDH->GetSubDetectors();
1887 fSoftwareTrigger.ReadoutList( AliHLTReadoutList(Int_t(detectors)) );
1892 int AliHLTGlobalTriggerComponent::PrintStatistics(const AliHLTGlobalTrigger* pTrigger, AliHLTComponentLogSeverity level, int offset) const
1894 // print some statistics
1895 int totalEvents=fTotalEventCounter+offset;
1896 const TArrayL64& counters = pTrigger->GetCounters();
1897 if (pTrigger->CallFailed()) return -EPROTO;
1898 for (int i = 0; i < counters.GetSize(); i++) {
1899 ULong64_t count = counters[i];
1901 if (totalEvents>0) ratio=100*(float)count/totalEvents;
1902 HLTLog(level, "Item %d: total events: %d - counted events: %llu (%.1f%%)", i, totalEvents, count, ratio);
1907 int AliHLTGlobalTriggerComponent::AddCTPDecisions(AliHLTGlobalTrigger* pTrigger, const AliHLTCTPData* pCTPData, const AliHLTComponentTriggerData* trigData)
1909 // add trigger decisions for the valid CTP classes
1910 if (!pCTPData || !pTrigger) return 0;
1912 AliHLTUInt64_t triggerMask=pCTPData->Mask();
1913 AliHLTUInt64_t bit0=0x1;
1914 if (!fCTPDecisions) {
1917 fCTPDecisions=new TClonesArray(AliHLTTriggerDecision::Class(), gkNCTPTriggerClasses);
1919 catch (const std::bad_alloc&)
1921 HLTError("Could not allocate memory for the CTP decisions array.");
1924 if (!fCTPDecisions) return -ENOMEM;
1928 fCTPDecisions->ExpandCreate(gkNCTPTriggerClasses);
1930 catch (const std::bad_alloc&)
1932 HLTError("Could not allocate more memory for the CTP decisions array.");
1935 for (int i=0; i<gkNCTPTriggerClasses; i++) {
1936 const char* name=pCTPData->Name(i);
1937 if (triggerMask&(bit0<<i) && name) {
1938 AliHLTTriggerDecision* pDecision=dynamic_cast<AliHLTTriggerDecision*>(fCTPDecisions->At(i));
1941 delete fCTPDecisions;
1945 pDecision->Name(name);
1950 for (int i=0; i<gkNCTPTriggerClasses; i++) {
1951 const char* name=pCTPData->Name(i);
1952 if ((triggerMask&(bit0<<i))==0 || name==NULL) continue;
1953 AliHLTTriggerDecision* pDecision=dynamic_cast<AliHLTTriggerDecision*>(fCTPDecisions->At(i));
1954 HLTDebug("updating CTP trigger decision %d %s (%p casted %p)", i, name, fCTPDecisions->At(i), pDecision);
1955 if (!pDecision) return -ENOENT;
1958 // 13 March 2010 - Optimisation:
1959 // Dont use the EvaluateCTPTriggerClass method, which uses slow TFormula objects.
1960 AliHLTUInt64_t triggers = 0;
1961 if (trigData) triggers = pCTPData->ActiveTriggers(*trigData);
1962 else triggers = pCTPData->Triggers();
1963 result = (triggers&((AliHLTUInt64_t)0x1<<i)) ? true : false;
1964 //if (trigData) result=pCTPData->EvaluateCTPTriggerClass(name, *trigData);
1965 //else result=pCTPData->EvaluateCTPTriggerClass(name);
1966 pDecision->Result(result);
1967 pDecision->TriggerDomain().Clear();
1968 if (trigData) pDecision->TriggerDomain().Add(pCTPData->ReadoutList(*trigData));
1969 else pDecision->TriggerDomain().Add(pCTPData->ReadoutList());
1971 pTrigger->Add(fCTPDecisions->At(i), kAliHLTDataTypeTriggerDecision, kAliHLTVoidDataSpec);
1972 if (pTrigger->CallFailed()) return -EPROTO;