/** @file AliHLTConfiguration.cxx
@author Matthias Richter
@date
- @brief Implementation of HLT configuration handler.
+ @brief Implementation of HLT configurations.
*/
+// 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
fListSrcElement(),
fArguments(""),
fArgc(-1),
- fArgv(NULL)
+ fArgv(NULL),
+ fBufferSize(-1)
{
- // see header file for function documentation
+ // see header file for class documentation
+ // or
+ // refer to README to build package
+ // or
+ // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+
fListSrcElement=fListSources.begin();
}
-AliHLTConfiguration::AliHLTConfiguration(const char* id, const char* component, const char* sources, const char* arguments)
+AliHLTConfiguration::AliHLTConfiguration(const char* id, const char* component, const char* sources,
+ const char* arguments, const char* bufsize)
:
fID(id),
fComponent(component),
fListSrcElement(),
fArguments(arguments),
fArgc(-1),
- fArgv(NULL)
+ fArgv(NULL),
+ fBufferSize(-1)
{
// see header file for function documentation
+ if (bufsize) fBufferSize=ConvertSizeString(bufsize);
fListSrcElement=fListSources.begin();
if (id && component) {
if (fgConfigurationHandler) {
fListSrcElement(),
fArguments(src.fArguments),
fArgc(-1),
- fArgv(NULL)
+ fArgv(NULL),
+ fBufferSize(src.fBufferSize)
{
// see header file for function documentation
fListSrcElement=fListSources.begin();
fArguments=src.fArguments;
fArgc=-1;
fArgv=NULL;
+ fBufferSize=src.fBufferSize;
return *this;
}
// see header file for function documentation
if (fgConfigurationHandler) {
if (fgConfigurationHandler->FindConfiguration(fID.Data())!=NULL) {
+ // remove the configuration from the handler if it exists
+ // but DO NOT remove the clone configuration
fgConfigurationHandler->RemoveConfiguration(this);
}
}
{
// see header file for function documentation
int iResult=0;
- if (fgConfigurationHandler!=NULL) {
+ if (fgConfigurationHandler!=NULL && fgConfigurationHandler!=pHandler) {
fgConfigurationHandler->Logging(kHLTLogWarning, "AliHLTConfiguration::GlobalInit", HLT_DEFAULT_LOG_KEYWORD, "configuration handler already initialized, overriding object %p with %p", fgConfigurationHandler, pHandler);
}
fgConfigurationHandler=pHandler;
{
// see header file for function documentation
int iResult=0;
- if (pHandler!=NULL && fgConfigurationHandler!=pHandler) {
+ if (fgConfigurationHandler!=NULL && fgConfigurationHandler!=pHandler) {
fgConfigurationHandler->Logging(kHLTLogWarning, "AliHLTConfiguration::GlobalDeinit", HLT_DEFAULT_LOG_KEYWORD, "handler %p is not set, skip ...", pHandler);
return -EBADF;
}
{
// see header file for function documentation
AliHLTConfiguration* pSrc=NULL;
- if (fNofSources>=0 || ExtractSources()) {
+ if (fNofSources>=0 || ExtractSources()>=0) {
fListSrcElement=fListSources.begin();
if (fListSrcElement!=fListSources.end()) pSrc=*fListSrcElement;
}
{
// see header file for function documentation
int iResult=0;
- if (fNofSources>=0 || bAuto && (iResult=ExtractSources())>=0) {
+ if (fNofSources>=0 || (bAuto && (iResult=ExtractSources()))>=0) {
//HLTDebug("fNofSources=%d", fNofSources);
//HLTDebug("list size = %d", fListSources.size());
iResult=fNofSources==(int)fListSources.size();
return iResult;
}
-int AliHLTConfiguration::FollowDependency(const char* id, TList* pTgtList)
+int AliHLTConfiguration::ConvertSizeString(const char* strSize) const
{
// see header file for function documentation
- int iResult=0;
- if (id) {
- AliHLTConfiguration* pDep=NULL;
- if ((pDep=GetSource(id))!=NULL) {
- if (pTgtList) pTgtList->Add(pDep);
- iResult++;
- } else {
- pDep=GetFirstSource();
- while (pDep && iResult==0) {
- if ((iResult=pDep->FollowDependency(id, pTgtList))>0) {
- if (pTgtList) pTgtList->AddFirst(pDep);
- iResult++;
- }
- pDep=GetNextSource();
- }
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-
-/** ROOT macro for the implementation of ROOT specific class methods */
-ClassImp(AliHLTTask)
-
-AliHLTTask::AliHLTTask()
- :
- fpConfiguration(NULL),
- fpComponent(NULL),
- fpDataBuffer(NULL),
- fListTargets(),
- fListDependencies(),
- fBlockDataArray()
-{
- // see header file for function documentation
-}
-
-AliHLTTask::AliHLTTask(AliHLTConfiguration* pConf)
- :
- fpConfiguration(pConf),
- fpComponent(NULL),
- fpDataBuffer(NULL),
- fListTargets(),
- fListDependencies(),
- fBlockDataArray()
-{
- // see header file for function documentation
-}
-
-AliHLTTask::~AliHLTTask()
-{
- TObjLink* lnk=fListDependencies.FirstLink();
+ int size=0;
+ if (!strSize) return -1;
- while (lnk!=NULL) {
- AliHLTTask* pTask=(AliHLTTask*)lnk->GetObject();
- pTask->UnsetTarget(this);
- lnk=lnk->Next();
- }
- lnk=fListTargets.FirstLink();
-
- while (lnk!=NULL) {
- AliHLTTask* pTask=(AliHLTTask*)lnk->GetObject();
- pTask->UnsetDependency(this);
- lnk=lnk->Next();
- }
-
- if (fpComponent) delete fpComponent;
- fpComponent=NULL;
-}
-
-int AliHLTTask::Init(AliHLTConfiguration* pConf, AliHLTComponentHandler* pCH)
-{
- // see header file for function documentation
- int iResult=0;
- if (fpConfiguration!=NULL && pConf!=NULL && fpConfiguration!=pConf) {
- HLTWarning("overriding existing reference to configuration object %p (%s) by %p",
- fpConfiguration, GetName(), pConf);
- }
- if (pConf!=NULL) fpConfiguration=pConf;
- if (fpConfiguration) {
- if (pCH) {
- int argc=0;
- const char** argv=NULL;
- if ((iResult=fpConfiguration->GetArguments(&argv))>=0) {
- argc=iResult; // just to make it clear
- // TODO: we have to think about the optional environment parameter,
- // currently just set to NULL.
- iResult=pCH->CreateComponent(fpConfiguration->GetComponentID(), NULL, argc, argv, fpComponent);
- if (fpComponent || iResult<=0) {
- //HLTDebug("component %s (%p) created", fpComponent->GetComponentID(), fpComponent);
- } else {
- HLTError("can not find component \"%s\" (%d)", fpConfiguration->GetComponentID(), iResult);
- }
+ char* endptr=NULL;
+ size=strtol(strSize, &endptr, 10);
+ if (size>=0) {
+ if (endptr) {
+ if (endptr==strSize) {
+ HLTWarning("ignoring unrecognized buffer size '%s'", strSize);
+ size=-1;
+ } else if (*endptr==0) {
+ // no unit specifier
+ } else if (*endptr=='k') {
+ size*=1014;
+ } else if (*endptr=='M') {
+ size*=1024*1024;
} else {
- HLTError("can not get argument list for configuration %s (%s)", fpConfiguration->GetName(), fpConfiguration->GetComponentID());
- iResult=-EINVAL;
+ HLTWarning("ignoring buffer size of unknown unit '%c'", endptr[0]);
}
} else {
- HLTError("component handler instance needed for task initialization");
- iResult=-EINVAL;
+ HLTWarning("ignoring negative buffer size specifier '%s'", strSize);
+ size=-1;
}
- } else {
- HLTError("configuration object instance needed for task initialization");
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTTask::Deinit()
-{
- // see header file for function documentation
- int iResult=0;
- AliHLTComponent* pComponent=GetComponent();
- fpComponent=NULL;
- if (pComponent) {
- //HLTDebug("delete component %s (%p)", pComponent->GetComponentID(), pComponent);
- pComponent->Deinit();
- delete pComponent;
- } else {
- HLTWarning("task %s (%p) doesn't seem to be in initialized", GetName(), this);
- }
- return iResult;
-}
-
-const char *AliHLTTask::GetName() const
-{
- // see header file for function documentation
- if (fpConfiguration)
- return fpConfiguration->GetName();
- return TObject::GetName();
-}
-
-AliHLTConfiguration* AliHLTTask::GetConf() const
-{
- // see header file for function documentation
- return fpConfiguration;
-}
-
-AliHLTComponent* AliHLTTask::GetComponent() const
-{
- // see header file for function documentation
- return fpComponent;
-}
-
-AliHLTTask* AliHLTTask::FindDependency(const char* id)
-{
- // see header file for function documentation
- AliHLTTask* pTask=NULL;
- if (id) {
- pTask=(AliHLTTask*)fListDependencies.FindObject(id);
}
- return pTask;
+ return size;
}
-int AliHLTTask::FollowDependency(const char* id, TList* pTgtList)
+int AliHLTConfiguration::FollowDependency(const char* id, TList* pTgtList)
{
// see header file for function documentation
int iResult=0;
if (id) {
- AliHLTTask* pDep=NULL;
- if ((pDep=(AliHLTTask*)fListDependencies.FindObject(id))!=NULL) {
+ AliHLTConfiguration* pDep=NULL;
+ if ((pDep=GetSource(id))!=NULL) {
if (pTgtList) pTgtList->Add(pDep);
iResult++;
} else {
- TObjLink* lnk=fListDependencies.FirstLink();
- while (lnk && iResult==0) {
- pDep=(AliHLTTask*)lnk->GetObject();
- if (pDep) {
- if ((iResult=pDep->FollowDependency(id, pTgtList))>0) {
- if (pTgtList) pTgtList->AddFirst(pDep);
- iResult++;
- }
- } else {
- iResult=-EFAULT;
- }
- lnk=lnk->Next();
- }
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-void AliHLTTask::PrintDependencyTree(const char* id, int bFromConfiguration)
-{
- // see header file for function documentation
- HLTLogKeyword("task dependencies");
- int iResult=0;
- TList tgtList;
- if (bFromConfiguration) {
- if (fpConfiguration)
- iResult=fpConfiguration->FollowDependency(id, &tgtList);
- else
- iResult=-EFAULT;
- } else
- iResult=FollowDependency(id, &tgtList);
- if (iResult>0) {
- HLTMessage(" task \"%s\": dependency level %d ", GetName(), iResult);
- TObjLink* lnk=tgtList.FirstLink();
- int i=iResult;
- char* pSpace = new char[iResult+1];
- if (pSpace) {
- memset(pSpace, 32, iResult);
- pSpace[i]=0;
- while (lnk) {
- TObject* obj=lnk->GetObject();
- HLTMessage(" %s^-- %s ", &pSpace[i--], obj->GetName());
- lnk=lnk->Next();
- }
- delete [] pSpace;
- } else {
- iResult=-ENOMEM;
- }
- }
-}
-
-int AliHLTTask::SetDependency(AliHLTTask* pDep)
-{
- // see header file for function documentation
- int iResult=0;
- if (pDep) {
- if (FindDependency(pDep->GetName())==NULL) {
- fListDependencies.Add(pDep);
- } else {
- iResult=-EEXIST;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTTask::UnsetDependency(AliHLTTask* pDep)
-{
- fListDependencies.Remove(pDep);
- if (fpConfiguration) {
- fpConfiguration->InvalidateSources();
- }
- return 0;
-}
-
-int AliHLTTask::CheckDependencies()
-{
- // see header file for function documentation
- int iResult=0;
- AliHLTConfiguration* pSrc=fpConfiguration->GetFirstSource();
- while (pSrc) {
- if (FindDependency(pSrc->GetName())==NULL) {
- //HLTDebug("dependency \"%s\" unresolved", pSrc->GetName());
- iResult++;
- }
- pSrc=fpConfiguration->GetNextSource();
- }
- return iResult;
-}
-
-
-int AliHLTTask::Depends(AliHLTTask* pTask)
-{
- // see header file for function documentation
- int iResult=0;
- if (pTask) {
- if (fpConfiguration) {
- iResult=fpConfiguration->GetSource(pTask->GetName())!=NULL;
- if (iResult>0) {
- //HLTDebug("task \"%s\" depends on \"%s\"", GetName(), pTask->GetName());
- } else {
- //HLTDebug("task \"%s\" independend of \"%s\"", GetName(), pTask->GetName());
- }
- } else {
- iResult=-EFAULT;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-AliHLTTask* AliHLTTask::FindTarget(const char* id)
-{
- // see header file for function documentation
- AliHLTTask* pTask=NULL;
- if (id) {
- pTask=(AliHLTTask*)fListTargets.FindObject(id);
- }
- return pTask;
-}
-
-int AliHLTTask::SetTarget(AliHLTTask* pTgt)
-{
- // see header file for function documentation
- int iResult=0;
- if (pTgt) {
- if (FindTarget(pTgt->GetName())==NULL) {
- fListTargets.Add(pTgt);
- } else {
- iResult=-EEXIST;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTTask::UnsetTarget(AliHLTTask* pTarget)
-{
- fListTargets.Remove(pTarget);
- return 0;
-}
-
-int AliHLTTask::StartRun()
-{
- // see header file for function documentation
- int iResult=0;
- int iNofInputDataBlocks=0;
- AliHLTComponent* pComponent=GetComponent();
- if (pComponent) {
- // determine the number of input data blocks provided from the source tasks
- TObjLink* lnk=fListDependencies.FirstLink();
- while (lnk && iResult>=0) {
- AliHLTTask* pSrcTask=(AliHLTTask*)lnk->GetObject();
- if (pSrcTask) {
- if ((iResult=pSrcTask->GetNofMatchingDataTypes(this))>0) {
- iNofInputDataBlocks+=iResult;
- } else if (iResult==0) {
- HLTWarning("source task %s (%p) does not provide any matching data type for task %s (%p)", pSrcTask->GetName(), pSrcTask, GetName(), this);
- } else {
- HLTError("task %s (%p): error getting matching data types for source task %s (%p)", GetName(), this, pSrcTask->GetName(), pSrcTask);
- iResult=-EFAULT;
- }
- }
- lnk=lnk->Next();
- }
- if (iResult>=0) {
- if (fBlockDataArray.size()>0) {
- HLTWarning("block data array for task %s (%p) was not cleaned", GetName(), this);
- fBlockDataArray.resize(0);
- }
-
- // component init
- // the initialization of the component is done by the ComponentHandler after creation
- // of the component.
- //iResult=Init( AliHLTComponentEnvironment* environ, void* environ_param, int argc, const char** argv );
-
- // allocate internal task variables for bookkeeping aso.
- // we allocate the BlockData array with at least one member
- if (iNofInputDataBlocks==0) iNofInputDataBlocks=1;
- AliHLTComponentBlockData init;
- memset(&init, 0, sizeof(AliHLTComponentBlockData));
- fBlockDataArray.resize(iNofInputDataBlocks, init);
-
- // allocate the data buffer, which controls the output buffer and subscriptions
- if (iResult>=0) {
- fpDataBuffer=new AliHLTDataBuffer;
- if (fpDataBuffer!=NULL) {
- HLTDebug("created data buffer %p for task %s (%p)", fpDataBuffer, GetName(), this);
- TObjLink* lnk=fListTargets.FirstLink();
- while (lnk && iResult>=0) {
- AliHLTTask* pTgtTask=(AliHLTTask*)lnk->GetObject();
- if (pTgtTask) {
- if ((iResult=fpDataBuffer->SetConsumer(pTgtTask->GetComponent()))>=0) {
- }
- } else {
- break;
- iResult=-EFAULT;
- }
- lnk=lnk->Next();
- }
- } else {
- HLTFatal("can not create data buffer object, memory allocation failed");
- iResult=-ENOMEM;
- }
- }
- }
- } else {
- HLTError("task %s (%p) does not have a component", GetName(), this);
- iResult=-EFAULT;
- }
- return iResult;
-}
-
-int AliHLTTask::EndRun()
-{
- // see header file for function documentation
- int iResult=0;
- if (fBlockDataArray.size()>0) {
- fBlockDataArray.resize(0);
- } else {
- HLTWarning("task %s (%p) doesn't seem to be in running mode", GetName(), this);
- }
- if (fpDataBuffer) {
- AliHLTDataBuffer* pBuffer=fpDataBuffer;
- fpDataBuffer=NULL;
- delete pBuffer;
- }
- return iResult;
-}
-
-int AliHLTTask::ProcessTask(Int_t eventNo)
-{
- // see header file for function documentation
- int iResult=0;
- AliHLTComponent* pComponent=GetComponent();
- if (pComponent && fpDataBuffer) {
- HLTDebug("Processing task %s (%p) fpDataBuffer %p", GetName(), this, fpDataBuffer);
- fpDataBuffer->Reset();
- int iSourceDataBlock=0;
- int iInputDataVolume=0;
-
- AliHLTTask* pSrcTask=NULL;
- TList subscribedTaskList;
- TObjLink* lnk=fListDependencies.FirstLink();
-
- // subscribe to all source tasks
- while (lnk && iResult>=0) {
- pSrcTask=(AliHLTTask*)lnk->GetObject();
- if (pSrcTask) {
- int iMatchingDB=pSrcTask->GetNofMatchingDataBlocks(this);
- if (iMatchingDB>fBlockDataArray.size()-iSourceDataBlock) {
- AliHLTComponentBlockData init;
- memset(&init, 0, sizeof(AliHLTComponentBlockData));
- fBlockDataArray.resize(iSourceDataBlock+iMatchingDB, init);
- }
- if ((iResult=pSrcTask->Subscribe(this, &fBlockDataArray[iSourceDataBlock],fBlockDataArray.size()-iSourceDataBlock))>0) {
- for (int i=0; i<iResult; i++) {
- iInputDataVolume+=fBlockDataArray[i+iSourceDataBlock].fSize;
- // put the source task as many times into the list as it provides data blocks
- // makes the bookkeeping for the data release easier
- subscribedTaskList.Add(pSrcTask);
- }
- HLTDebug("Task %s (%p) successfully subscribed to %d data block(s) of task %s (%p)", GetName(), this, iResult, pSrcTask->GetName(), pSrcTask);
- iSourceDataBlock+=iResult;
- iResult=0;
- } else {
- HLTError("Task %s (%p): subscription to task %s (%p) failed with error %d", GetName(), this, pSrcTask->GetName(), pSrcTask, iResult);
- iResult=-EFAULT;
- }
- } else {
- HLTFatal("fatal internal error in ROOT list handling");
- iResult=-EFAULT;
- }
- lnk=lnk->Next();
- }
-
- // process the event
- int iNofTrial=0; // repeat processing if component returns -ENOSPC
- AliHLTUInt32_t size=0;
- if (iResult>=0) {
- do {
- long unsigned int iConstBase=0;
- double fInputMultiplier=0;
- if (pComponent->GetComponentType()!=AliHLTComponent::kSink)
- pComponent->GetOutputDataSize(iConstBase, fInputMultiplier);
- if (fInputMultiplier<0) {
- HLTWarning("ignoring negative input multiplier");
- fInputMultiplier=0;
- }
- long unsigned int iOutputDataSize=int(fInputMultiplier*iInputDataVolume) + iConstBase;
- //HLTDebug("task %s: reqired output size %d", GetName(), iOutputDataSize);
- if (iNofTrial>0) {
- // dont process again if the buffer size is the same
- if (size==iOutputDataSize) break;
- HLTInfo("processing task %s again with buffer size %d", GetName(), iOutputDataSize);
- }
- AliHLTUInt8_t* pTgtBuffer=NULL;
- if (iOutputDataSize>0) pTgtBuffer=fpDataBuffer->GetTargetBuffer(iOutputDataSize);
- //HLTDebug("provided raw buffer %p", pTgtBuffer);
- AliHLTComponentEventData evtData;
- AliHLTComponent::FillEventData(evtData);
- evtData.fEventID=(AliHLTEventID_t)eventNo;
- evtData.fBlockCnt=iSourceDataBlock;
- AliHLTComponentTriggerData trigData;
- size=iOutputDataSize;
- AliHLTUInt32_t outputBlockCnt=0;
- AliHLTComponentBlockData* outputBlocks=NULL;
- AliHLTComponentEventDoneData* edd;
- if (pTgtBuffer!=NULL || iOutputDataSize==0) {
- iResult=pComponent->ProcessEvent(evtData, &fBlockDataArray[0], trigData, pTgtBuffer, size, outputBlockCnt, outputBlocks, edd);
- HLTDebug("task %s: component %s ProcessEvent finnished (%d): size=%d blocks=%d", GetName(), pComponent->GetComponentID(), iResult, size, outputBlockCnt);
- if (iResult>=0 && pTgtBuffer) {
- iResult=fpDataBuffer->SetSegments(pTgtBuffer, outputBlocks, outputBlockCnt);
- delete [] outputBlocks; outputBlocks=NULL; outputBlockCnt=0;
- } else {
- fpDataBuffer->Reset();
- }
- } else {
- HLTError("task %s: no target buffer available", GetName());
- iResult=-EFAULT;
- }
- } while (iResult==-ENOSPC && iNofTrial++<1);
- }
-
- // now release all buffers which we have subscribed to
- iSourceDataBlock=0;
- lnk=subscribedTaskList.FirstLink();
- while (lnk) {
- pSrcTask=(AliHLTTask*)lnk->GetObject();
- if (pSrcTask) {
- int iTempRes=0;
- if ((iTempRes=pSrcTask->Release(&fBlockDataArray[iSourceDataBlock], this))>=0) {
- HLTDebug("Task %s (%p) successfully released segment of task %s (%p)", GetName(), this, pSrcTask->GetName(), pSrcTask);
- } else {
- HLTError("Task %s (%p): realease of task %s (%p) failed with error %d", GetName(), this, pSrcTask->GetName(), pSrcTask, iTempRes);
- }
- } else {
- HLTFatal("task %s (%p): internal error in ROOT list handling", GetName(), this);
- if (iResult>=0) iResult=-EFAULT;
- }
- subscribedTaskList.Remove(lnk);
- lnk=subscribedTaskList.FirstLink();
- iSourceDataBlock++;
- }
- if (subscribedTaskList.GetSize()>0) {
- HLTError("task %s (%p): could not release all data buffers", GetName(), this);
- }
- } else {
- HLTError("task %s (%p): internal failure (not initialized component %p, data buffer %p)", GetName(), this, fpComponent, fpDataBuffer);
- iResult=-EFAULT;
- }
- return iResult;
-}
-
-int AliHLTTask::GetNofMatchingDataBlocks(const AliHLTTask* pConsumerTask) const
-{
- // see header file for function documentation
- int iResult=0;
- if (pConsumerTask) {
- if (fpDataBuffer) {
- iResult=fpDataBuffer->FindMatchingDataBlocks(pConsumerTask->GetComponent(), NULL);
- } else {
- HLTFatal("internal data buffer missing");
- iResult=-EFAULT;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTTask::GetNofMatchingDataTypes(const AliHLTTask* pConsumerTask) const
-{
- // see header file for function documentation
- int iResult=0;
- if (pConsumerTask) {
- AliHLTComponent* pComponent=GetComponent();
- if (!pComponent) {
- // init ?
- HLTError("component not initialized");
- iResult=-EFAULT;
- }
- if (pComponent) {
- iResult=pComponent->FindMatchingDataTypes(pConsumerTask->GetComponent(), NULL);
- } else {
- HLTFatal("task initialization failed");
- iResult=-EFAULT;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTTask::Subscribe(const AliHLTTask* pConsumerTask, AliHLTComponentBlockData* pBlockDesc, int iArraySize)
-{
- // see header file for function documentation
- int iResult=0;
- if (pConsumerTask) {
- if (fpDataBuffer) {
- iResult=fpDataBuffer->Subscribe(pConsumerTask->GetComponent(), pBlockDesc, iArraySize);
- } else {
- HLTFatal("internal data buffer missing");
- iResult=-EFAULT;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTTask::Release(AliHLTComponentBlockData* pBlockDesc, const AliHLTTask* pConsumerTask)
-{
- // see header file for function documentation
- int iResult=0;
- if (pConsumerTask && pBlockDesc) {
- if (fpDataBuffer) {
- iResult=fpDataBuffer->Release(pBlockDesc, pConsumerTask->GetComponent());
- } else {
- HLTFatal("internal data buffer missing");
- iResult=-EFAULT;
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-void AliHLTTask::PrintStatus()
-{
- // see header file for function documentation
- HLTLogKeyword("task properties");
- AliHLTComponent* pComponent=GetComponent();
- if (pComponent) {
- HLTMessage(" component: %s (%p)", pComponent->GetComponentID(), pComponent);
- } else {
- HLTMessage(" no component set!");
- }
- if (fpConfiguration) {
- AliHLTConfiguration* pSrc=fpConfiguration->GetFirstSource();
- while (pSrc) {
- const char* pQualifier="unresolved";
- if (FindDependency(pSrc->GetName()))
- pQualifier="resolved";
- HLTMessage(" source: %s (%s)", pSrc->GetName(), pQualifier);
- pSrc=fpConfiguration->GetNextSource();
- }
- TObjLink* lnk = fListTargets.FirstLink();
- while (lnk) {
- TObject *obj = lnk->GetObject();
- HLTMessage(" target: %s", obj->GetName());
- lnk = lnk->Next();
- }
- } else {
- HLTMessage(" task \"%s\" not initialized", GetName());
- }
-}
-
-///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-
-/** ROOT macro for the implementation of ROOT specific class methods */
-ClassImp(AliHLTConfigurationHandler)
-
-AliHLTConfigurationHandler::AliHLTConfigurationHandler()
- :
- fgListConfigurations()
-{
- // see header file for function documentation
- SetLocalLoggingLevel(kHLTLogInfo);
-}
-
-AliHLTConfigurationHandler::~AliHLTConfigurationHandler()
-{
- // see header file for function documentation
- TObjLink* lnk=NULL;
- while (lnk=fgListConfigurations.FirstLink()) {
- AliHLTConfiguration* pConf=(AliHLTConfiguration*)lnk->GetObject();
- HLTDebug("delete configuration \"%s\"", pConf->GetName());
- fgListConfigurations.Remove(lnk);
- delete pConf;
- }
-}
-
-int AliHLTConfigurationHandler::RegisterConfiguration(AliHLTConfiguration* pConf)
-{
- // see header file for function documentation
- int iResult=0;
- if (pConf) {
- if (FindConfiguration(pConf->GetName()) == NULL) {
- AliHLTConfiguration* pClone=new AliHLTConfiguration(*pConf);
- fgListConfigurations.Add(pClone);
- HLTDebug("configuration \"%s\" (%p) registered from %p", pClone->GetName(), pClone, pConf);
-
- // mark all configurations with unresolved dependencies for re-evaluation
- TObjLink* lnk=fgListConfigurations.FirstLink();
- while (lnk) {
- AliHLTConfiguration* pSrc=(AliHLTConfiguration*)lnk->GetObject();
- if (pSrc && pSrc!=pClone && pSrc->SourcesResolved()!=1) {
- pSrc->InvalidateSources();
+ pDep=GetFirstSource();
+ while (pDep && iResult==0) {
+ if ((iResult=pDep->FollowDependency(id, pTgtList))>0) {
+ if (pTgtList) pTgtList->AddFirst(pDep);
+ iResult++;
}
- lnk=lnk->Next();
+ pDep=GetNextSource();
}
- } else {
- iResult=-EEXIST;
- HLTWarning("configuration \"%s\" already registered", pConf->GetName());
- }
- } else {
- iResult=-EINVAL;
- }
- return iResult;
-}
-
-int AliHLTConfigurationHandler::CreateConfiguration(const char* id, const char* component, const char* sources, const char* arguments)
-{
- // see header file for function documentation
- int iResult=0;
- AliHLTConfiguration* pConf= new AliHLTConfiguration(id, component, sources, arguments);
- if (pConf) {
- // the configuration will be registered automatically, if this failes the configuration
- // is missing -> delete it
- if (FindConfiguration(id)==NULL) {
- delete pConf;
- pConf=NULL;
- iResult=-EEXIST;
- }
- } else {
- HLTError("system error: object allocation failed");
- iResult=-ENOMEM;
- }
- return iResult;
-}
-
-void AliHLTConfigurationHandler::PrintConfigurations()
-{
- // see header file for function documentation
- HLTLogKeyword("configuration listing");
- HLTMessage("registered configurations:");
- TObjLink *lnk = fgListConfigurations.FirstLink();
- while (lnk) {
- TObject *obj = lnk->GetObject();
- HLTMessage(" %s", obj->GetName());
- lnk = lnk->Next();
- }
-}
-
-int AliHLTConfigurationHandler::RemoveConfiguration(const char* id)
-{
- // see header file for function documentation
- int iResult=0;
- if (id) {
- AliHLTConfiguration* pConf=NULL;
- if ((pConf=FindConfiguration(id))!=NULL) {
- iResult=RemoveConfiguration(pConf);
- delete pConf;
- pConf=NULL;
- } else {
- HLTWarning("can not find configuration \"%s\"", id);
- iResult=-ENOENT;
}
} else {
iResult=-EINVAL;
return iResult;
}
-int AliHLTConfigurationHandler::RemoveConfiguration(AliHLTConfiguration* pConf)
-{
- // see header file for function documentation
- int iResult=0;
- if (pConf) {
- // remove the configuration from the list
- HLTDebug("remove configuration \"%s\"", pConf->GetName());
- fgListConfigurations.Remove(pConf);
- // remove cross links in the remaining configurations
- TObjLink* lnk=fgListConfigurations.FirstLink();
- while (lnk && iResult>=0) {
- AliHLTConfiguration* pRem=(AliHLTConfiguration*)lnk->GetObject();
- if (pRem) {
- pRem->InvalidateSource(pConf);
- } else {
- iResult=-EFAULT;
- }
- lnk=lnk->Next();
- }
- }
- return iResult;
-}
-
-AliHLTConfiguration* AliHLTConfigurationHandler::FindConfiguration(const char* id)
-{
- // see header file for function documentation
- AliHLTConfiguration* pConf=NULL;
- if (id) {
- pConf=(AliHLTConfiguration*)fgListConfigurations.FindObject(id);
- }
- return pConf;
-}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff