// $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> *
- * 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 *
- * 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 AliHLTExternalInterface.cxx
@author Matthias Richter, Timm Steinbeck
@date
- @brief Pure C interface to the AliRoot HLT component handler
+ @brief Pure C interface to the AliRoot HLT analysis framework
*/
-#if __GNUC__>= 3
-using namespace std;
-#endif
-
#include "AliHLTExternalInterface.h"
#include "AliHLTComponentHandler.h"
#include "AliHLTComponent.h"
#include "AliHLTSystem.h"
#include <cerrno>
+/////////////////////////////////////////////////////////////////////////////////////
+//
+// AliHLT external interface functions
+//
-static AliHLTComponentHandler *gComponentHandler_C = NULL;
-
+static AliHLTComponentHandler *gComponentHandler = NULL;
+static AliHLTRunDesc gRunDesc=kAliHLTVoidRunDesc;
+static char* gRunType=NULL;
-int AliHLT_C_Component_InitSystem( AliHLTComponentEnvironment* comenv )
+int AliHLTAnalysisInitSystem( unsigned long version, AliHLTAnalysisEnvironment* externalEnv, unsigned long runNo, const char* runType )
{
- if ( gComponentHandler_C )
- {
- return EINPROGRESS;
- }
- gComponentHandler_C = new AliHLTComponentHandler(comenv);
- if ( !gComponentHandler_C )
+ if ( gComponentHandler ) {
+ return EINPROGRESS;
+ }
+
+ if (!externalEnv) {
+ return EINVAL;
+ }
+
+ if (!externalEnv->fStructSize) {
+ return EPERM;
+ }
+
+ // map the environment structure to the internal structure to
+ // support different versions of the interface
+ AliHLTAnalysisEnvironment mappedEnv;
+ memset(&mappedEnv, 0, sizeof(mappedEnv));
+ memcpy(&mappedEnv, externalEnv, sizeof(mappedEnv)<externalEnv->fStructSize?sizeof(mappedEnv):externalEnv->fStructSize);
+ mappedEnv.fStructSize=sizeof(mappedEnv);
+
+ gComponentHandler = new AliHLTComponentHandler(&mappedEnv);
+ if ( !gComponentHandler )
return EFAULT;
- gComponentHandler_C->InitAliLogTrap(gComponentHandler_C);
- gComponentHandler_C->AnnounceVersion();
+ gComponentHandler->InitAliLogTrap(gComponentHandler);
+ gComponentHandler->AnnounceVersion();
+
+ if (version!=ALIHLT_DATA_TYPES_VERSION && externalEnv->fLoggingFunc) {
+ char message[100];
+ sprintf(message, "interface definition does not match: internal %d - external %lu", ALIHLT_DATA_TYPES_VERSION, version);
+ externalEnv->fLoggingFunc(externalEnv->fParam, kHLTLogWarning, "AliHLTAnalysisInitSystem", "interface version", message);
+ }
+
+ gRunDesc.fRunNo=runNo;
+ if (runType && strlen(runType)>0) {
+ gRunType=new char[strlen(runType)+1];
+ if (gRunType) {
+ strcpy(gRunType, runType);
+ }
+ }
return 0;
}
-int AliHLT_C_Component_DeinitSystem()
+int AliHLTAnalysisDeinitSystem()
{
- if ( gComponentHandler_C )
- {
- delete gComponentHandler_C;
- gComponentHandler_C = NULL;
- }
+ if (gComponentHandler) delete gComponentHandler;
+ gComponentHandler = NULL;
+
+ if (gRunType) delete[] gRunType;
+ gRunType=NULL;
+
+ gRunDesc=kAliHLTVoidRunDesc;
+
return 0;
}
-int AliHLT_C_Component_LoadLibrary( const char* libraryPath )
+int AliHLTAnalysisLoadLibrary( const char* libraryPath )
{
- if ( !gComponentHandler_C )
+ if ( !gComponentHandler )
return ENXIO;
- return gComponentHandler_C->LoadLibrary( libraryPath );
+ return gComponentHandler->LoadLibrary( libraryPath );
}
-int AliHLT_C_Component_UnloadLibrary( const char* libraryPath )
+int AliHLTAnalysisUnloadLibrary( const char* /*libraryPath*/ )
{
- if ( !gComponentHandler_C )
+ if ( !gComponentHandler )
return ENXIO;
- return gComponentHandler_C->UnloadLibrary( libraryPath );
+ // Matthias 26.10.2007
+ // Unloading of libraries has to be re-worked. It has been commented out here
+ // since the libraries will be unloaded at the destruction of the component
+ // handler instance anyway. So it has no effect to the operation in PubSub.
+ // With the introduction of the dynamic component registration via module
+ // agents we run into trouble when cleaning up the samples managed by the
+ // component handler. Destruction of the sample objects is done AFTER
+ // unloading of the library and thus the destructor is not present any
+ // more.
+ //return gComponentHandler->UnloadLibrary( libraryPath );
+ return 0;
}
-int AliHLT_C_CreateComponent( const char* componentType, void* environParam, int argc, const char** argv, AliHLTComponentHandle* handle )
+int AliHLTAnalysisCreateComponent( const char* componentType, void* environParam, int argc, const char** argv, AliHLTComponentHandle* handle, const char* description )
{
- if ( !gComponentHandler_C )
- return ENXIO;
- AliHLTComponent* comp;
- int ret = gComponentHandler_C->CreateComponent( componentType, environParam, argc, argv, comp );
+ if ( !gComponentHandler ) return ENXIO;
+ if (!handle) return EINVAL;
+
+ AliHLTComponent* comp=NULL;
+ const char* cdbPath = getenv("ALIHLT_HCDBDIR");
+ if (!cdbPath) cdbPath = getenv("ALICE_ROOT");
+ int ret = gComponentHandler->CreateComponent( componentType, comp);
+ if (ret>=0 && comp) {
+ comp->InitCDB(cdbPath, gComponentHandler);
+ const AliHLTAnalysisEnvironment* comenv=gComponentHandler->GetEnvironment();
+ if (comenv) {
+ if (description) {
+ comp->SetComponentDescription(description);
+ }
+ comp->SetRunDescription(&gRunDesc, gRunType);
+ }
+ ret=comp->Init(comenv, environParam, argc, argv);
+ }
*handle = reinterpret_cast<AliHLTComponentHandle>( comp );
+
return ret;
}
-void AliHLT_C_DestroyComponent( AliHLTComponentHandle handle )
+int AliHLTAnalysisDestroyComponent( AliHLTComponentHandle handle )
{
if ( !handle )
- return;
+ return ENOENT;
AliHLTComponent* pComp=reinterpret_cast<AliHLTComponent*>( handle );
pComp->Deinit();
delete pComp;
+ return 0;
}
-int AliHLT_C_ProcessEvent( AliHLTComponentHandle handle, const AliHLTComponentEventData* evtData, const AliHLTComponentBlockData* blocks,
+int AliHLTAnalysisProcessEvent( AliHLTComponentHandle handle, const AliHLTComponentEventData* evtData, const AliHLTComponentBlockData* blocks,
AliHLTComponentTriggerData* trigData, AliHLTUInt8_t* outputPtr,
AliHLTUInt32_t* size, AliHLTUInt32_t* outputBlockCnt,
AliHLTComponentBlockData** outputBlocks,
AliHLTComponentEventDoneData** edd )
{
- if ( !handle )
- return ENXIO;
+ if ( !handle ) return EINVAL;
AliHLTComponent* comp = reinterpret_cast<AliHLTComponent*>( handle );
- return comp->ProcessEvent( *evtData, blocks, *trigData, outputPtr, *size, *outputBlockCnt, *outputBlocks, *edd );
+ if (!comp) return ENXIO;
+ int ret=comp->ProcessEvent( *evtData, blocks, *trigData, outputPtr, *size, *outputBlockCnt, *outputBlocks, *edd );
+
+ // internally, return values <0 are errors, >=0 are success with some
+ // optional return vaue.
+ // externally everthing !=0 is error. This is also according to the
+ // common habit
+ if (ret>0) ret=0;
+ else if (ret<0) ret*=-1;
+ return ret;
}
-int AliHLT_C_GetOutputDataType( AliHLTComponentHandle handle, AliHLTComponentDataType* dataType )
+int AliHLTAnalysisGetOutputDataType( AliHLTComponentHandle handle, AliHLTComponentDataType* dataType )
{
- if ( !handle )
- return ENXIO;
+ if ( !handle ) return EINVAL;
AliHLTComponent* comp = reinterpret_cast<AliHLTComponent*>( handle );
+ if (!comp) return ENXIO;
*dataType = comp->GetOutputDataType();
return 0;
}
-int AliHLT_C_GetOutputSize( AliHLTComponentHandle handle, unsigned long* constBase, double* inputMultiplier )
+int AliHLTAnalysisGetOutputSize( AliHLTComponentHandle handle, unsigned long* constEventBase, unsigned long* constBlockBase, double* inputBlockMultiplier )
{
- if ( !handle )
- return ENXIO;
+ if ( !handle ) return EINVAL;
AliHLTComponent* comp = reinterpret_cast<AliHLTComponent*>( handle );
- comp->GetOutputDataSize( *constBase, *inputMultiplier );
+ if (!comp) return ENXIO;
+ // TODO: extend component interface
+ if (constEventBase) *constEventBase=0;
+ comp->GetOutputDataSize( *constBlockBase, *inputBlockMultiplier );
return 0;
}
+struct AliHLTAnalysisInterfaceCall {
+ const char* fSignature;
+ void* fCall;
+};
+
+AliHLTAnalysisInterfaceCall gSignatures[]={
+ //int AliHLTAnalysisInitSystem( unsigned long version, AliHLTAnalysisEnvironment* externalEnv, unsigned long runNo, const char* runType )
+ {"int AliHLTAnalysisInitSystem(unsigned long,AliHLTAnalysisEnvironment*,unsigned long,const char*)", (void*)AliHLTAnalysisInitSystem},
+
+ //int AliHLTAnalysisDeinitSystem()
+ {"int AliHLTAnalysisDeinitSystem()", (void*)AliHLTAnalysisDeinitSystem},
+
+ //int AliHLTAnalysisLoadLibrary( const char* libraryPath )
+ {"int AliHLTAnalysisLoadLibrary(const char*)", (void*)AliHLTAnalysisLoadLibrary},
+
+ //int AliHLTAnalysisUnloadLibrary( const char* /*libraryPath*/ )
+ {"int AliHLTAnalysisUnloadLibrary(const char*)", (void*)AliHLTAnalysisUnloadLibrary},
+
+ //int AliHLTAnalysisCreateComponent( const char* componentType, void* environParam, int argc, const char** argv, AliHLTComponentHandle* handle, const char* description )
+ {"int AliHLTAnalysisCreateComponent(const char*,void*,int,const char**,AliHLTComponentHandle*,const char*)", (void*)AliHLTAnalysisCreateComponent},
+
+ //int AliHLTAnalysisDestroyComponent( AliHLTComponentHandle handle )
+ {"int AliHLTAnalysisDestroyComponent(AliHLTComponentHandle)", (void*)AliHLTAnalysisDestroyComponent},
+
+ //int AliHLTAnalysisProcessEvent( AliHLTComponentHandle handle, const AliHLTComponentEventData* evtData, const AliHLTComponentBlockData* blocks, AliHLTComponentTriggerData* trigData, AliHLTUInt8_t* outputPtr, AliHLTUInt32_t* size, AliHLTUInt32_t* outputBlockCnt, AliHLTComponentBlockData** outputBlocks, AliHLTComponentEventDoneData** edd )
+ {"int AliHLTAnalysisProcessEvent(AliHLTComponentHandle,const AliHLTComponentEventData*,const AliHLTComponentBlockData*,AliHLTComponentTriggerData*,AliHLTUInt8_t*,AliHLTUInt32_t*,AliHLTUInt32_t*,AliHLTComponentBlockData**,AliHLTComponentEventDoneData**)", (void*)AliHLTAnalysisProcessEvent},
+
+ //int AliHLTAnalysisGetOutputDataType( AliHLTComponentHandle handle, AliHLTComponentDataType* dataType )
+ {"int AliHLTAnalysisGetOutputDataType(AliHLTComponentHandle,AliHLTComponentDataType*)", (void*)AliHLTAnalysisGetOutputDataType},
+
+ //int AliHLTAnalysisGetOutputSize( AliHLTComponentHandle handle, unsigned long* constEventBase, unsigned long* constBlockBase, double* inputBlockMultiplier )
+ {"int AliHLTAnalysisGetOutputSize(AliHLTComponentHandle,unsigned long*,unsigned long*,double*)", (void*)AliHLTAnalysisGetOutputSize},
+
+ {NULL, NULL}
+};
+
+void* AliHLTAnalysisGetInterfaceCall(const char* signature)
+{
+ if (!signature) return NULL;
+ for (int i=0; gSignatures[i].fSignature!=NULL; i++) {
+ if (strcmp(gSignatures[i].fSignature, signature)==0) {
+ return gSignatures[i].fCall;
+ }
+ }
+ return NULL;
+}
+
+/////////////////////////////////////////////////////////////////////////////////////
+//
+// AliHLTSystem interface functions
+//
int AliHLTSystemSetOptions(AliHLTSystem* pInstance, const char* options)
{
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff