// @(#) $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> *
- * for The ALICE Off-line Project. *
+ * 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 *
@note The class is used in Offline (AliRoot) context
*/
+// see header file for class documentation
+// or
+// refer to README to build package
+// or
+// visit http://web.ift.uib.no/~kjeks/doc/alice-hlt
+
#include "AliHLTModuleAgent.h"
+#include "AliHLTOUTHandler.h"
/** ROOT macro for the implementation of ROOT specific class methods */
ClassImp(AliHLTModuleAgent)
-AliHLTModuleAgent::AliHLTModuleAgent()
+AliHLTModuleAgent::AliHLTModuleAgent(const char* id)
+ :
+ fpNext(NULL),
+ fpComponentHandler(NULL),
+ fModuleId(id)
{
// see header file for class documentation
// or
Register(this);
}
-AliHLTModuleAgent::AliHLTModuleAgent(const AliHLTModuleAgent&)
- :
- TObject(),
- AliHLTLogging()
+const char* AliHLTModuleAgent::GetQAPlugins() const
{
- // see header file for function documentation
+ // default implementation, childs can overload
+ return "";
}
-AliHLTModuleAgent& AliHLTModuleAgent::operator=(const AliHLTModuleAgent&)
+const AliHLTModuleAgent::AliHLTOUTHandlerDesc AliHLTModuleAgent::fgkVoidHandlerDesc;
+
+AliHLTModuleAgent::~AliHLTModuleAgent()
{
// see header file for function documentation
- return *this;
+ Unregister(this);
}
-TList AliHLTModuleAgent::fgAgentList;
-TObjLink* AliHLTModuleAgent::fgCurrentLnk=NULL;
-
-AliHLTModuleAgent::~AliHLTModuleAgent()
+const char* AliHLTModuleAgent::GetModuleId() const
{
// see header file for function documentation
- Unregister(this);
+ return fModuleId.Data();
}
void AliHLTModuleAgent::PrintStatus(const char* agent)
{
// see header file for function documentation
AliHLTLogging log;
- if (agent) {
- TObject* pAgent=fgAgentList.FindObject(agent);
- if (pAgent) {
- log.Logging(kHLTLogInfo, "AliHLTModuleAgent::PrintStatus", "module agents",
- "agent %s available", pAgent->GetName());
- } else {
- log.Logging(kHLTLogInfo, "AliHLTModuleAgent::PrintStatus", "module agents",
- "agent %s not found", agent);
- }
+ if (agent) {
+ AliHLTModuleAgent* pCurrent=fgAnchor;
+ while (pCurrent!=NULL && strcmp(pCurrent->GetName(), agent)!=0) pCurrent=pCurrent->fpNext;
+ if (pCurrent) {
+ log.Logging(kHLTLogInfo, "AliHLTModuleAgent::PrintStatus", "module agents",
+ "agent %s available", pCurrent->GetName());
+ } else {
+ log.Logging(kHLTLogInfo, "AliHLTModuleAgent::PrintStatus", "module agents",
+ "agent %s not found", agent);
+ }
} else {
- TObjLink* lnk=fgAgentList.FirstLink();
- log.Logging(kHLTLogInfo, "AliHLT", "", "-----------------------");
- log.Logging(kHLTLogInfo, "AliHLT", "", "available module agents");
- if (lnk==NULL)
- log.Logging(kHLTLogInfo, "AliHLT", "", " none");
- while (lnk) {
- TString msg;
- msg.Form(" %s : %p", ((AliHLTModuleAgent*)lnk->GetObject())->GetName(), lnk->GetObject());
- log.Logging(kHLTLogInfo, "AliHLT", "", msg.Data());
- lnk=lnk->Next();
- }
- log.Logging(kHLTLogInfo, "AliHLT", "", "-----------------------");
+ AliHLTModuleAgent* pCurrent=fgAnchor;
+ log.Logging(kHLTLogInfo, "AliHLT", "", "-----------------------");
+ log.Logging(kHLTLogInfo, "AliHLT", "", "available module agents");
+ if (pCurrent==NULL)
+ log.Logging(kHLTLogInfo, "AliHLT", "", " none");
+ while (pCurrent) {
+ TString msg;
+ msg.Form(" %s : %p", pCurrent->GetName(), pCurrent);
+ log.Logging(kHLTLogInfo, "AliHLT", "", msg.Data());
+ pCurrent=pCurrent->fpNext;
+ }
+ log.Logging(kHLTLogInfo, "AliHLT", "", "-----------------------");
}
}
-int AliHLTModuleAgent::CreateConfigurations(AliHLTConfigurationHandler* handler,
- AliRunLoader* runloader) const
+int AliHLTModuleAgent::CreateConfigurations(AliHLTConfigurationHandler* /*handler*/,
+ AliRawReader* /*rawReader*/,
+ AliRunLoader* /*runloader*/) const
{
// default method, nothing to be done, child classes can overload
- if (handler==NULL && runloader==NULL) {
- // get rid of 'unused parameter' warning
- }
return 0;
}
-const char* AliHLTModuleAgent::GetLocalRecConfigurations(AliRunLoader* runloader) const
+const char* AliHLTModuleAgent::GetReconstructionChains(AliRawReader* /*rawReader*/,
+ AliRunLoader* /*runloader*/) const
{
// default method, nothing to be done, child classes can overload
- if (runloader==NULL) {
- // get rid of 'unused parameter' warning
- }
return NULL;
}
-const char* AliHLTModuleAgent::GetEventRecConfigurations(AliRunLoader* runloader) const
+const char* AliHLTModuleAgent::GetRequiredComponentLibraries() const
{
// default method, nothing to be done, child classes can overload
- if (runloader==NULL) {
- // get rid of 'unused parameter' warning
- }
return NULL;
}
-const char* AliHLTModuleAgent::GetRequiredComponentLibraries() const
+int AliHLTModuleAgent::GetHandlerDescription(AliHLTComponentDataType /*dt*/,
+ AliHLTUInt32_t /*spec*/,
+ AliHLTOUTHandlerDesc& /*desc*/) const
+{
+ // default method, nothing to be done, child classes can overload
+ return 0;
+}
+
+AliHLTOUTHandler* AliHLTModuleAgent::GetOutputHandler(AliHLTComponentDataType /*dt*/,
+ AliHLTUInt32_t /*spec*/)
{
// default method, nothing to be done, child classes can overload
return NULL;
}
-int AliHLTModuleAgent::RegisterComponents(AliRunLoader* runloader) const
+int AliHLTModuleAgent::DeleteOutputHandler(AliHLTOUTHandler* pInstance)
+{
+ // default method, simply deletes object
+ if (pInstance) return -EINVAL;
+ delete pInstance;
+ return 0;
+}
+
+
+// likely to be moved to AliHLTOUTHandler
+// AliRawStream* AliHLTModuleAgent::GetRawStream(AliHLTComponentDataType /*dt*/,
+// AliHLTUInt32_t /*spec*/,
+// const AliHLTOUT* /*pData*/) const
+// {
+// // default method, nothing to be done, child classes can overload
+// return NULL;
+// }
+
+int AliHLTModuleAgent::ActivateComponentHandler(AliHLTComponentHandler* pHandler)
{
- if (runloader==NULL) {
- // get rid of 'unused parameter' warning
+ // see header file for function documentation
+ int iResult=0;
+ if (pHandler==NULL) {
+ if (fpComponentHandler!=NULL) {
+ // reset and think about deregistration
+ fpComponentHandler=NULL;
+ HLTWarning("deregistration of components not yet implemented");
+ }
+ return 0;
}
+ if (fpComponentHandler!=NULL) {
+ if (pHandler!=fpComponentHandler) {
+ HLTError("only one component handler can be activated per agent");
+ return -EINVAL;
+ }
+ return 0;
+ }
+ if ((iResult=RegisterComponents(pHandler))>=0) {
+ fpComponentHandler=pHandler;
+ }
+ return iResult;
+}
+
+int AliHLTModuleAgent::RegisterComponents(AliHLTComponentHandler* /*pHandler*/) const
+{
// default method, nothing to be done, child classes can overload
return 0;
}
+AliHLTModulePreprocessor* AliHLTModuleAgent::GetPreprocessor()
+{
+ // default method, nothing to be done, child classes can overload
+ return NULL;
+}
+
+AliHLTModuleAgent* AliHLTModuleAgent::fgAnchor=NULL;
+AliHLTModuleAgent* AliHLTModuleAgent::fgCurrent=NULL;
+int AliHLTModuleAgent::fgCount=0;
+
AliHLTModuleAgent* AliHLTModuleAgent::GetFirstAgent()
{
// see header file for function documentation
- fgCurrentLnk=fgAgentList.FirstLink();
- if (fgCurrentLnk==NULL) return NULL;
- return (AliHLTModuleAgent*)fgCurrentLnk->GetObject();
+ fgCurrent=fgAnchor;
+ return fgAnchor;
}
AliHLTModuleAgent* AliHLTModuleAgent::GetNextAgent()
{
// see header file for function documentation
- if (fgCurrentLnk==NULL) return NULL;
- fgCurrentLnk=fgCurrentLnk->Next();
- if (fgCurrentLnk==NULL) return NULL;
- return (AliHLTModuleAgent*)fgCurrentLnk->GetObject();
+ if (fgCurrent!=NULL) fgCurrent=fgCurrent->fpNext;
+ return fgCurrent;
+}
+
+string AliHLTModuleAgent::GetAgentIds()
+{
+ // see header file for function documentation
+ string ids;
+ ids.clear();
+ for (AliHLTModuleAgent* pCurrent=fgAnchor;
+ pCurrent;
+ pCurrent=pCurrent->fpNext) {
+ if (ids.size()>0) ids+=" ";
+ ids+=pCurrent->GetModuleId();
+ }
+
+ return ids;
}
int AliHLTModuleAgent::Register(AliHLTModuleAgent* pAgent)
// see header file for function documentation
AliHLTLogging log;
if (!pAgent) return -EINVAL;
- if (fgAgentList.FindObject(pAgent)==NULL) {
- log.Logging(kHLTLogDebug, "AliHLTModuleAgent::Register", "", "module agent %p registered", pAgent);
- fgAgentList.Add(pAgent);
+ // The following check is for extra protection. In some strange cases the agent might
+ // try to register itself more than once. So we need to check for that and prevent it.
+ // Otherwise we create a cycle in our linked list and go into an infinite loop.
+ AliHLTModuleAgent* current=fgAnchor;
+ while (current!=NULL) {
+ if (current == pAgent) return 0;
+ current = current->fpNext;
}
- return 0;
+ if (fgAnchor==NULL) {
+ fgAnchor=pAgent;
+ } else {
+ pAgent->fpNext=fgAnchor;
+ fgAnchor=pAgent;
+ }
+ // log.Logging(kHLTLogDebug, "AliHLTModuleAgent::Register", "", "module agent %p registered", pAgent);
+ fgCount++;
+ return 0;
}
int AliHLTModuleAgent::Unregister(AliHLTModuleAgent* pAgent)
// see header file for function documentation
AliHLTLogging log;
if (!pAgent) return -EINVAL;
- if (fgAgentList.FindObject(pAgent)!=NULL) {
- log.Logging(kHLTLogDebug, "AliHLTModuleAgent::Unregister", "", "module agent %p removed", pAgent);
- fgAgentList.Remove(pAgent);
- } else {
+ fgCurrent=NULL;
+ AliHLTModuleAgent* prev=NULL;
+ AliHLTModuleAgent* handler=fgAnchor;
+ while (handler!=NULL && handler!=pAgent) {
+ prev=handler;
+ handler=handler->fpNext;
+ }
+ if (handler) {
+ if (prev==NULL) {
+ fgAnchor=handler->fpNext;
+ } else {
+ prev->fpNext=handler->fpNext;
+ }
+ //log.Logging(kHLTLogDebug, "AliHLTModuleAgent::Unregister", "", "module agent %p removed", pAgent);
+ fgCount--;
}
return 0;
}
git://git.uio.no / u / mrichter / AliRoot.git / blobdiff