DataHeaderCnv.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef DATAHEADERCNV_H
#define DATAHEADERCNV_H

 
#include "AthenaPoolCnvSvc/T_AthenaPoolCustomCnv.h"
#include "PersistentDataModel/DataHeader.h"
#include "PersistentDataModelTPCnv/DataHeader_p6.h"
#include "PersistentDataModelTPCnv/DataHeaderCnv_p5.h"
#include "PersistentDataModelTPCnv/DataHeaderCnv_p6.h"
 
#include "GaudiKernel/IIncidentListener.h"
#include "GaudiKernel/ServiceHandle.h"
#include "PoolSvc/IPoolSvc.h"
 
#include <map>
 
class  DataHeader_p5;
class  DataHeaderForm_p6;

typedef  T_AthenaPoolCustomCnv<DataHeader, DataHeader_p6> DataHeaderCnvBase;
class DataHeaderCnv : public DataHeaderCnvBase, virtual public IIncidentListener
{
   friend class CnvFactory<DataHeaderCnv>;
public:
   DataHeaderCnv(ISvcLocator* svcloc);
   ~DataHeaderCnv();
   virtual StatusCode initialize() override;

   virtual StatusCode updateRep(IOpaqueAddress* pAddress, DataObject* pObject) override;
 
   virtual StatusCode updateRepRefs(IOpaqueAddress* pAddress, DataObject* pObject) override;
 
   virtual StatusCode DataObjectToPool(IOpaqueAddress* pAddr, DataObject* pObj) override;
 
   std::unique_ptr<DataHeader_p5> poolReadObject_p5(const Token* token);
   std::unique_ptr<DataHeader_p6> poolReadObject_p6(const Token* token);
 
   DataHeader_p6* createPersistent(DataHeader* transObj, DataHeaderForm_p6*) ;
   virtual DataHeader* createTransient(const Token* token) override;
 
   [[deprecated("this converter uses createPersistent() with 2 arguments")]]
   virtual DataHeader_p6* createPersistent(DataHeader*) override { return nullptr; }

   virtual void handle(const Incident& incident) override;

   void clearInputDHFormCache( const std::string& dbGuid );

   void         removeBadElements(DataHeader* dh);
  
protected:
   DataHeaderCnv_p6     m_tpOutConverter;
   DataHeaderCnv_p6     m_tpInConverter;
  
   RootType             m_dhFormType;
   bool                 m_oneDHForm = true;
   struct placementComp{ bool operator() (const std::string& lhs, const std::string& rhs) const; };
   std::map<std::string,  std::unique_ptr<DataHeaderForm_p6>, placementComp >  m_persFormMap;
   std::map<std::string,  std::unique_ptr<DataHeaderForm_p6> >  m_inputDHForms;

   std::map<std::string,  unsigned>                             m_inDHFormCount;
   unsigned                                                     m_inDHFMapMaxsize{};
 
   std::map< std::string, std::string>  m_lastGoodDHFRef;

   DataHeaderCnv_p5                     m_tpInConverter_p5;  
   std::unique_ptr<DataHeaderForm_p5>   m_dhInForm5;
   std::string                          m_dhFormMdx;

   DataHeader_p6*                       m_sharedWriterCachedDH = nullptr;  // no ownership
   std::map< std::string, std::unique_ptr<DataHeaderForm_p6> >  m_sharedWriterCachedDHForm;
   std::string                          m_sharedWriterCachedDHKey;
   std::string                          m_sharedWriterCachedDHToken;
   ServiceHandle<IPoolSvc>              m_poolSvc{"PoolSvc", "DataHeaderCnv"};
};
 
#endif