]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - HLT/BASE/AliHLTModuleAgent.h
bugfix 88038: inconsistent handling of reference counters in library manager
[u/mrichter/AliRoot.git] / HLT / BASE / AliHLTModuleAgent.h
index 5d4b8f17356c8461b16c005f5720467e8427ac0e..ca1c8030363ff42de5e7c6572f37a4700bc3fc5d 100644 (file)
 // or
 // visit http://web.ift.uib.no/~kjeks/doc/alice-hlt   
 
+#include <string>
 #include <TObject.h>
 #include <TList.h>
+#include <TString.h>
 #include "AliHLTLogging.h"
 #include "AliHLTConfiguration.h"
 #include "AliHLTConfigurationHandler.h"
@@ -32,6 +34,7 @@ class AliRawReader;
 class AliRawStream;
 class AliHLTOUTHandler;
 class AliHLTOUT;
+class AliHLTModulePreprocessor;
 
 /**
  * @class AliHLTModuleAgent
@@ -44,8 +47,8 @@ class AliHLTOUT;
  * @note There must not be more than one agent per module/library.
  *
  * If a run loader is available, reconstruction is performed on simulated
- * data as part of <tt>AliSimulation</tt>, if the raw reader is present on
- * raw data as part of <tt>AliReconstruction</tt>. The configurations
+ * data as part of <tt>AliSimulation</tt>, if only the raw reader is present,
+ * on raw data as part of <tt>AliReconstruction</tt>. The configurations
  * can adapt to the two cases.
  *
  * All HLT component libraries are loaded on demand through the HLT steering
@@ -68,8 +71,8 @@ class AliHLTOUT;
  *       Create HLT configuration forming an HLT analysis chain.            <br>
  *       Reconstruction of raw data or simulated data from digits needs
  *       usually different configurations. If a run loader is available,
- *       reconstruction is performed on simulated data, on raw data if the
- *       raw reader is present.
+ *       reconstruction is performed on simulated data, on raw data if Run
+ *       loader is NULL and only the raw reader present.
  *
  * - @ref GetReconstructionChains                                           <br>
  *       Configurations run during event reconstruction.                    <br>
@@ -96,12 +99,6 @@ class AliHLTOUT;
  *       Return AliHLTOUTHandler for a given data type and specification.
  *       This is mainly intended to treat detector proprietary data.
  *
- * - @ref GetRawStream                                                      <br>
- *       Return an AliRawStream object which is capable of treating the
- *       specified data type and specification. Rawstream must be provided
- *       for data blocks intended to be the input for AliRoot detector
- *       reconstruction by replacing the normal input stream.
- *
  * @section alihltmoduleagent_references References
  * @see @ref AliHLTReconstructor interface to the AliRoot reconstruction
  * @see @ref AliHLTAgentSample agent for the libAliHLTSample library
@@ -114,10 +111,18 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    * standard constructor. The agent is automatically registered in the
    * global agent manager
    */
-  AliHLTModuleAgent();
+  AliHLTModuleAgent(const char* id);
   /** destructor */
   virtual ~AliHLTModuleAgent();
 
+  /**
+   * Get module id.
+   * The module id is a string specifying the detector, or module. The
+   * library must follow the naming scheme \em libAliHLTModule.so, e.g.
+   * \em libAliHLTTPC.so if the module is 'TPC'
+   */
+  const char* GetModuleId() const;
+
   /**
    * Print status info.
    * Short summary on registered agents. This function acts globally on the
@@ -137,6 +142,11 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    */
   static AliHLTModuleAgent* GetNextAgent();
 
+  /**
+   * Get string of blank separated Module Ids
+   */
+  static string GetAgentIds();
+
   /**
    * Activate a component handler for this agent.
    * The @ref RegisterComponents method will be called in order to allow
@@ -145,7 +155,7 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    * invocation. In the current stage of development, only one handler
    * can be activated per agent. This is sufficient for the current
    * operation, but can be extended.
-   * @param pHandler  [in] the component handler instance
+   * @param [in] pHandler  the component handler instance
    */
   int ActivateComponentHandler(AliHLTComponentHandler* pHandler);
 
@@ -154,14 +164,16 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    * AliHLTConfigurationHandler. The agent can adapt the configurations
    * to be registered to the current AliRoot setup by checking the
    * runloader and the raw reader. <br>
-   * Run loader and raw reader are usually not present at the same time.
-   * If a run loader is available, reconstruction is performed on simulated
-   * data, if the raw reader is present on raw data. The configurations
+   * The presence of Run loader and raw reader determines the mode of the
+   * HLT reconstruction. If a run loader is available, reconstruction is
+   * performed on simulated data, a raw reader might be available in that
+   * case also. When running embedded into AliReconstruction, the Run loader
+   * is always NULL and the raw gives access to data. The configurations
    * can adapt to the two cases.
    *
