T_AthenaPoolCustomCnv.h

Go to the documentation of this file.

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

 
#include "AthenaKernel/SlotSpecificObj.h"
 
#include "T_AthenaPoolCustCnv.h"
 
#include <unordered_map>
#include <vector>
 
// class TopLevelTPCnvBase;
// need the TopLevelTPCnvBase typedef still
#include "TPTools/TopLevelTPCnvBase.h"
 
// forward declarations:
template <class T, class P> class T_AthenaPoolExtendingCnv;

template <class TRANS, class PERS>
class T_AthenaPoolCustomCnvWithKey : public T_AthenaPoolCustCnv<TRANS, PERS>
{
friend class T_AthenaPoolExtendingCnv<TRANS,PERS>;
 
public:
   typedef T_AthenaPoolCustCnv<TRANS, PERS> BaseType;

   T_AthenaPoolCustomCnvWithKey(ISvcLocator* pSvcLocator,
                                const char* name = nullptr);
 
protected:
 
   // the 2 following methods are allowed to throw std::runtime_error

   virtual PERS* createPersistentWithKey(TRANS* obj, const std::string& key) = 0;

  virtual TRANS* createTransientWithKey(const Token* token, const std::string& key) = 0;

   template <class P>
   P* poolReadObject(const Token* token);

   template <class P>
   void poolReadObject(TopLevelTPCnvBase& tlp_converter, const Token* token);

   void keepPoolObj(PERS* obj, const std::string& output);

   virtual StatusCode transToPers(TRANS*, PERS*&) override { return(StatusCode::FAILURE); }
   virtual StatusCode persToTrans(TRANS*&, PERS*) override { return(StatusCode::FAILURE); }

   virtual StatusCode DataObjectToPool(IOpaqueAddress* pAddr, DataObject* pObj) override;

   virtual StatusCode PoolToDataObject(DataObject*& pObj, const Token* token,
                                       const std::string& key) override;

   virtual StatusCode cleanUp(const std::string& output) override;

   using PersObjCache_t = std::unordered_map<std::string, std::vector<std::unique_ptr<PERS>>>;
   SG::SlotSpecificObj<PersObjCache_t, SG::InvalidSlot::Enabled> m_persObjLists;

   std::mutex  m_pListMutex;
};

template <class TRANS, class PERS>
class T_AthenaPoolCustomCnv
  : public T_AthenaPoolCustomCnvWithKey<TRANS, PERS>
{
protected:
  using T_AthenaPoolCustomCnvWithKey<TRANS, PERS>::T_AthenaPoolCustomCnvWithKey;
 
  virtual PERS* createPersistent(TRANS* obj) = 0;
  virtual PERS* createPersistentWithKey(TRANS* obj, const std::string& /*key*/) override;
 
  virtual TRANS* createTransient(const Token* token) = 0;
  virtual TRANS* createTransientWithKey(const Token* token, const std::string& /*key*/) override;
};
 
#include "AthenaPoolCnvSvc/T_AthenaPoolCustomCnv.icc"
 
#endif