HLT/BASE/AliHLTOUTHandlerChain.cxx

   1 // $Id$
   2
   3 //**************************************************************************
   4 //* This file is property of and copyright by the ALICE HLT Project        *
   5 //* ALICE Experiment at CERN, All rights reserved.                         *
   6 //*                                                                        *
   7 //* Primary Authors: Matthias Richter <Matthias.Richter@ift.uib.no>        *
   8 //*                  for The ALICE HLT Project.                            *
   9 //*                                                                        *
  10 //* Permission to use, copy, modify and distribute this software and its   *
  11 //* documentation strictly for non-commercial purposes is hereby granted   *
  12 //* without fee, provided that the above copyright notice appears in all   *
  13 //* copies and that both the copyright notice and this permission notice   *
  14 //* appear in the supporting documentation. The authors make no claims     *
  15 //* about the suitability of this software for any purpose. It is          *
  16 //* provided "as is" without express or implied warranty.                  *
  17 //**************************************************************************
  18
  19 /** @file   AliHLTOUTHandlerChain.cxx
  20     @author Matthias Richter
  21     @date   24.06.2008
  22     @brief  HLTOUT handler of type kChain.
  23 */
  24
  25 #include "AliHLTOUTHandlerChain.h"
  26 #include "AliHLTOUT.h"
  27 #include "AliHLTSystem.h"
  28 #include "AliHLTOUTTask.h"
  29 #include "TString.h"
  30 #include "TObjString.h"
  31 #include "TObjArray.h"
  32
  33 /** ROOT macro for the implementation of ROOT specific class methods */
  34 ClassImp(AliHLTOUTHandlerChain)
  35
  36 AliHLTOUTHandlerChain::AliHLTOUTHandlerChain(const char* arguments)
  37   :
  38   fChains(),
  39   fOptions(),
  40   fpSystem(NULL),
  41   fpTask(NULL)
  42 {
  43   // see header file for class documentation
  44   // or
  45   // refer to README to build package
  46   // or
  47   // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
  48   if (arguments) {
  49     TString args=arguments;
  50     TObjArray* pTokens=args.Tokenize(" ");
  51     if (pTokens) {
  52       int iEntries=pTokens->GetEntries();
  53       for (int i=0; i<iEntries; i++) {
  54         TString token=(((TObjString*)pTokens->At(i))->GetString());
  55         if (token.Contains("chains=")) {
  56           TString param=token.ReplaceAll("chains=", "");
  57           fChains=param.ReplaceAll(",", " ");
  58         } else {
  59           if (!fOptions.IsNull()) fOptions+=" ";
  60           fOptions+=token;
  61         }
  62       }
  63       delete pTokens;
  64     }
  65   }
  66 }
  67
  68 AliHLTOUTHandlerChain::~AliHLTOUTHandlerChain()
  69 {
  70   // see header file for class documentation
  71   if (fpSystem) {
  72     delete fpSystem;
  73   }
  74 }
  75
  76 int AliHLTOUTHandlerChain::ProcessData(AliHLTOUT* pData)
  77 {
  78   // see header file for class documentation
  79   if (!pData) return -EINVAL;
  80   int iResult=0;
  81
  82   if (CheckStatus(kHandlerError)) {
  83     HLTWarning("kChain handler '%s' in error state, skipping processing of associated HLTOUT blocks", fChains.Data());
  84     return -EPERM;
  85   }
  86
  87   if (!fpSystem && (iResult=InitSystem())<0) {
  88     return iResult;
  89   }
  90
  91   if (fpSystem->CheckStatus(AliHLTSystem::kError) || !fpTask) {
  92     HLTWarning("kChain handler '%s': system in error state, skipping processing of associated HLTOUT blocks", fChains.Data());
  93     return -EACCES;
  94   }
  95
  96   // run one event and do not stop the chain
  97   fpTask->Reset();
  98   {
  99     AliHLTOUT::AliHLTOUTGlobalInstanceGuard g(pData);
 100     if ((iResult=fpSystem->Run(1,0))>=0) {
 101       // sub-collection is going to be reset from the
 102       // parent HLTOUT collection
 103       AliHLTOUT* pSubCollection=dynamic_cast<AliHLTOUT*>(fpTask);
 104       pSubCollection->Init();
 105       pData->AddSubCollection(pSubCollection);
 106     } else {
 107       fpTask->Reset();
 108     }
 109   }
 110
 111   return iResult;
 112 }
 113
 114 int AliHLTOUTHandlerChain::CreateConfigurations(AliHLTConfigurationHandler* /*handler*/)
 115 {
 116   //default implementation, nothing to do
 117   return 0;
 118 }
 119
 120 int AliHLTOUTHandlerChain::InitSystem()
 121 {
 122   // see header file for class documentation
 123   int iResult=0;
 124   if (!fpSystem) {
 125     // init AliHLTSystem
 126     fpSystem = new AliHLTSystem(GetGlobalLoggingLevel());
 127     if (fpSystem) {
 128       if ((iResult=fpSystem->ScanOptions(fOptions.Data()))>=0) {
 129         // load configurations if not specified by external macro
 130         if (!fOptions.Contains("config="))
 131           iResult=CreateConfigurations(fpSystem->fpConfigurationHandler);
 132
 133         if (iResult>=0) {
 134           iResult=fpSystem->BuildTaskList(fChains.Data());
 135         }
 136
 137         // add AliHLTOUTTask on top of the configuartions in order to
 138         // collect the data
 139         fpTask=new AliHLTOUTTask(fChains.Data());
 140       }
 141     } else {
 142       iResult=-ENOMEM;
 143     }
 144     if (iResult>=0 && fpSystem && fpTask) {
 145       if (fpTask->GetConf() && fpTask->GetConf()->SourcesResolved()>=0) {
 146         iResult=fpSystem->InsertTask(fpTask);
 147       } else {
 148         HLTError("HLTOUT task (%s) sources not resolved", fpTask->GetName());
 149         iResult=-ENOENT;
 150       }
 151     }
 152     if (iResult<0 || !fpTask) {
 153       SetStatusFlag(kHandlerError);
 154       if (fpSystem) delete fpSystem; fpSystem=NULL;
 155       if (fpTask) delete fpTask; fpTask=NULL;
 156     }
 157   }
 158   return iResult;
 159 }