-   * @param handler   [in] the configuration handler
-   * @param rawReader [in] AliRoot RawReader instance 
-   * @param runloader [in] AliRoot runloader
+   * @param [in] handler   the configuration handler
+   * @param [in] rawReader AliRoot RawReader instance 
+   * @param [in] runloader AliRoot runloader
    * @return neg. error code if failed
    */
   virtual int CreateConfigurations(AliHLTConfigurationHandler* handler,
@@ -174,8 +186,8 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    * described by the last configuration(s) in the chain. 
    * The agent can adapt the configurations to be registered to the current
    * AliRoot setup by checking the run loader and the raw reader.
-   * @param rawReader [in] AliRoot RawReader instance 
-   * @param runloader [in] AliRoot runloader
+   * @param [in] rawReader AliRoot RawReader instance 
+   * @param [in] runloader AliRoot runloader
    * @return string containing the top configurations separated by blanks
    */
   virtual const char* GetReconstructionChains(AliRawReader* rawReader=NULL,
@@ -199,10 +211,16 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    * - @ref AliHLTComponentHandler::AddComponent                           <br>
    *        Same functionality but handler deletes the object at the end.
    *
-   * @param pHandler  [in] instance of the component handler          
+   * @param [in] pHandler  instance of the component handler          
    */
   virtual int RegisterComponents(AliHLTComponentHandler* pHandler) const;
 
+  /**
+   * Define QA plugins
+   * @return blank separated list of class names
+   */
+  virtual const char* GetQAPlugins() const;
+
   /**
    * IDs for output handlers.
    * The agent can provide output handlers in order to treat the output
@@ -210,12 +228,32 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
    */
   enum AliHLTOUTHandlerType {
     kUnknownOutput =0,
+
     /** output is in ESD format */
     kEsd,
-    /** agent can create a raw stream */
-    kRawstream,
-    /** agent provides a chain */
+
+    /** agent provides data for a RawReader
+     * From the data block one or more output blocks can be
+     * created idenditcal to the ddl format. The blocks are
+     * provided to subsequent analysis by a RawReader instance.
+     * The data block can be processed in order to provide the
+     * raw data, e.g. in case of lossless compression.
+     */
+    kRawReader,
+
+    /** agent can create a raw stream
+     * The agent directly generates a detector specific RawStream
+     * object. This is used for pre-analyzed data which will not
+     * be converted back to the raw format.
+     */
+    kRawStream,
+
+    /** agent provides a chain
+     * The data block is fed into an analysis chain, the treatment
+     * depends on the components in the chain.
+     */
     kChain,
+
     /** agent provides detector specific handler */
     kProprietary,
     kLastOutputHandler
@@ -224,47 +262,114 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
   /**
    * Output handler description.
    * \em fModule: module name specific for the handler type
-   *              - kRawStream: class name of the Rawstream class
+   *              - kRawReader: DDL no printed in ascii format
+   *              - kRawStream: class name of the RawStream class
    *              - kChain:     blank separated list of chains
    *              - kProprietary: name of the handler class
    */
-  struct AliHLTOUTHandlerDesc {
+  class AliHLTOUTHandlerDesc {
+  public:
+    AliHLTOUTHandlerDesc() : fHType(kUnknownOutput), fDt(kAliHLTVoidDataType), fModule() {}
+
+    AliHLTOUTHandlerDesc(AliHLTOUTHandlerType handlerType, AliHLTComponentDataType dt, const char* module) 
+      : fHType(handlerType), fDt(dt), fModule(module) {}
+
+    AliHLTOUTHandlerDesc(const AliHLTOUTHandlerDesc& src) 
+      : fHType(src.fHType), fDt(src.fDt), fModule(src.fModule) {}
+
+    const AliHLTOUTHandlerDesc& operator=(const AliHLTOUTHandlerDesc& src) {
+      fHType=src.fHType; fDt=src.fDt; fModule=src.fModule; return *this;
+    }
+
+    ~AliHLTOUTHandlerDesc() {}
+
+    bool operator==(const AliHLTOUTHandlerType handlerType) const {
+      return fHType==handlerType;
+    }
+    /**
+     * Two descriptors are equal if all members match.
+     */
+    bool operator==(const AliHLTOUTHandlerDesc& desc) const {
+      return fDt==desc.fDt && fHType==desc.fHType && fModule==desc.fModule;
+    }
+
+    operator AliHLTOUTHandlerType() {return fHType;}
+    operator AliHLTComponentDataType() {return fDt;}
+
+  private:
     /** type of the handler */
-    AliHLTOUTHandlerType    fHType;
+    AliHLTOUTHandlerType    fHType;                          //!transient
     /** data type treated by the handler */
-    AliHLTComponentDataType fDt;
+    AliHLTComponentDataType fDt;                             //!transient
     /** class or chain name */
-    const char*             fModule;
+    TString                 fModule;                         //!transient
   };
 
+  static const AliHLTOUTHandlerDesc fgkVoidHandlerDesc; //! initializer
+
   /**
    * Get handler description for a data block.
-   * @param dt        [in] data type of the block
-   * @param spec      [in] specification of the block
-   * @param desc      [out] handler description
+   * Depending on the data type and data specification the handler must
+   * provide information
+   * - if it can handle the data block, and
+   * - details how it will handle it, mainly the type of the handler
+   *   @ref AliHLTOUTHandlerType
+   * 
+   * @param [in] dt        data type of the block
+   * @param [in] spec      specification of the block
+   * @param [out] desc      handler description
    * @return 1 if the agent can provide a handler, 0 if not
    */
   virtual int GetHandlerDescription(AliHLTComponentDataType dt,
                                    AliHLTUInt32_t spec,
                                    AliHLTOUTHandlerDesc& desc) const;
+
   /**
    * Get handler for a data block of the HLTOUT data.
-   * @param dt        [in] data type of the block
-   * @param spec      [in] specification of the block
+   * The agent can also provide an overloaded @ref DeleteOutputHandler
+   * function to implement customized clean up. It is also possible to
+   * return the same instance of a handler for different data blocks.<br>
+   *
+   * The framework first collects the handlers for all data blocks, and
+   * calls the @ref AliHLTOUTHandler::ProcessData method afterwords for
+   * each handler.
+   * @param [in] dt        data type of the block
+   * @param [in] spec      specification of the block
+   * @return pointer to handler
    */
   virtual AliHLTOUTHandler* GetOutputHandler(AliHLTComponentDataType dt,
-                                            AliHLTUInt32_t spec) const;
+                                            AliHLTUInt32_t spec);
+
+  /**
+   * Delete an HLTOUT handler.
+   * This is the final cleanup. The framwork makes sure that the handler is
+   * not used any further outside the agent. Even if the agent returned the
+   * same handler several times, cleanup is invoked only once. The default
+   * implementation just deletes the object.
+   * @param pInstance      pointer to handler
+   */
+  virtual int DeleteOutputHandler(AliHLTOUTHandler* pInstance);
 
   /**
    * Get raw stream for a data block.
-   * @param dt        [in] data type of the block
-   * @param spec      [in] specification of the block
-   * @param pData     [in] data control object
+   * @param [in] dt        data type of the block
+   * @param [in] spec      specification of the block
+   * @param [in] pData     data control object
    * @return Rawstream object, NULL if no Rawstream available for data type/spec
    */
-  virtual AliRawStream* GetRawStream(AliHLTComponentDataType dt,
-                                    AliHLTUInt32_t spec,
-                                    const AliHLTOUT* pData) const;
+  // this method is likely to be moved to a specific implementation
+  // of AliHLTOUTHandler
+//   virtual AliRawStream* GetRawStream(AliHLTComponentDataType dt,
+//                                  AliHLTUInt32_t spec,
+//                                  const AliHLTOUT* pData);
+
+  /**
+   * Get the preprocessor for this component library.
+   * Create an instance of the preprocessor for this component library.
+   * The caller will delete it after useage.
+   * @return pointer to AliHLTModulePreprocessor object.
+   */
+  virtual AliHLTModulePreprocessor* GetPreprocessor();
 
   /**
    * Old method kept for backward compatibility, redirected to @ref
@@ -277,6 +382,8 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
  protected:
 
  private:
+  /** standard constructor prohibited */
+  AliHLTModuleAgent();
   /** copy constructor prohibited */
   AliHLTModuleAgent(const AliHLTModuleAgent&);
   /** assignment operator prohibited */
@@ -295,21 +402,24 @@ class AliHLTModuleAgent : public TObject, public AliHLTLogging {
   static int Unregister(AliHLTModuleAgent* pAgent);
 
   /** the list of active agents */
-  static AliHLTModuleAgent* fAnchor;                               //! transient
+  static AliHLTModuleAgent* fgAnchor;                               //! transient
 
   /** next element in the list */
   AliHLTModuleAgent* fpNext;                                       //! transient
 
   /** the current object link (list position) */
-  static AliHLTModuleAgent* fCurrent;                              //! transient
+  static AliHLTModuleAgent* fgCurrent;                              //! transient
 
   /** number of agents */
-  static int fCount;                                               //! transient
+  static int fgCount;                                               //! transient
 
-  /* instance of the active component handler */
+  /** instance of the active component handler */
   AliHLTComponentHandler* fpComponentHandler;                      //! transient
 
-  ClassDef(AliHLTModuleAgent, 2);
+  /** id of the module */
+  TString fModuleId;                                               //! transient
+
+  ClassDef(AliHLTModuleAgent, 3);
 };
 
 #endif