T_AthenaPoolCustomCnv.h

Go to the documentation of this file.

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

 
#include "GaudiKernel/ThreadLocalContext.h"
#include "GaudiKernel/EventContext.h"
#include "T_AthenaPoolCustCnv.h"
 
#include <vector>
 
// class TopLevelTPCnvBase;
// need the TopLevelTPCnvBase typedef still
#include "AthenaPoolTopLevelTPCnvBase.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 std::string& key) = 0;

   template <class P>
   P* poolReadObject();

   template <class P>
   void poolReadObject(TopLevelTPCnvBase& tlp_converter);

   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 DataObjectToPers(DataObject* pObj, IOpaqueAddress*& pAddr) override;

   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;

   std::map<std::string, std::vector< std::unique_ptr<PERS> > > 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() = 0;
  virtual TRANS* createTransientWithKey(const std::string& /*key*/) override;
};
 
#include "AthenaPoolCnvSvc/T_AthenaPoolCustomCnv.icc"
 
#endif