#include "AliHLTStdIncludes.h"
#include "AliHLTComponent.h"
#include "AliHLTComponentHandler.h"
-#include "AliHLTSystem.h"
+#include "TString.h"
/** ROOT macro for the implementation of ROOT specific class methods */
ClassImp(AliHLTComponent)
AliHLTComponent::AliHLTComponent()
:
fEnvironment(),
- fCurrentEvent(0)
-{
+ fCurrentEvent(0),
+ fEventCount(-1)
+{
+ // see header file for class documentation
+ // or
+ // refer to README to build package
+ // or
+ // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
memset(&fEnvironment, 0, sizeof(AliHLTComponentEnvironment));
- if (fpComponentHandler)
- fpComponentHandler->ScheduleRegister(this);
+ if (fgpComponentHandler)
+ fgpComponentHandler->ScheduleRegister(this);
+}
+
+AliHLTComponent::AliHLTComponent(const AliHLTComponent&)
+ :
+ fEnvironment(),
+ fCurrentEvent(0),
+ fEventCount(-1)
+{
+ // 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
}
-AliHLTComponentHandler* AliHLTComponent::fpComponentHandler=NULL;
+AliHLTComponentHandler* AliHLTComponent::fgpComponentHandler=NULL;
int AliHLTComponent::SetGlobalComponentHandler(AliHLTComponentHandler* pCH, int bOverwrite)
{
+ // see header file for function documentation
int iResult=0;
- if (fpComponentHandler==NULL || bOverwrite!=0)
- fpComponentHandler=pCH;
+ if (fgpComponentHandler==NULL || bOverwrite!=0)
+ fgpComponentHandler=pCH;
else
iResult=-EPERM;
return iResult;
}
-int AliHLTComponent::UnsetGlobalComponentHandler() {
+int AliHLTComponent::UnsetGlobalComponentHandler()
+{
+ // see header file for function documentation
return SetGlobalComponentHandler(NULL,1);
}
-int AliHLTComponent::Init( AliHLTComponentEnvironment* environ, void* environ_param, int argc, const char** argv )
+int AliHLTComponent::Init( AliHLTComponentEnvironment* environ, void* environParam, int argc, const char** argv )
{
+ // see header file for function documentation
int iResult=0;
if (environ) {
memcpy(&fEnvironment, environ, sizeof(AliHLTComponentEnvironment));
- fEnvironment.fParam=environ_param;
+ fEnvironment.fParam=environParam;
}
iResult=DoInit(argc, argv);
+ if (iResult>=0) fEventCount=0;
return iResult;
}
int AliHLTComponent::Deinit()
{
+ // see header file for function documentation
int iResult=0;
iResult=DoDeinit();
return iResult;
int AliHLTComponent::DoInit( int argc, const char** argv )
{
+ // see header file for function documentation
if (argc==0 && argv==NULL) {
// this is currently just to get rid of the warning "unused parameter"
}
int AliHLTComponent::DoDeinit()
{
+ // see header file for function documentation
return 0;
}
-void AliHLTComponent::DataType2Text( const AliHLTComponentDataType& type, char output[kAliHLTComponentDataTypefIDsize+kAliHLTComponentDataTypefOriginSize+2] ) {
+void AliHLTComponent::DataType2Text( const AliHLTComponentDataType& type, char output[kAliHLTComponentDataTypefIDsize+kAliHLTComponentDataTypefOriginSize+2] ) const
+{
+ // see header file for function documentation
memset( output, 0, kAliHLTComponentDataTypefIDsize+kAliHLTComponentDataTypefOriginSize+2 );
strncat( output, type.fOrigin, kAliHLTComponentDataTypefOriginSize );
strcat( output, ":" );
string AliHLTComponent::DataType2Text( const AliHLTComponentDataType& type )
{
+ // see header file for function documentation
string out("");
+
if (type==kAliHLTVoidDataType) {
out="VOID:VOID";
} else {
- out.append(type.fOrigin, kAliHLTComponentDataTypefOriginSize);
+ // some gymnastics in order to avoid a '0' which is part of either or both
+ // ID and origin terminating the whole string. Unfortunately, string doesn't
+ // stop appending at the '0' if the number of elements to append was
+ // explicitely specified
+ string tmp("");
+ tmp.append(type.fOrigin, kAliHLTComponentDataTypefOriginSize);
+ out.append(tmp.c_str());
out.append(":");
- out.append(type.fID, kAliHLTComponentDataTypefIDsize);
+ tmp="";
+ tmp.append(type.fID, kAliHLTComponentDataTypefIDsize);
+ out.append(tmp.c_str());
}
return out;
}
-void* AliHLTComponent::AllocMemory( unsigned long size ) {
+void* AliHLTComponent::AllocMemory( unsigned long size )
+{
+ // see header file for function documentation
if (fEnvironment.fAllocMemoryFunc)
return (*fEnvironment.fAllocMemoryFunc)(fEnvironment.fParam, size );
HLTFatal("no memory allocation handler registered");
}
int AliHLTComponent::MakeOutputDataBlockList( const vector<AliHLTComponentBlockData>& blocks, AliHLTUInt32_t* blockCount,
- AliHLTComponentBlockData** outputBlocks ) {
+ AliHLTComponentBlockData** outputBlocks )
+{
+ // see header file for function documentation
if ( blockCount==NULL || outputBlocks==NULL )
return -EFAULT;
AliHLTUInt32_t count = blocks.size();
}
-int AliHLTComponent::GetEventDoneData( unsigned long size, AliHLTComponentEventDoneData** edd ) {
+int AliHLTComponent::GetEventDoneData( unsigned long size, AliHLTComponentEventDoneData** edd )
+{
+ // see header file for function documentation
if (fEnvironment.fGetEventDoneDataFunc)
return (*fEnvironment.fGetEventDoneDataFunc)(fEnvironment.fParam, fCurrentEvent, size, edd );
return -ENOSYS;
int AliHLTComponent::FindMatchingDataTypes(AliHLTComponent* pConsumer, vector<AliHLTComponentDataType>* tgtList)
{
+ // see header file for function documentation
int iResult=0;
if (pConsumer) {
vector<AliHLTComponentDataType> ctlist;
return iResult;
}
-void AliHLTComponent::FillBlockData( AliHLTComponentBlockData& blockData ) {
+void AliHLTComponent::FillBlockData( AliHLTComponentBlockData& blockData ) const
+{
+ // see header file for function documentation
blockData.fStructSize = sizeof(blockData);
FillShmData( blockData.fShmKey );
blockData.fOffset = ~(AliHLTUInt32_t)0;
blockData.fSpecification = ~(AliHLTUInt32_t)0;
}
-void AliHLTComponent::FillShmData( AliHLTComponentShmData& shmData ) {
+void AliHLTComponent::FillShmData( AliHLTComponentShmData& shmData ) const
+{
+ // see header file for function documentation
shmData.fStructSize = sizeof(shmData);
shmData.fShmType = gkAliHLTComponentInvalidShmType;
shmData.fShmID = gkAliHLTComponentInvalidShmID;
}
-void AliHLTComponent::FillDataType( AliHLTComponentDataType& dataType ) {
+void AliHLTComponent::FillDataType( AliHLTComponentDataType& dataType ) const
+{
+ // see header file for function documentation
dataType=kAliHLTAnyDataType;
}
-void AliHLTComponent::CopyDataType(AliHLTComponentDataType& tgtdt, const AliHLTComponentDataType& srcdt) {
+void AliHLTComponent::CopyDataType(AliHLTComponentDataType& tgtdt, const AliHLTComponentDataType& srcdt)
+{
+ // see header file for function documentation
memcpy(&tgtdt.fID[0], &srcdt.fID[0], kAliHLTComponentDataTypefIDsize);
memcpy(&tgtdt.fOrigin[0], &srcdt.fOrigin[0], kAliHLTComponentDataTypefOriginSize);
}
-void AliHLTComponent::SetDataType(AliHLTComponentDataType& tgtdt, const char* id, const char* origin) {
+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);
void AliHLTComponent::FillEventData(AliHLTComponentEventData& evtData)
{
+ // see header file for function documentation
memset(&evtData, 0, sizeof(AliHLTComponentEventData));
evtData.fStructSize=sizeof(AliHLTComponentEventData);
}
-void AliHLTComponent::PrintComponentDataTypeInfo(const AliHLTComponentDataType& dt) {
+void AliHLTComponent::PrintComponentDataTypeInfo(const AliHLTComponentDataType& dt)
+{
+ // see header file for function documentation
TString msg;
msg.Form("AliHLTComponentDataType(%d): ID=\"", dt.fStructSize);
for ( int i = 0; i < kAliHLTComponentDataTypefIDsize; i++ ) {
else msg+="\\0";
}
msg+="\"";
- HLTMessage(msg.Data());
+ AliHLTLogging::Message(NULL, kHLTLogNone, NULL , NULL, msg.Data());
+}
+
+int AliHLTComponent::GetEventCount() const
+{
+ // see header file for function documentation
+ return fEventCount;
}
+int AliHLTComponent::IncrementEventCounter()
+{
+ // see header file for function documentation
+ if (fEventCount>=0) fEventCount++;
+ return fEventCount;
+}
+
+int AliHLTComponent::ProcessEvent( const AliHLTComponentEventData& evtData,
+ const AliHLTComponentBlockData* blocks,
+ AliHLTComponentTriggerData& trigData,
+ AliHLTUInt8_t* outputPtr,
+ AliHLTUInt32_t& size,
+ AliHLTUInt32_t& outputBlockCnt,
+ AliHLTComponentBlockData*& outputBlocks,
+ AliHLTComponentEventDoneData*& edd )
+{
+ // see header file for function documentation
+ int iResult=0;
+ fCurrentEvent=evtData.fEventID;
+ iResult=DoProcessing(evtData, blocks, trigData, outputPtr, size, outputBlockCnt, outputBlocks, edd);
+ IncrementEventCounter();
+ return iResult;
+}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff