// $Id$
-/**************************************************************************
- * This file is property of and copyright by the ALICE HLT Project *
- * ALICE Experiment at CERN, All rights reserved. *
- * *
- * Primary Authors: Matthias Richter <Matthias.Richter@ift.uib.no> *
- * for The ALICE HLT Project. *
- * *
- * Permission to use, copy, modify and distribute this software and its *
- * documentation strictly for non-commercial purposes is hereby granted *
- * without fee, provided that the above copyright notice appears in all *
- * copies and that both the copyright notice and this permission notice *
- * appear in the supporting documentation. The authors make no claims *
- * about the suitability of this software for any purpose. It is *
- * provided "as is" without express or implied warranty. *
- **************************************************************************/
+//**************************************************************************
+//* This file is property of and copyright by the ALICE HLT Project *
+//* ALICE Experiment at CERN, All rights reserved. *
+//* *
+//* Primary Authors: Matthias Richter <Matthias.Richter@ift.uib.no> *
+//* for The ALICE HLT Project. *
+//* *
+//* Permission to use, copy, modify and distribute this software and its *
+//* documentation strictly for non-commercial purposes is hereby granted *
+//* without fee, provided that the above copyright notice appears in all *
+//* copies and that both the copyright notice and this permission notice *
+//* appear in the supporting documentation. The authors make no claims *
+//* about the suitability of this software for any purpose. It is *
+//* provided "as is" without express or implied warranty. *
+//**************************************************************************
/** @file AliHLTSimulation.cxx
@author Matthias Richter
#include <cassert>
#include <cerrno>
+#include "TObjArray.h"
+#include "TObjString.h"
#include "AliHLTSimulation.h"
#include "AliLog.h"
+#include "AliRun.h"
#include "AliRunLoader.h"
+#include "AliHeader.h"
+#include "AliTracker.h"
+#include "AliCDBManager.h"
+#include "AliCDBEntry.h"
+#include "AliCDBPath.h"
+#include "AliCDBId.h"
+#include "AliCDBMetaData.h"
#include "AliHLTSystem.h"
+#include "AliRawReaderFile.h"
+#include "AliRawReaderDate.h"
+#include "AliRawReaderRoot.h"
+#include "AliESDEvent.h"
+#include "AliHLTOUTComponent.h"
#if ALIHLTSIMULATION_LIBRARY_VERSION != LIBHLTSIM_VERSION
#error library version in header file and lib*.pkg do not match
AliHLTSimulation::AliHLTSimulation()
:
fOptions(),
- fpSystem(NULL)
+ fpSystem(NULL),
+ fpRawReader(NULL)
{
// see header file for class documentation
// or
delete fpSystem;
}
fpSystem=NULL;
+ if (fpRawReader) {
+ delete fpRawReader;
+ }
+ fpRawReader=NULL;
}
AliHLTSimulation* AliHLTSimulation::CreateInstance()
{
// init the simulation
fOptions=options;
+ TString sysOp;
if (!fpSystem) fpSystem=new AliHLTSystem;
if (!fpSystem) {
return -EFAULT;
}
- if (fpSystem->ScanOptions(options)<0) {
+ // scan options for specific entries
+ TObjArray* pTokens=fOptions.Tokenize(" ");
+ if (pTokens) {
+ int iEntries=pTokens->GetEntries();
+ for (int i=0; i<iEntries; i++) {
+ TString token=(((TObjString*)pTokens->At(i))->GetString());
+ if (token.Contains("rawfile=")) {
+ TString param=token.ReplaceAll("rawfile=", "");
+ if (param.EndsWith("/")) {
+ AliInfo(Form("creating AliRawReaderFile (%s)", param.Data()));
+ fpRawReader = new AliRawReaderFile(param);
+ } else if (param.EndsWith(".root")) {
+ AliInfo(Form("creating AliRawReaderRoot (%s)", param.Data()));
+ fpRawReader = new AliRawReaderRoot(param);
+ } else if (!param.IsNull()) {
+ AliInfo(Form("creating AliRawReaderDate (%s)", param.Data()));
+ fpRawReader = new AliRawReaderDate(param);
+ fpRawReader->SelectEvents(7);
+ }
+ if (fpRawReader) {
+ fpRawReader->RewindEvents();
+ int count=0;
+ for (; fpRawReader->NextEvent(); count++);
+ if (count!=pRunLoader->GetNumberOfEvents()) {
+ AliError(Form("mismatch in event count: runloader %d, rawreader %d; ignoring rawreader",
+ pRunLoader->GetNumberOfEvents(), count));
+ count=0;
+ }
+ if (count>0) {
+ fpRawReader->RewindEvents();
+ fpRawReader->NextEvent();
+ } else {
+ delete fpRawReader;
+ fpRawReader=NULL;
+ }
+ }
+ } else if (token.Contains("writerawfiles=")) {
+ if (!token.ReplaceAll("writerawfiles=", "").Contains("HLT")) {
+ AliHLTOUTComponent::ClearGlobalOption(AliHLTOUTComponent::kWriteRawFiles);
+ }
+ } else {
+ if (sysOp.Length()>0) sysOp+=" ";
+ sysOp+=token;
+ }
+ }
+ delete pTokens;
+ }
+
+ // init solenoid field
+ Bool_t bUniformField=kTRUE;
+ AliTracker::SetFieldMap(pRunLoader->GetAliRun()->Field(),bUniformField);
+ Double_t solenoidBz=AliTracker::GetBz();
+ AliCDBManager* man = AliCDBManager::Instance();
+ if (man && man->IsDefaultStorageSet())
+ {
+ const char* cdbSolenoidPath="HLT/ConfigHLT/SolenoidBz";
+ int runNo=pRunLoader->GetHeader()->GetRun();
+ TString cdbSolenoidParam;
+ cdbSolenoidParam.Form("-solenoidBz %f", solenoidBz);
+
+ // check if the entry is already there
+ AliCDBEntry *pEntry = man->Get(cdbSolenoidPath, runNo);
+ TObjString* pString=NULL;
+ if (pEntry) pString=dynamic_cast<TObjString*>(pEntry->GetObject());
+
+ if (!pEntry || !pString || pString->GetString().CompareTo(cdbSolenoidParam)!=0) {
+ TObjString obj(cdbSolenoidParam);
+ AliCDBPath cdbSolenoidEntry(cdbSolenoidPath);
+ AliCDBId cdbSolenoidId(cdbSolenoidEntry, runNo, runNo);
+ AliCDBMetaData cdbMetaData;
+ man->Put(&obj, cdbSolenoidId, &cdbMetaData);
+ }
+ }
+
+ // scan options
+ if (fpSystem->ScanOptions(sysOp.Data())<0) {
AliError("error setting options for HLT system");
return -EINVAL;
}
return -EINVAL;
}
- Int_t nEvents = pRunLoader->GetNumberOfEvents();
+ int nEvents = pRunLoader->GetNumberOfEvents();
int iResult=0;
if (fpSystem->CheckStatus(AliHLTSystem::kError)) {
AliError("HLT system in error state");
return -EFAULT;
}
- if ((iResult=fpSystem->Reconstruct(nEvents, pRunLoader, NULL))>=0) {
+
+ // Note: the rawreader is already placed at the first event
+ if ((iResult=fpSystem->Reconstruct(1, pRunLoader, fpRawReader))>=0) {
+ fpSystem->FillESD(0, pRunLoader, NULL);
+ for (int i=1; i<nEvents; i++) {
+ if (fpRawReader && !fpRawReader->NextEvent()) {
+ AliError("mismatch in event count, rawreader corrupted");
+ break;
+ }
+ fpSystem->Reconstruct(1, pRunLoader, fpRawReader);
+ fpSystem->FillESD(i, pRunLoader, NULL);
+ }
+ // send specific 'event' to execute the stop sequence
+ fpSystem->Reconstruct(0, NULL, NULL);
}
return iResult;
}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff