// $Id$
/**************************************************************************
- * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
+ * This file is property of and copyright by the ALICE HLT Project *
+ * ALICE Experiment at CERN, All rights reserved. *
* *
- * Authors: Matthias Richter <Matthias.Richter@ift.uib.no> *
- * Timm Steinbeck <timm@kip.uni-heidelberg.de> *
- * for The ALICE Off-line Project. *
+ * Primary Authors: Matthias Richter <Matthias.Richter@ift.uib.no> *
+ * Timm Steinbeck <timm@kip.uni-heidelberg.de> *
+ * 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 *
@date
@brief Base class implementation for HLT components. */
+// see header file for class documentation
+// or
+// refer to README to build package
+// or
+// visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+
#if __GNUC__>= 3
using namespace std;
#endif
#include "AliHLTComponentHandler.h"
#include "AliHLTMessage.h"
#include "TString.h"
+#include "TMath.h"
#include "TObjArray.h"
+#include "TObjectTable.h"
#include "TClass.h"
#include "TStopwatch.h"
+#include "AliHLTMemoryFile.h"
+#include "AliHLTMisc.h"
+#include <cassert>
/** ROOT macro for the implementation of ROOT specific class methods */
ClassImp(AliHLTComponent);
fOutputBufferSize(0),
fOutputBufferFilled(0),
fOutputBlocks(),
- fpStopwatches(new TObjArray(kSWTypeCount))
+ fpStopwatches(new TObjArray(kSWTypeCount)),
+ fMemFiles(),
+ fpRunDesc(NULL),
+ fpDDLList(NULL),
+ fCDBSetRunNoFunc(false),
+ fChainId()
{
// see header file for class documentation
// or
//SetLocalLoggingLevel(kHLTLogDefault);
}
-AliHLTComponent::AliHLTComponent(const AliHLTComponent&)
- :
- AliHLTLogging(),
- fEnvironment(),
- fCurrentEvent(0),
- fEventCount(-1),
- fFailedEvents(0),
- fCurrentEventData(),
- fpInputBlocks(NULL),
- fCurrentInputBlock(-1),
- fSearchDataType(kAliHLTVoidDataType),
- fClassName(),
- fpInputObjects(NULL),
- fpOutputBuffer(NULL),
- fOutputBufferSize(0),
- fOutputBufferFilled(0),
- fOutputBlocks(),
- fpStopwatches(NULL)
-{
- // see header file for class documentation
- HLTFatal("copy constructor untested");
-}
-
-AliHLTComponent& AliHLTComponent::operator=(const AliHLTComponent&)
-{
- // see header file for class documentation
- HLTFatal("assignment operator untested");
- return *this;
-}
-
AliHLTComponent::~AliHLTComponent()
{
// see header file for function documentation
CleanupInputObjects();
if (fpStopwatches!=NULL) delete fpStopwatches;
fpStopwatches=NULL;
+ AliHLTMemoryFilePList::iterator element=fMemFiles.begin();
+ while (element!=fMemFiles.end()) {
+ if (*element) {
+ if ((*element)->IsClosed()==0) {
+ HLTWarning("memory file has not been closed, possible data loss or incomplete buffer");
+ // close but do not flush as we dont know whether the buffer is still valid
+ (*element)->CloseMemoryFile(0);
+ }
+ delete *element;
+ *element=NULL;
+ }
+ element++;
+ }
}
AliHLTComponentHandler* AliHLTComponent::fgpComponentHandler=NULL;
// see header file for function documentation
int iResult=0;
iResult=DoDeinit();
+ if (fpRunDesc) {
+ HLTWarning("did not receive EOR for run %d", fpRunDesc->fRunNo);
+ AliHLTRunDesc* pRunDesc=fpRunDesc;
+ fpRunDesc=NULL;
+ delete pRunDesc;
+ }
+ fEventCount=0;
return iResult;
}
-int AliHLTComponent::DoInit( int argc, const char** argv )
+int AliHLTComponent::InitCDB(const char* cdbPath, AliHLTComponentHandler* pHandler)
{
// see header file for function documentation
- if (argc==0 && argv==NULL) {
- // this is currently just to get rid of the warning "unused parameter"
+ int iResult=0;
+ if (cdbPath, pHandler) {
+ // I have to think about separating the library handling from the
+ // component handler. Requiring the component hanlder here is not
+ // the cleanest solution.
+ // We presume the library already to be loaded
+ // find the symbol
+ AliHLTMiscInitCDB_t pFunc=(AliHLTMiscInitCDB_t)pHandler->FindSymbol(ALIHLTMISC_LIBRARY, ALIHLTMISC_INIT_CDB);
+ if (pFunc) {
+ if ((iResult=(*pFunc)(cdbPath))>=0) {
+ if (!(fCDBSetRunNoFunc=pHandler->FindSymbol(ALIHLTMISC_LIBRARY, ALIHLTMISC_SET_CDB_RUNNO))) {
+ Message(NULL, kHLTLogWarning, "AliHLTComponent::InitCDB", "init CDB",
+ "can not find function to set CDB run no");
+ }
+ }
+ } else {
+ Message(NULL, kHLTLogError, "AliHLTComponent::InitCDB", "init CDB",
+ "can not find initialization function");
+ iResult=-ENOSYS;
}
- fEventCount=0;
+ } else {
+ iResult=-EINVAL;
+ }
+ return iResult;
+}
+
+int AliHLTComponent::SetCDBRunNo(int runNo)
+{
+ // see header file for function documentation
+ if (!fCDBSetRunNoFunc) return 0;
+ return (*((AliHLTMiscSetCDBRunNo_t)fCDBSetRunNoFunc))(runNo);
+}
+
+int AliHLTComponent::DoInit( int /*argc*/, const char** /*argv*/)
+{
+ // default implementation, childs can overload
return 0;
}
int AliHLTComponent::DoDeinit()
{
- // see header file for function documentation
- fEventCount=0;
+ // default implementation, childs can overload
+ return 0;
+}
+
+int AliHLTComponent::Reconfigure(const char* /*cdbEntry*/, const char* /*chainId*/)
+{
+ // default implementation, childs can overload
+ return 0;
+}
+
+int AliHLTComponent::GetOutputDataTypes(AliHLTComponentDataTypeList& /*tgtList*/)
+{
+ // default implementation, childs can overload
+ HLTLogKeyword("dummy");
return 0;
}
strncat( output, type.fID, kAliHLTComponentDataTypefIDsize );
}
-string AliHLTComponent::DataType2Text( const AliHLTComponentDataType& type )
+string AliHLTComponent::DataType2Text( const AliHLTComponentDataType& type, int mode)
{
// see header file for function documentation
string out("");
-
+
+ if (mode==2) {
+ int i=0;
+ char tmp[8];
+ for (i=0; i<kAliHLTComponentDataTypefOriginSize; i++) {
+ sprintf(tmp, "'%d", type.fOrigin[i]);
+ out+=tmp;
+ }
+ out+="':'";
+ for (i=0; i<kAliHLTComponentDataTypefIDsize; i++) {
+ sprintf(tmp, "%d'", type.fID[i]);
+ out+=tmp;
+ }
+ return out;
+ }
+
+ if (mode==1) {
+ int i=0;
+ char tmp[8];
+ for (i=0; i<kAliHLTComponentDataTypefOriginSize; i++) {
+ unsigned char* puc=(unsigned char*)type.fOrigin;
+ if ((puc[i])<32)
+ sprintf(tmp, "'\\%x", type.fOrigin[i]);
+ else
+ sprintf(tmp, "'%c", type.fOrigin[i]);
+ out+=tmp;
+ }
+ out+="':'";
+ for (i=0; i<kAliHLTComponentDataTypefIDsize; i++) {
+ unsigned char* puc=(unsigned char*)type.fID;
+ if (puc[i]<32)
+ sprintf(tmp, "\\%x'", type.fID[i]);
+ else
+ sprintf(tmp, "%c'", type.fID[i]);
+ out+=tmp;
+ }
+ return out;
+ }
+
if (type==kAliHLTVoidDataType) {
out="VOID:VOID";
} else {
return NULL;
}
-int AliHLTComponent::MakeOutputDataBlockList( const vector<AliHLTComponentBlockData>& blocks, AliHLTUInt32_t* blockCount,
+int AliHLTComponent::MakeOutputDataBlockList( const AliHLTComponentBlockDataList& blocks, AliHLTUInt32_t* blockCount,
AliHLTComponentBlockData** outputBlocks )
{
// see header file for function documentation
return -ENOSYS;
}
-int AliHLTComponent::FindMatchingDataTypes(AliHLTComponent* pConsumer, vector<AliHLTComponentDataType>* tgtList)
+int AliHLTComponent::FindMatchingDataTypes(AliHLTComponent* pConsumer, AliHLTComponentDataTypeList* tgtList)
{
// see header file for function documentation
int iResult=0;
if (pConsumer) {
- vector<AliHLTComponentDataType> ctlist;
- ((AliHLTComponent*)pConsumer)->GetInputDataTypes(ctlist);
- vector<AliHLTComponentDataType>::iterator type=ctlist.begin();
- //AliHLTComponentDataType ouptdt=GetOutputDataType();
- //PrintDataTypeContent(ouptdt, "publisher \'%s\'");
- while (type!=ctlist.end() && iResult==0) {
- //PrintDataTypeContent((*type), "consumer \'%s\'");
- if ((*type)==GetOutputDataType() ||
- (*type)==kAliHLTAnyDataType) {
- if (tgtList) tgtList->push_back(*type);
+ AliHLTComponentDataTypeList itypes;
+ AliHLTComponentDataTypeList otypes;
+ otypes.push_back(GetOutputDataType());
+ if (otypes[0]==kAliHLTMultipleDataType) {
+ otypes.clear();
+ int count=0;
+ if ((count=GetOutputDataTypes(otypes))>0) {
+ } else if (GetComponentType()!=kSink) {
+ HLTWarning("component %s indicates multiple output data types but GetOutputDataTypes returns %d", GetComponentID(), count);
+ }
+ }
+ ((AliHLTComponent*)pConsumer)->GetInputDataTypes(itypes);
+ AliHLTComponentDataTypeList::iterator itype=itypes.begin();
+ while (itype!=itypes.end()) {
+ //PrintDataTypeContent((*itype), "consumer \'%s\'");
+ AliHLTComponentDataTypeList::iterator otype=otypes.begin();
+ while (otype!=otypes.end() && (*itype)!=(*otype)) otype++;
+ //if (otype!=otypes.end()) PrintDataTypeContent(*otype, "publisher \'%s\'");
+ if (otype!=otypes.end() ||
+ (*itype)==kAliHLTAnyDataType) {
+ if (tgtList) tgtList->push_back(*itype);
iResult++;
- // this loop has to be changed in case of multiple output types
- break;
}
- type++;
+ itype++;
}
} else {
iResult=-EINVAL;
dt.fOrigin[3]);
}
-void AliHLTComponent::FillBlockData( AliHLTComponentBlockData& blockData ) const
+void AliHLTComponent::FillBlockData( AliHLTComponentBlockData& blockData )
{
// see header file for function documentation
blockData.fStructSize = sizeof(blockData);
blockData.fSpecification = kAliHLTVoidDataSpec;
}
-void AliHLTComponent::FillShmData( AliHLTComponentShmData& shmData ) const
+void AliHLTComponent::FillShmData( AliHLTComponentShmData& shmData )
{
// see header file for function documentation
shmData.fStructSize = sizeof(shmData);
shmData.fShmID = gkAliHLTComponentInvalidShmID;
}
-void AliHLTComponent::FillDataType( AliHLTComponentDataType& dataType ) const
+void AliHLTComponent::FillDataType( AliHLTComponentDataType& dataType )
{
// see header file for function documentation
dataType=kAliHLTAnyDataType;
void AliHLTComponent::SetDataType(AliHLTComponentDataType& tgtdt, const char* id, const char* origin)
{
// see header file for function documentation
- tgtdt.fStructSize = sizeof(AliHLTComponentDataType);
- memset(&tgtdt.fID[0], 0, kAliHLTComponentDataTypefIDsize);
- memset(&tgtdt.fOrigin[0], 0, kAliHLTComponentDataTypefOriginSize);
-
- if ((int)strlen(id)>kAliHLTComponentDataTypefIDsize) {
- HLTWarning("data type id %s is too long, truncated to %d", id, kAliHLTComponentDataTypefIDsize);
+ tgtdt.fStructSize=sizeof(AliHLTComponentDataType);
+ if (id) {
+ memset(&tgtdt.fID[0], 0, kAliHLTComponentDataTypefIDsize);
+ strncpy(&tgtdt.fID[0], id, strlen(id)<(size_t)kAliHLTComponentDataTypefIDsize?strlen(id):kAliHLTComponentDataTypefIDsize);
}
- strncpy(&tgtdt.fID[0], id, kAliHLTComponentDataTypefIDsize);
-
- if ((int)strlen(origin)>kAliHLTComponentDataTypefOriginSize) {
- HLTWarning("data type origin %s is too long, truncated to %d", origin, kAliHLTComponentDataTypefOriginSize);
+ if (origin) {
+ memset(&tgtdt.fOrigin[0], 0, kAliHLTComponentDataTypefOriginSize);
+ strncpy(&tgtdt.fOrigin[0], origin, strlen(origin)<(size_t)kAliHLTComponentDataTypefOriginSize?strlen(origin):kAliHLTComponentDataTypefOriginSize);
}
- strncpy(&tgtdt.fOrigin[0], origin, kAliHLTComponentDataTypefOriginSize);
}
void AliHLTComponent::FillEventData(AliHLTComponentEventData& evtData)
if (classname) fClassName=classname;
else fClassName.clear();
int idx=FindInputBlock(fSearchDataType, 0, 1);
- HLTDebug("found block %d when searching for data type %s", idx, DataType2Text(dt).c_str());
TObject* pObj=NULL;
if (idx>=0) {
+ HLTDebug("found block %d when searching for data type %s", idx, DataType2Text(dt).c_str());
if ((pObj=GetInputObject(idx, fClassName.c_str(), bForce))!=NULL) {
fCurrentInputBlock=idx;
} else {
AliHLTUInt32_t firstWord=*((AliHLTUInt32_t*)fpInputBlocks[idx].fPtr);
if (firstWord!=fpInputBlocks[idx].fSize-sizeof(AliHLTUInt32_t)) continue;
}
- if (dt == kAliHLTAnyDataType || fpInputBlocks[idx].fDataType == dt) {
+ if (dt == kAliHLTAnyDataType || fpInputBlocks[idx].fDataType == dt ||
+ (memcmp(dt.fID, kAliHLTAnyDataTypeID, kAliHLTComponentDataTypefIDsize)==0 &&
+ memcmp(dt.fOrigin, fpInputBlocks[idx].fDataType.fOrigin, kAliHLTComponentDataTypefOriginSize)==0) ||
+ (memcmp(dt.fID, fpInputBlocks[idx].fDataType.fID, kAliHLTComponentDataTypefIDsize)==0) &&
+ memcmp(dt.fOrigin, kAliHLTDataOriginAny, kAliHLTComponentDataTypefOriginSize)==0) {
iResult=idx;
}
}
return pObj;
}
-TObject* AliHLTComponent::GetInputObject(int idx, const char* classname, int bForce)
+TObject* AliHLTComponent::GetInputObject(int idx, const char* /*classname*/, int bForce)
{
// see header file for function documentation
if (fpInputObjects==NULL) {
fpInputObjects=NULL;
for (int i=0; i<array->GetEntries(); i++) {
TObject* pObj=array->At(i);
- if (pObj) delete pObj;
+ // grrr, garbage collection strikes back: When read via AliHLTMessage
+ // (CreateInputObject), and written to a TFile afterwards, the
+ // TFile::Close calls ROOOT's garbage collection. No clue why the
+ // object ended up in the key list and needs to be deleted
+ if (pObj && gObjectTable->PtrIsValid(pObj)) delete pObj;
}
delete array;
return 0;
return iSpec;
}
+int AliHLTComponent::Forward(const TObject* pObject)
+{
+ // see header file for function documentation
+ int iResult=0;
+ int idx=fCurrentInputBlock;
+ if (pObject) {
+ if (fpInputObjects==NULL || (idx=fpInputObjects->IndexOf(pObject))>=0) {
+ } else {
+ HLTError("unknown object %p", pObject);
+ iResult=-ENOENT;
+ }
+ }
+ if (idx>=0) {
+ fOutputBlocks.push_back(fpInputBlocks[idx]);
+ }
+ return iResult;
+}
+
+int AliHLTComponent::Forward(const AliHLTComponentBlockData* pBlock)
+{
+ // see header file for function documentation
+ int iResult=0;
+ int idx=fCurrentInputBlock;
+ if (pBlock) {
+ if (fpInputObjects==NULL || (idx=FindInputBlock(pBlock))>=0) {
+ } else {
+ HLTError("unknown Block %p", pBlock);
+ iResult=-ENOENT;
+ }
+ }
+ if (idx>=0) {
+ // check for fpInputBlocks pointer done in FindInputBlock
+ fOutputBlocks.push_back(fpInputBlocks[idx]);
+ }
+ return iResult;
+}
+
const AliHLTComponentBlockData* AliHLTComponent::GetFirstInputBlock(const AliHLTComponentDataType& dt)
{
// see header file for function documentation
return GetFirstInputBlock(dt);
}
+const AliHLTComponentBlockData* AliHLTComponent::GetInputBlock(int index)
+{
+ // see header file for function documentation
+ ALIHLTCOMPONENT_BASE_STOPWATCH();
+ assert( 0 <= index and index < fCurrentEventData.fBlockCnt );
+ return &fpInputBlocks[index];
+}
+
const AliHLTComponentBlockData* AliHLTComponent::GetNextInputBlock()
{
// see header file for function documentation
return iSpec;
}
-int AliHLTComponent::PushBack(TObject* pObject, const AliHLTComponentDataType& dt, AliHLTUInt32_t spec)
+int AliHLTComponent::PushBack(TObject* pObject, const AliHLTComponentDataType& dt, AliHLTUInt32_t spec,
+ void* pHeader, int headerSize)
{
// see header file for function documentation
ALIHLTCOMPONENT_BASE_STOPWATCH();
Int_t iMsgLength=msg.Length();
if (iMsgLength>0) {
msg.SetLength(); // sets the length to the first (reserved) word
- iResult=InsertOutputBlock(msg.Buffer(), iMsgLength, dt, spec);
+ iResult=InsertOutputBlock(msg.Buffer(), iMsgLength, dt, spec, pHeader, headerSize);
if (iResult>=0) {
HLTDebug("object %s (%p) size %d inserted to output", pObject->ClassName(), pObject, iMsgLength);
}
return iResult;
}
-int AliHLTComponent::PushBack(TObject* pObject, const char* dtID, const char* dtOrigin, AliHLTUInt32_t spec)
+int AliHLTComponent::PushBack(TObject* pObject, const char* dtID, const char* dtOrigin, AliHLTUInt32_t spec,
+ void* pHeader, int headerSize)
{
// see header file for function documentation
ALIHLTCOMPONENT_BASE_STOPWATCH();
AliHLTComponentDataType dt;
SetDataType(dt, dtID, dtOrigin);
- return PushBack(pObject, dt, spec);
+ return PushBack(pObject, dt, spec, pHeader, headerSize);
}
-int AliHLTComponent::PushBack(void* pBuffer, int iSize, const AliHLTComponentDataType& dt, AliHLTUInt32_t spec)
+int AliHLTComponent::PushBack(void* pBuffer, int iSize, const AliHLTComponentDataType& dt, AliHLTUInt32_t spec,
+ void* pHeader, int headerSize)
{
// see header file for function documentation
ALIHLTCOMPONENT_BASE_STOPWATCH();
- return InsertOutputBlock(pBuffer, iSize, dt, spec);
+ return InsertOutputBlock(pBuffer, iSize, dt, spec, pHeader, headerSize);
}
-int AliHLTComponent::PushBack(void* pBuffer, int iSize, const char* dtID, const char* dtOrigin, AliHLTUInt32_t spec)
+int AliHLTComponent::PushBack(void* pBuffer, int iSize, const char* dtID, const char* dtOrigin, AliHLTUInt32_t spec,
+ void* pHeader, int headerSize)
{
// see header file for function documentation
ALIHLTCOMPONENT_BASE_STOPWATCH();
AliHLTComponentDataType dt;
SetDataType(dt, dtID, dtOrigin);
- return PushBack(pBuffer, iSize, dt, spec);
+ return PushBack(pBuffer, iSize, dt, spec, pHeader, headerSize);
}
-int AliHLTComponent::InsertOutputBlock(void* pBuffer, int iSize, const AliHLTComponentDataType& dt, AliHLTUInt32_t spec)
+int AliHLTComponent::InsertOutputBlock(void* pBuffer, int iBufferSize, const AliHLTComponentDataType& dt, AliHLTUInt32_t spec,
+ void* pHeader, int iHeaderSize)
{
// see header file for function documentation
int iResult=0;
+ int iBlkSize = iBufferSize + iHeaderSize;
if (pBuffer) {
- if (fpOutputBuffer && iSize<=(int)(fOutputBufferSize-fOutputBufferFilled)) {
+ if (fpOutputBuffer && iBlkSize<=(int)(fOutputBufferSize-fOutputBufferFilled)) {
AliHLTUInt8_t* pTgt=fpOutputBuffer+fOutputBufferFilled;
AliHLTComponentBlockData bd;
FillBlockData( bd );
bd.fOffset = fOutputBufferFilled;
- bd.fPtr = pTgt;
- bd.fSize = iSize;
+ bd.fSize = iBlkSize;
bd.fDataType = dt;
bd.fSpecification = spec;
+ if (pHeader!=NULL && pHeader!=pTgt) {
+ memcpy(pTgt, pHeader, iHeaderSize);
+ }
+
+ pTgt += (AliHLTUInt8_t) iHeaderSize;
+
if (pBuffer!=NULL && pBuffer!=pTgt) {
- memcpy(pTgt, pBuffer, iSize);
+ memcpy(pTgt, pBuffer, iBufferSize);
+
//AliHLTUInt32_t firstWord=*((AliHLTUInt32_t*)pBuffer);
- //HLTDebug("copy %d bytes from %p to output buffer %p, first word %#x", iSize, pBuffer, pTgt, firstWord);
+ //HLTDebug("copy %d bytes from %p to output buffer %p, first word %#x", iBufferSize, pBuffer, pTgt, firstWord);
}
fOutputBufferFilled+=bd.fSize;
fOutputBlocks.push_back( bd );
- //HLTDebug("buffer inserted to output: size %d data type %s spec %#x", iSize, DataType2Text(dt).c_str(), spec);
+ //HLTDebug("buffer inserted to output: size %d data type %s spec %#x", iBlkSize, DataType2Text(dt).c_str(), spec);
} else {
if (fpOutputBuffer) {
- HLTError("too little space in output buffer: %d, required %d", fOutputBufferSize-fOutputBufferFilled, iSize);
+ HLTError("too little space in output buffer: %d, required %d", fOutputBufferSize-fOutputBufferFilled, iBlkSize);
} else {
HLTError("output buffer not available");
}
return msg.Length();
}
-int AliHLTComponent::CreateEventDoneData(AliHLTComponentEventDoneData edd)
+AliHLTMemoryFile* AliHLTComponent::CreateMemoryFile(int capacity, const char* dtID,
+ const char* dtOrigin,
+ AliHLTUInt32_t spec)
+{
+ // see header file for function documentation
+ ALIHLTCOMPONENT_BASE_STOPWATCH();
+ AliHLTComponentDataType dt;
+ SetDataType(dt, dtID, dtOrigin);
+ return CreateMemoryFile(capacity, dt, spec);
+}
+
+AliHLTMemoryFile* AliHLTComponent::CreateMemoryFile(int capacity,
+ const AliHLTComponentDataType& dt,
+ AliHLTUInt32_t spec)
+{
+ // see header file for function documentation
+ ALIHLTCOMPONENT_BASE_STOPWATCH();
+ AliHLTMemoryFile* pFile=NULL;
+ if (capacity>=0 && static_cast<unsigned int>(capacity)<=fOutputBufferSize-fOutputBufferFilled){
+ AliHLTUInt8_t* pTgt=fpOutputBuffer+fOutputBufferFilled;
+ pFile=new AliHLTMemoryFile((char*)pTgt, capacity);
+ if (pFile) {
+ unsigned int nofBlocks=fOutputBlocks.size();
+ if (nofBlocks+1>fMemFiles.size()) {
+ fMemFiles.resize(nofBlocks+1, NULL);
+ }
+ if (nofBlocks<fMemFiles.size()) {
+ fMemFiles[nofBlocks]=pFile;
+ AliHLTComponentBlockData bd;
+ FillBlockData( bd );
+ bd.fOffset = fOutputBufferFilled;
+ bd.fSize = capacity;
+ bd.fDataType = dt;
+ bd.fSpecification = spec;
+ fOutputBufferFilled+=bd.fSize;
+ fOutputBlocks.push_back( bd );
+ } else {
+ HLTError("can not allocate/grow object array");
+ pFile->CloseMemoryFile(0);
+ delete pFile;
+ pFile=NULL;
+ }
+ }
+ } else {
+ HLTError("can not create memory file of size %d (%d available)", capacity, fOutputBufferSize-fOutputBufferFilled);
+ }
+ return pFile;
+}
+
+AliHLTMemoryFile* AliHLTComponent::CreateMemoryFile(const char* dtID,
+ const char* dtOrigin,
+ AliHLTUInt32_t spec,
+ float capacity)
+{
+ // see header file for function documentation
+ ALIHLTCOMPONENT_BASE_STOPWATCH();
+ AliHLTComponentDataType dt;
+ SetDataType(dt, dtID, dtOrigin);
+ int size=fOutputBufferSize-fOutputBufferFilled;
+ if (capacity<0 || capacity>1.0) {
+ HLTError("invalid parameter: capacity %f", capacity);
+ return NULL;
+ }
+ size=(int)(size*capacity);
+ return CreateMemoryFile(size, dt, spec);
+}
+
+AliHLTMemoryFile* AliHLTComponent::CreateMemoryFile(const AliHLTComponentDataType& dt,
+ AliHLTUInt32_t spec,
+ float capacity)
+{
+ // see header file for function documentation
+ ALIHLTCOMPONENT_BASE_STOPWATCH();
+ int size=fOutputBufferSize-fOutputBufferFilled;
+ if (capacity<0 || capacity>1.0) {
+ HLTError("invalid parameter: capacity %f", capacity);
+ return NULL;
+ }
+ size=(int)(size*capacity);
+ return CreateMemoryFile(size, dt, spec);
+}
+
+int AliHLTComponent::Write(AliHLTMemoryFile* pFile, const TObject* pObject,
+ const char* key, int option)
+{
+ // see header file for function documentation
+ int iResult=0;
+ if (pFile && pObject) {
+ pFile->cd();
+ iResult=pObject->Write(key, option);
+ if (iResult>0) {
+ // success
+ } else {
+ iResult=-pFile->GetErrno();
+ if (iResult==-ENOSPC) {
+ HLTError("error writing memory file, buffer too small");
+ }
+ }
+ } else {
+ iResult=-EINVAL;
+ }
+ return iResult;
+}
+
+int AliHLTComponent::CloseMemoryFile(AliHLTMemoryFile* pFile)
+{
+ // see header file for function documentation
+ int iResult=0;
+ if (pFile) {
+ AliHLTMemoryFilePList::iterator element=fMemFiles.begin();
+ int i=0;
+ while (element!=fMemFiles.end() && iResult>=0) {
+ if (*element && *element==pFile) {
+ iResult=pFile->CloseMemoryFile();
+
+ // sync memory files and descriptors
+ if (iResult>=0) {
+ fOutputBlocks[i].fSize=(*element)->GetSize()+(*element)->GetHeaderSize();
+ }
+ delete *element;
+ *element=NULL;
+ return iResult;
+ }
+ element++; i++;
+ }
+ HLTError("can not find memory file %p", pFile);
+ iResult=-ENOENT;
+ } else {
+ iResult=-EINVAL;
+ }
+ return iResult;
+}
+
+int AliHLTComponent::CreateEventDoneData(AliHLTComponentEventDoneData /*edd*/)
{
// see header file for function documentation
int iResult=-ENOSYS;
fOutputBufferSize=size;
fOutputBufferFilled=0;
fOutputBlocks.clear();
+
+ // find special events
+ if (fpInputBlocks) {
+ // first look for all special events and execute in the appropriate
+ // sequence afterwords
+ int indexComConfEvent=-1;
+ int indexSOREvent=-1;
+ int indexEOREvent=-1;
+ for (unsigned int i=0; i<evtData.fBlockCnt && iResult>=0; i++) {
+ if (fpInputBlocks[i].fDataType==kAliHLTDataTypeSOR) {
+ indexSOREvent=i;
+ } else if (fpInputBlocks[i].fDataType==kAliHLTDataTypeEOR) {
+ indexEOREvent=i;
+ } else if (fpInputBlocks[i].fDataType==kAliHLTDataTypeDDL) {
+ // DDL list
+ // this event is most likely deprecated
+ } else if (fpInputBlocks[i].fDataType==kAliHLTDataTypeComConf) {
+ indexComConfEvent=i;
+ }
+ }
+ if (indexSOREvent>=0) {
+ // start of run
+ if (fpRunDesc==NULL) {
+ fpRunDesc=new AliHLTRunDesc;
+ if (fpRunDesc) {
+ if ((iResult=CopyStruct(fpRunDesc, sizeof(AliHLTRunDesc), indexSOREvent, "AliHLTRunDesc", "SOR"))>0) {
+ HLTDebug("set run decriptor, run no %d", fpRunDesc->fRunNo);
+ SetCDBRunNo(fpRunDesc->fRunNo);
+ }
+ } else {
+ iResult=-ENOMEM;
+ }
+ } else {
+ HLTWarning("already received SOR event run no %d, ignoring SOR", fpRunDesc->fRunNo);
+ }
+ }
+ if (indexEOREvent>=0) {
+ if (fpRunDesc!=NULL) {
+ if (fpRunDesc) {
+ AliHLTRunDesc rundesc;
+ if ((iResult=CopyStruct(&rundesc, sizeof(AliHLTRunDesc), indexEOREvent, "AliHLTRunDesc", "SOR"))>0) {
+ if (fpRunDesc->fRunNo!=rundesc.fRunNo) {
+ HLTWarning("run no missmatch: SOR %d, EOR %d", fpRunDesc->fRunNo, rundesc.fRunNo);
+ } else {
+ HLTDebug("EOR run no %d", fpRunDesc->fRunNo);
+ }
+ }
+ AliHLTRunDesc* pRunDesc=fpRunDesc;
+ fpRunDesc=NULL;
+ delete pRunDesc;
+ }
+ } else {
+ HLTWarning("did not receive SOR, ignoring EOR");
+ }
+ }
+ if (indexComConfEvent>=0) {
+ TString cdbEntry;
+ if (fpInputBlocks[indexComConfEvent].fPtr!=NULL && fpInputBlocks[indexComConfEvent].fSize>0) {
+ cdbEntry.Append(reinterpret_cast<const char*>(fpInputBlocks[indexComConfEvent].fPtr), fpInputBlocks[indexComConfEvent].fSize);
+ }
+ HLTDebug("received component configuration command: entry %s", cdbEntry.IsNull()?"none":cdbEntry.Data());
+ int tmpResult=Reconfigure(cdbEntry[0]==0?NULL:cdbEntry.Data(), fChainId.c_str());
+ if (tmpResult<0) {
+ HLTWarning("reconfiguration of component %p (%s) failed with error code %d", this, GetComponentID(), tmpResult);
+ }
+ }
+ }
- vector<AliHLTComponentBlockData> blockData;
+ AliHLTComponentBlockDataList blockData;
{ // dont delete, sets the scope for the stopwatch guard
ALIHLTCOMPONENT_DA_STOPWATCH();
iResult=DoProcessing(evtData, blocks, trigData, outputPtr, size, blockData, edd);
if (iResult>=0) {
if (fOutputBlocks.size()>0) {
//HLTDebug("got %d block(s) via high level interface", fOutputBlocks.size());
- if (blockData.size()>0) {
- HLTError("low level and high interface must not be mixed; use PushBack methods to insert data blocks");
- iResult=-EFAULT;
- } else {
- iResult=MakeOutputDataBlockList(fOutputBlocks, &outputBlockCnt, &outputBlocks);
- size=fOutputBufferFilled;
+
+ // sync memory files and descriptors
+ AliHLTMemoryFilePList::iterator element=fMemFiles.begin();
+ int i=0;
+ while (element!=fMemFiles.end() && iResult>=0) {
+ if (*element) {
+ if ((*element)->IsClosed()==0) {
+ HLTWarning("memory file has not been closed, force flush");
+ iResult=CloseMemoryFile(*element);
+ }
+ }
+ element++; i++;
+ }
+
+ if (iResult>=0) {
+ // create the descriptor list
+ if (blockData.size()>0) {
+ HLTError("low level and high interface must not be mixed; use PushBack methods to insert data blocks");
+ iResult=-EFAULT;
+ } else {
+ iResult=MakeOutputDataBlockList(fOutputBlocks, &outputBlockCnt, &outputBlocks);
+ size=fOutputBufferFilled;
+ }
}
} else {
iResult=MakeOutputDataBlockList(blockData, &outputBlockCnt, &outputBlocks);
outputBlocks=NULL;
}
CleanupInputObjects();
- IncrementEventCounter();
+ if (iResult>=0) {
+ IncrementEventCounter();
+ }
return iResult;
}
if (fpStopwatch && bStart==1) fpStopwatch->Start(kFALSE);
}
-AliHLTComponent::AliHLTStopwatchGuard::AliHLTStopwatchGuard(AliHLTStopwatchGuard&)
+AliHLTComponent::AliHLTStopwatchGuard::AliHLTStopwatchGuard(const AliHLTStopwatchGuard&)
:
fpStopwatch(NULL),
fpPrec(NULL)
{
- // copy constructor (not for use)
+ //
+ // copy constructor not for use
+ //
+}
+
+AliHLTComponent::AliHLTStopwatchGuard& AliHLTComponent::AliHLTStopwatchGuard::operator=(const AliHLTStopwatchGuard&)
+{
+ //
+ // assignment operator not for use
+ //
+ fpStopwatch=NULL;
+ fpPrec=NULL;
+ return *this;
}
AliHLTComponent::AliHLTStopwatchGuard* AliHLTComponent::AliHLTStopwatchGuard::fgpCurrent=NULL;
SetStopwatch(pStopwatches->At(i), (AliHLTStopwatchType)i);
return iResult;
}
+
+AliHLTUInt32_t AliHLTComponent::GetRunNo() const
+{
+ // see header file for function documentation
+ if (fpRunDesc==NULL) return 0;
+ return fpRunDesc->fRunNo;
+}
+
+AliHLTUInt32_t AliHLTComponent::GetRunType() const
+{
+ // see header file for function documentation
+ if (fpRunDesc==NULL) return 0;
+ return fpRunDesc->fRunType;
+}
+
+int AliHLTComponent::CopyStruct(void* pStruct, unsigned int iStructSize, unsigned int iBlockNo,
+ const char* structname, const char* eventname)
+{
+ // see header file for function documentation
+ int iResult=0;
+ if (pStruct!=NULL && iStructSize>sizeof(AliHLTUInt32_t)) {
+ if (fpInputBlocks!=NULL && iBlockNo<fCurrentEventData.fBlockCnt) {
+ AliHLTUInt32_t* pTgt=(AliHLTUInt32_t*)pStruct;
+ if (fpInputBlocks[iBlockNo].fPtr && fpInputBlocks[iBlockNo].fSize) {
+ AliHLTUInt32_t copy=*((AliHLTUInt32_t*)fpInputBlocks[iBlockNo].fPtr);
+ if (fpInputBlocks[iBlockNo].fSize!=copy) {
+ HLTWarning("%s event: missmatch of block size (%d) and structure size (%d)", eventname, fpInputBlocks[iBlockNo].fSize, copy);
+ if (copy>fpInputBlocks[iBlockNo].fSize) copy=fpInputBlocks[iBlockNo].fSize;
+ }
+ if (copy!=iStructSize) {
+ HLTWarning("%s event: missmatch in %s version (data type version %d)", eventname, structname, ALIHLT_DATA_TYPES_VERSION);
+ if (copy>iStructSize) {
+ copy=iStructSize;
+ } else {
+ memset(pTgt, 0, iStructSize);
+ }
+ }
+ memcpy(pTgt, fpInputBlocks[iBlockNo].fPtr, copy);
+ *pTgt=iStructSize;
+ iResult=copy;
+ } else {
+ HLTWarning("%s event: missing data block", eventname);
+ }
+ } else {
+ iResult=-ENODATA;
+ }
+ } else {
+ HLTError("invalid struct");
+ iResult=-EINVAL;
+ }
+ return iResult;
+}
+
+void AliHLTComponent::SetDDLBit(AliHLTEventDDL &list, Int_t ddlId, Bool_t state ) const
+{
+ // see header file for function documentation
+
+ // -- Detector offset
+ Int_t ddlIdBase = TMath::FloorNint( (Double_t) ddlId / 256.0 );
+
+ // -- Word Base = 1. word of detector ( TPC has 8 words, TOF 3 )
+ Int_t wordBase = 0;
+
+ if ( ddlIdBase <= 3 )
+ wordBase = ddlIdBase;
+ else if ( ddlIdBase > 3 && ddlIdBase < 5 )
+ wordBase = ddlIdBase + 7;
+ else
+ wordBase = ddlIdBase + 9;
+
+ // -- Bit index in Word
+ Int_t bitIdx = ddlId % 32;
+
+ // -- Index of word
+ Int_t wordIdx = wordBase;
+
+ // -- if TPC (3) or TOD (5) add word idx
+ if ( ( ddlIdBase == 3 ) || ( ddlIdBase == 5 ) ) {
+ wordIdx += TMath::FloorNint( (Double_t) ( ddlId - ( ddlIdBase * 256 ) ) / 32.0 );
+ }
+
+ // -- Set -- 'OR' word with bit mask;
+ if ( state )
+ list.fList[wordIdx] |= ( 0x00000001 << bitIdx );
+ // -- Unset -- 'AND' word with bit mask;
+ else
+ list.fList[wordIdx] &= ( 0xFFFFFFFF ^ ( 0x00000001 << bitIdx ) );
+}
+
+Int_t AliHLTComponent::GetFirstUsedDDLWord(AliHLTEventDDL &list) const
+{
+ // see header file for function documentation
+
+ Int_t iResult = -1;
+
+ for ( Int_t wordNdx = 0 ; wordNdx < gkAliHLTDDLListSize ; wordNdx++ ) {
+
+ if ( list.fList[wordNdx] != 0 && iResult == -1 ) {
+ // check for special cases TPC and TOF
+ if ( wordNdx > 3 && wordNdx <= 10 ) {
+ wordNdx = 10;
+ iResult = 3;
+ }
+ else if ( wordNdx > 12 && wordNdx <= 14 ) {
+ wordNdx = 14;
+ iResult = 12;
+ }
+ else
+ iResult = wordNdx;
+ }
+ else if ( list.fList[wordNdx] != 0 && iResult >= 0 ) {
+ HLTError( "DDLIDs for minimum of TWO detectors ( %d, %d ) set, this function works only for ONE detector.", iResult, wordNdx );
+ iResult = -1;
+ break;
+ }
+ }
+
+ return iResult;
+}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff