This templated class extends T_AthenaPoolCustCnv to provide management of the persistent objects created by the converter and to correctly delete retrieved persistent objects. More...

#include <T_AthenaPoolCustomCnv.h>

Inherits T_AthenaPoolCustCnv< TRANS, PERS >.

Collaboration diagram for T_AthenaPoolCustomCnvWithKey< TRANS, PERS >:

Public Types
typedef T_AthenaPoolCustCnv< TRANS, PERS >	BaseType

Public Member Functions
	T_AthenaPoolCustomCnvWithKey (ISvcLocator pSvcLocator, const char name=nullptr)
	Constructor.
virtual StatusCode	finalize () override
virtual long	repSvcType () const override
virtual StatusCode	createObj (IOpaqueAddress pAddr, DataObject &pObj) override
	Create a transient object from a POOL persistent representation.
virtual StatusCode	createRep (DataObject pObj, IOpaqueAddress &pAddr) override
	Create a POOL persistent representation for a transient object.
virtual StatusCode	fillRepRefs (IOpaqueAddress pAddr, DataObject pObj) override
	Create a POOL persistent representation for a transient object.
const ServiceHandle< StoreGateSvc > &	detStore () const
	Handle to DetectorStore.
bool	msgLvl (const MSG::Level lvl) const
	Test the output level.
MsgStream &	msg () const
	The standard message stream.
MsgStream &	msg (const MSG::Level lvl) const
	The standard message stream.
void	setLevel (MSG::Level lvl)
	Change the current logging level.

Static Public Member Functions
static CLID	classID ()
static long	storageType ()

Protected Types
using	PersObjCache_t = std::unordered_map<std::string, std::vector<std::unique_ptr<PERS>>>
	Local cache for persistent objects created by this converter, grouped by processing slot These objects are deleted after a commit.
typedef std::mutex	CallMutex

Protected Member Functions
virtual PERS *	createPersistentWithKey (TRANS *obj, const std::string &key)=0
	method to be implemented by the developer.
virtual TRANS *	createTransientWithKey (const Token *token, const std::string &key)=0
	method to be implemented by the developer.
template<class P>
P *	poolReadObject (const Token *token)
	Read object of type P.
template<class P>
void	poolReadObject (TopLevelTPCnvBase &tlp_converter, const Token *token)
	Read object of type P (plus all extending objects) using the indicated top-level TP converter.
void	keepPoolObj (PERS *obj, const std::string &output)
	Remember the POOL object to be written out (will be deleted after commit).
virtual StatusCode	transToPers (TRANS , PERS &) override
	Obsolete methods replaced by createPersistent() and createTransient() obsolete.
virtual StatusCode	persToTrans (TRANS &, PERS ) override
	obsolete
virtual StatusCode	DataObjectToPool (IOpaqueAddress pAddr, DataObject pObj) override
	Write an object into POOL.
virtual StatusCode	PoolToDataObject (DataObject &pObj, const Token token, const std::string &key) override
	Read an object from POOL.
virtual StatusCode	cleanUp (const std::string &output) override
	Callback from the CleanupSvc to delete persistent object in the local list.
virtual StatusCode	initialize ()
	Gaudi Service Interface method implementations:
template<class P>
Placement	setPlacementForP (P &p, const std::string &key, const std::string &output)
	Set POOL placement for type P.
template<class P>
StatusCode	objectToPool (P *pObj, std::unique_ptr< Token > &token, const std::string &key, const std::string &output)
	Write an object into POOL returning its token.
template<class P>
StatusCode	poolToObject (const Token token, P &pObj)
	Read an object from POOL.
virtual bool	compareClassGuid (const Token *token, const Guid &clid) const
	Compare POOL class GUID with the one of the object being read.
virtual Placement	setPlacement (const std::string &key, const std::string &output)
	Set POOL placement.
virtual Placement	setPlacementWithType (const std::string &tname, const std::string &key, const std::string &output)
	Set POOL placement hint for a given type.

Protected Attributes
SG::SlotSpecificObj< PersObjCache_t, SG::InvalidSlot::Enabled >	m_persObjLists
std::mutex	m_pListMutex
	protection mutex for m_persObjLists
RootType	m_classDesc
ServiceHandle< StoreGateSvc >	m_detStore
ServiceHandle< IAthenaPoolCnvSvc >	m_athenaPoolCnvSvc
CallMutex	m_conv_mut

Private Types
typedef std::map< std::string, RootType >	ClassMap

Private Member Functions
void	initMessaging () const
	Initialize our message level and MessageSvc.

Private Attributes
std::string	m_className
ClassMap	m_classDescs
std::string	m_nm
	Message source name.
boost::thread_specific_ptr< MsgStream >	m_msg_tls
	MsgStream instance (a std::cout like with print-out levels).
std::atomic< IMessageSvc * >	m_imsg { nullptr }
	MessageSvc pointer.
std::atomic< MSG::Level >	m_lvl { MSG::NIL }
	Current logging level.
std::atomic_flag m_initialized	ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT
	Messaging initialized (initMessaging).

Friends
class	T_AthenaPoolExtendingCnv< TRANS, PERS >
	need the extending converter class as friend, so clones can access the original converter methods

Detailed Description

template<class TRANS, class PERS>
class T_AthenaPoolCustomCnvWithKey< TRANS, PERS >

This templated class extends T_AthenaPoolCustCnv to provide management of the persistent objects created by the converter and to correctly delete retrieved persistent objects.

Definition at line 35 of file T_AthenaPoolCustomCnv.h.

Member Typedef Documentation

◆ BaseType

template<class TRANS, class PERS>

typedef T_AthenaPoolCustCnv<TRANS, PERS> T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::BaseType

Definition at line 42 of file T_AthenaPoolCustomCnv.h.

◆ CallMutex

typedef std::mutex AthenaPoolConverter::CallMutex

protectedinherited

Definition at line 110 of file AthenaPoolConverter.h.

◆ ClassMap

template<class TRANS, class PERS>

typedef std::map<std::string, RootType> T_AthenaPoolCustCnv< TRANS, PERS >::ClassMap

privateinherited

Definition at line 86 of file T_AthenaPoolCustCnv.h.

◆ PersObjCache_t

template<class TRANS, class PERS>

using T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::PersObjCache_t = std::unordered_map<std::string, std::vector<std::unique_ptr<PERS>>>

protected

Local cache for persistent objects created by this converter, grouped by processing slot These objects are deleted after a commit.

Definition at line 116 of file T_AthenaPoolCustomCnv.h.

Constructor & Destructor Documentation

◆ T_AthenaPoolCustomCnvWithKey()

template<class TRANS, class PERS>

T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::T_AthenaPoolCustomCnvWithKey	(	ISvcLocator *	pSvcLocator,
		const char *	name = nullptr )

Constructor.

Parameters

svcloc	[IN] Gaudi service locator
name	[IN] Optional name, for error reporting.

Member Function Documentation

◆ classID()

template<class TRANS, class PERS>

CLID T_AthenaPoolCustCnv< TRANS, PERS >::classID ( )

staticinherited

Returns: class ID.

◆ cleanUp()

template<class TRANS, class PERS>

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::cleanUp ( const std::string & output )

overrideprotectedvirtual

Callback from the CleanupSvc to delete persistent object in the local list.

Reimplemented from AthenaPoolConverter.

◆ compareClassGuid()

template<class TRANS, class PERS>

virtual bool T_AthenaPoolCustCnv< TRANS, PERS >::compareClassGuid	(	const Token *	token,
		const Guid &	clid ) const

protectedvirtualinherited

Compare POOL class GUID with the one of the object being read.

Parameters

clid	[IN] GUID to compare

Returns: true if the type of the object about to be read matches the GUID

◆ createObj()

StatusCode AthenaPoolConverter::createObj	(	IOpaqueAddress *	pAddr,
		DataObject *&	pObj )

overridevirtualinherited

Create a transient object from a POOL persistent representation.

Parameters

pAddr	[IN] IOpaqueAddress of POOL persistent representation.
pObj	[OUT] pointer to the transient object.

Definition at line 52 of file AthenaPoolConverter.cxx.

                                                                                  {
   TokenAddress* tokAddr = dynamic_cast<TokenAddress*>(pAddr);
   
   bool ownTokAddr = false;
   if (tokAddr == nullptr || tokAddr->getToken() == nullptr) {
      ownTokAddr = true;
      auto token = std::make_unique<Token>();
      token->fromString(*(pAddr->par()));
      GenericAddress* genAddr = dynamic_cast<GenericAddress*>(pAddr);
      if (not genAddr){
        ATH_MSG_ERROR("Dynamic cast failed in AthenaPoolConverter::createObj");
        //clean up
        return StatusCode::FAILURE;
      }
      tokAddr = new TokenAddress(*genAddr, std::move(token));
   }
   if( tokAddr->ipar()[0] > 0 and tokAddr->getToken()->auxString().empty() ) {
      tokAddr->getToken()->setAuxString(CxxUtils::HexString<"[CTXT={}]">(static_cast<int>(*(pAddr->ipar()))));
   }
   ATH_MSG_VERBOSE("createObj: " << tokAddr->getToken()->toString() << ", CTX=" << tokAddr->ipar()[0]
                   << ", auxStr=" << tokAddr->getToken()->auxString() );
   try {
      std::string key = pAddr->par()[1];
      if (!PoolToDataObject(pObj, tokAddr->getToken(), key).isSuccess()) {
         ATH_MSG_ERROR("createObj PoolToDataObject() failed, Token = " << (tokAddr->getToken() ? tokAddr->getToken()->toString() : "NULL"));
         pObj = nullptr;
      }
   } catch (std::exception& e) {
      ATH_MSG_ERROR("createObj - caught exception: " << e.what());
      pObj = nullptr;
   }
   if (pObj == nullptr) {
      ATH_MSG_ERROR("createObj failed to get DataObject, Token = " << (tokAddr->getToken() ? tokAddr->getToken()->toString() : "NULL"));
   }
   if (ownTokAddr) {
      delete tokAddr; tokAddr = nullptr;
   }
   if (pObj == nullptr) {
      return StatusCode::FAILURE;
   }
   return StatusCode::SUCCESS;
}

◆ createPersistentWithKey()

template<class TRANS, class PERS>

virtual PERS * T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::createPersistentWithKey	(	TRANS *	obj,
		const std::string &	key )

protectedpure virtual

method to be implemented by the developer.

It should create the persistent representation of the object, using the default top-level TP converter.

Parameters

obj	[IN] transient object

Returns: the created persistent representation (by pointer)

◆ createRep()

StatusCode AthenaPoolConverter::createRep	(	DataObject *	pObj,
		IOpaqueAddress *&	pAddr )

overridevirtualinherited

Create a POOL persistent representation for a transient object.

Parameters

pObj	[IN] pointer to the transient object.
pAddr	[OUT] IOpaqueAddress of POOL persistent representation.

Definition at line 95 of file AthenaPoolConverter.cxx.

                                                                                  {
   const SG::DataProxy* proxy = dynamic_cast<SG::DataProxy*>(pObj->registry());
   if (proxy == nullptr) {
      ATH_MSG_ERROR("AthenaPoolConverter CreateRep failed to cast DataProxy, key = " << pObj->name());
      return StatusCode::FAILURE;
   }
   const CLID clid = proxy->clID();
   if (pAddr == nullptr) {
      // Create a IOpaqueAddress for this object.
      pAddr = new TokenAddress(this->storageType(), clid, "", "", 0, 0);
   } else {
      GenericAddress* gAddr = dynamic_cast<GenericAddress*>(pAddr);
      if (gAddr != nullptr) {
         gAddr->setSvcType(this->storageType());
      }
   }
   return StatusCode::SUCCESS;
}

◆ createTransientWithKey()

template<class TRANS, class PERS>

virtual TRANS * T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::createTransientWithKey	(	const Token *	token,
		const std::string &	key )

protectedpure virtual

method to be implemented by the developer.

It has to find out the type of the persistent object to be read (by comparing GUIDs), read it using poolReadObject<P>(), call TLP converter to create a transient representation and return it. if the version 1 of poolReadObject is used, the persistent object HAS TO BE DELETED manually.

◆ DataObjectToPool()

template<class TRANS, class PERS>

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::DataObjectToPool	(	IOpaqueAddress *	pAddr,
		DataObject *	pObj )

overrideprotectedvirtual

Write an object into POOL.

Parameters

pObj	[IN] pointer to the transient object.
key	[IN] StoreGate key (string) - placement hint to generate POOL container name

Reimplemented from T_AthenaPoolCustCnv< TRANS, PERS >.

Reimplemented in DataHeaderCnv.

◆ detStore()

const ServiceHandle< StoreGateSvc > & AthenaPoolConverter::detStore ( ) const

inlineinherited

Handle to DetectorStore.

Definition at line 68 of file AthenaPoolConverter.h.

68{ return m_detStore; }

AthenaPoolConverter::m_detStore

ServiceHandle< StoreGateSvc > m_detStore

Definition AthenaPoolConverter.h:107

◆ fillRepRefs()

StatusCode AthenaPoolConverter::fillRepRefs	(	IOpaqueAddress *	pAddr,
		DataObject *	pObj )

overridevirtualinherited

Create a POOL persistent representation for a transient object.

Parameters

pAddr	[IN] IOpaqueAddress of POOL persistent representation.
pObj	[IN] pointer to the transient object.

Definition at line 114 of file AthenaPoolConverter.cxx.

                                                                                   {
   try {
      if (!DataObjectToPool(pAddr, pObj).isSuccess()) {
         ATH_MSG_ERROR("FillRepRefs failed, key = " << pObj->name());
         return StatusCode::FAILURE;
      }
   } catch (std::exception& e) {
      ATH_MSG_ERROR("fillRepRefs - caught exception: " << e.what());
      return StatusCode::FAILURE;
   }
   return StatusCode::SUCCESS;
}

◆ finalize()

StatusCode AthenaPoolConverter::finalize ( )

overridevirtualinherited

Definition at line 40 of file AthenaPoolConverter.cxx.

                                         {
   // Release AthenaPoolCnvSvc
   if (!m_athenaPoolCnvSvc.release().isSuccess()) {
      ATH_MSG_WARNING("Cannot release AthenaPoolCnvSvc.");
   }
   return(::Converter::finalize());
}

◆ initialize()

template<class TRANS, class PERS>

virtual StatusCode T_AthenaPoolCustCnv< TRANS, PERS >::initialize ( )

protectedvirtualinherited

Gaudi Service Interface method implementations:

Reimplemented from T_AthenaPoolCnvBase< TRANS >.

Reimplemented in AlignableTransformContainerCnv, CaloTTOnAttrIdMapCnv, CaloTTOnOffIdMapCnv, CaloTTPpmRxIdMapCnv, CscPrepDataContainerCnv, CscRawDataContainerCnv, CscStripPrepDataContainerCnv, DataHeaderCnv, InDetTrackCnv, LArDigitContainerCnv, LArLATOMEHeaderContainerCnv, LArTTCellMapCnv, LayerMaterialMapCnv, MdtPrepDataContainerCnv, MM_RawDataContainerCnv, MMPrepDataContainerCnv, MuonCaloEnergiesCnv, MuonRdoContainerCnv< T >, MuonRdoContainerTPCnv< T, P, CONV >, MuonRdoContainerTPCnv< CscRawDataContainer, CscRawDataContainer_p4, CscRawDataContainerCnv_p4 >, MuonRdoContainerTPCnv< MdtCsmContainer, MdtCsmContainer_p1, MdtCsmContainerCnv_p1 >, MuonRdoContainerTPCnv< RpcPadContainer, RpcPadContainer_p2, RpcPadContainerCnv_p2 >, MuonRdoContainerTPCnv< TgcL1RdoContainer, TgcL1RdoContainer_p1, TgcL1RdoContainerCnv_p1 >, MuonRdoContainerTPCnv< TgcRdoContainer, TgcRdoContainer_p4, TgcRdoContainerCnv_p4 >, MVFVxContainerCnv, PhaseIIPixelRawDataContainerCnv, PhaseIIStripRawDataContainerCnv, PixelClusterContainerCnv, PixelRDO_ContainerCnv, RpcCoinDataContainerCnv, RpcPrepDataContainerCnv, SCT_ClusterContainerCnv, SCT_RDO_ContainerCnv, STGC_RawDataContainerCnv, sTgcPrepDataContainerCnv, T_AthenaPoolViewVectorCnv< DV >, TgcCoinDataContainerCnv, TgcPrepDataContainerCnv, TileCellContainerCnv, TrackCollectionCnv, TrackParticleContainerCnv, TRT_DriftCircleContainerCnv, TRT_RDO_ContainerCnv, V0ContainerCnv, VxContainerCnv, xAODSpacePointAuxContainerCnv, xAODTrackParticleAuxContainerCnv, and xAODTrackStateAuxContainerCnv.

◆ initMessaging()

void AthMessaging::initMessaging ( ) const

privateinherited

Initialize our message level and MessageSvc.

This method should only be called once.

Definition at line 39 of file AthMessaging.cxx.

{
  m_imsg = Athena::getMessageSvc();
  // If user did not set an explicit level, set a default
  if (m_lvl == MSG::NIL) {
    m_lvl = m_imsg ?
      static_cast<MSG::Level>( m_imsg.load()->outputLevel(m_nm) ) :
      MSG::INFO;
  }
}

◆ keepPoolObj()

template<class TRANS, class PERS>

void T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::keepPoolObj	(	PERS *	obj,
		const std::string &	output )

protected

Remember the POOL object to be written out (will be deleted after commit).

Parameters

obj	[IN] persistent object

◆ msg() [1/2]

MsgStream & AthMessaging::msg ( ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 167 of file AthMessaging.h.

{
  MsgStream* ms = m_msg_tls.get();
  if (!ms) {
    if (!m_initialized.test_and_set()) initMessaging();
    ms = new MsgStream(m_imsg,m_nm);
    m_msg_tls.reset( ms );
  }
 
  ms->setLevel (m_lvl);
  return *ms;
}

◆ msg() [2/2]

MsgStream & AthMessaging::msg ( const MSG::Level lvl ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 182 of file AthMessaging.h.

183{ return msg() << lvl; }

AthMessaging::msg

MsgStream & msg() const

The standard message stream.

Definition AthMessaging.h:167

◆ msgLvl()

bool AthMessaging::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Test the output level.

Parameters

lvl	The message level to test against

Returns: boolean Indicating if messages at given level will be printed

Return values

true	Messages at level "lvl" will be printed

Definition at line 151 of file AthMessaging.h.

{
  // If user did not set explicit message level we have to initialize
  // the messaging and retrieve the default via the MessageSvc.
  if (m_lvl==MSG::NIL && !m_initialized.test_and_set()) initMessaging();
 
  if (m_lvl <= lvl) {
    msg() << lvl;
    return true;
  } else {
    return false;
  }
}

◆ objectToPool()

template<class TRANS, class PERS>

template<class P>

StatusCode T_AthenaPoolCustCnv< TRANS, PERS >::objectToPool	(	P *	pObj,
		std::unique_ptr< Token > &	token,
		const std::string &	key,
		const std::string &	output )

protectedinherited

Write an object into POOL returning its token.

Parameters

pObj	[IN] pointer to the object to be written.
token	[OUT] POOL token of the persistent representation.
key	[IN] StoreGate key (string) - placement hint to generate POOL container name

◆ persToTrans()

template<class TRANS, class PERS>

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::persToTrans	(	TRANS *&	,
		PERS *	)

inlineoverrideprotectedvirtual

obsolete

Implements T_AthenaPoolCustCnv< TRANS, PERS >.

Definition at line 97 of file T_AthenaPoolCustomCnv.h.

97{ return(StatusCode::FAILURE); }

T_AthenaPoolCustomCnvWithKey

This templated class extends T_AthenaPoolCustCnv to provide management of the persistent objects crea...

Definition T_AthenaPoolCustomCnv.h:36

◆ poolReadObject() [1/2]

template<class TRANS, class PERS>

template<class P>

P * T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::poolReadObject ( const Token * token )

protected

Read object of type P.

This is an exception-throwing version of poolToObject() plus reading of all extending objects. Version 1 - (see createTransient() above)

Returns: object read from POOL (by pointer)

◆ poolReadObject() [2/2]

template<class TRANS, class PERS>

template<class P>

void T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::poolReadObject	(	TopLevelTPCnvBase &	tlp_converter,
		const Token *	token )

protected

Read object of type P (plus all extending objects) using the indicated top-level TP converter.

Version 2 - (see createTransient() above) NOTE: the TLP converter will delete the persistent object after createTransient()

Parameters

tlp_converter [IN] top-level TP converter to be used when reading

◆ PoolToDataObject()

template<class TRANS, class PERS>

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::PoolToDataObject	(	DataObject *&	pObj,
		const Token *	token,
		const std::string &	key )

overrideprotectedvirtual

Read an object from POOL.

Parameters

pObj	[OUT] pointer to the transient object.
token	[IN] POOL token of the persistent representation.
key	[IN] SG key of the object being read.

Reimplemented from T_AthenaPoolCustCnv< TRANS, PERS >.

◆ poolToObject()

template<class TRANS, class PERS>

template<class P>

StatusCode T_AthenaPoolCustCnv< TRANS, PERS >::poolToObject	(	const Token *	token,
		P *&	pObj )

protectedinherited

Read an object from POOL.

Parameters

token	[IN] POOL token of the persistent representation.
pObj	[OUT] pointer to the object read.

◆ repSvcType()

long AthenaPoolConverter::repSvcType ( ) const

overridevirtualinherited

Definition at line 48 of file AthenaPoolConverter.cxx.

                                           {
   return pool::POOL_StorageType.type();
}

◆ setLevel()

void AthMessaging::setLevel ( MSG::Level lvl )

inherited

Change the current logging level.

Use this rather than msg().setLevel() for proper operation with MT.

Definition at line 28 of file AthMessaging.cxx.

{
  m_lvl = lvl;
}

◆ setPlacement()

virtual Placement T_AthenaPoolCnvBase< TRANS >::setPlacement	(	const std::string &	key,
		const std::string &	output )

protectedvirtualinherited

Set POOL placement.

Implements AthenaPoolConverter.

◆ setPlacementForP()

template<class TRANS, class PERS>

template<class P>

Placement T_AthenaPoolCustCnv< TRANS, PERS >::setPlacementForP	(	P &	p,
		const std::string &	key,
		const std::string &	output )

protectedinherited

Set POOL placement for type P.

◆ setPlacementWithType()

Placement AthenaPoolConverter::setPlacementWithType	(	const std::string &	tname,
		const std::string &	key,
		const std::string &	output )

protectedvirtualinherited

Set POOL placement hint for a given type.

Parameters

tname	[IN] type name.
key	[IN] SG key.

Definition at line 140 of file AthenaPoolConverter.cxx.

                                                                                                                         {
   // Resulting placement
   Placement placement;
 
   // Extract the file name and global technology (if available)
   std::string::size_type pos1 = output.find('[');
   std::string outputConnectionSpec = output.substr(0, pos1);
   placement.setFileName(outputConnectionSpec);
 
   // Override streaming parameters from StreamTool if requested.
   std::string containerPrefix{APRDefaults::WriteConfig::getEventDataName()};
   std::string dhContainerPrefix{APRDefaults::WriteConfig::getDataHeaderName()};
   std::string containerName{""};
   std::string containerNameHint{""};
   std::string branchNameHint{""};
   std::string containerFriendPostfix{""};
   while (pos1 != std::string::npos) {
      const std::string::size_type pos2 = output.find('=', pos1);
      const std::string thisKey = output.substr(pos1 + 1, pos2 - pos1 - 1);
      const std::string::size_type pos3 = output.find(']', pos2);
      const std::string value = output.substr(pos2 + 1, pos3 - pos2 - 1);
      if (thisKey == "OutputCollection") {
         dhContainerPrefix = std::move(value);
      } else if (thisKey == "PoolContainerPrefix") {
         containerPrefix = std::move(value);
      } else if (thisKey == "TopLevelContainerName") {
        containerNameHint = std::move(value);
      } else if (thisKey == "SubLevelBranchName") {
         branchNameHint = std::move(value);
      } else if (thisKey == "PoolContainerFriendPostfix") {
         containerFriendPostfix = std::move(value);
      }
      pos1 = output.find('[', pos3);
   }
 
   // Extract the technology from the container prefix (if available)
   if (auto colonPost = containerPrefix.find(':'); colonPost != std::string::npos) {
      placement.setTechnology(pool::DbType::getType(containerPrefix.substr(0, colonPost)).type());
      containerPrefix.erase(0, colonPost + 1); // Note that DataHeader and EventTag bypass this...
   }
 
   // ---  Special types:   DataHeader & Form
   if ( tname.starts_with(APRDefaults::DataHeaderTypeName) ) {
      containerName = std::format("{}{}({}{})",
         dhContainerPrefix,
         tname.starts_with(APRDefaults::DataHeaderFormTypeName) ? "Form" : "",
         key.back() == '/' ? key : "",
         tname);
   }
   // AttributeList - writing attributes separately to EventTag container group
   else if ( tname.starts_with(APRDefaults::EventTagTypeName) ) {
      containerName = std::format("{}({})",
         APRDefaults::WriteConfig::getEventTagName(),
         key);
   }
   // all other object types
   else {
      constexpr std::string_view typeTok = "<type>", keyTok = "<key>";
      containerName = std::format("{}{}{}{}",
                           containerPrefix,
                           containerFriendPostfix,
                           containerNameHint,
                           branchNameHint.empty() ? "" : std::format("({})", branchNameHint));
      if (auto pos = containerName.find(typeTok); pos != std::string::npos) {
         containerName.replace(pos, typeTok.size(), tname);
      }
      if (auto pos = containerName.find(keyTok); pos != std::string::npos) {
         containerName.replace(pos, keyTok.size(), key.empty() ? tname : key);
      }
   }
 
   // Set the container name
   placement.setContainerName(containerName);
   return(placement);
}

◆ storageType()

long AthenaPoolConverter::storageType ( )

staticinherited

Returns: storage type.

Definition at line 127 of file AthenaPoolConverter.cxx.

                                      {
   return pool::POOL_StorageType.type();
}

◆ transToPers()

template<class TRANS, class PERS>

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::transToPers	(	TRANS *	,
		PERS *&	)

inlineoverrideprotectedvirtual

Obsolete methods replaced by createPersistent() and createTransient() obsolete.

Implements T_AthenaPoolCustCnv< TRANS, PERS >.

Definition at line 95 of file T_AthenaPoolCustomCnv.h.

95{ return(StatusCode::FAILURE); }

◆ T_AthenaPoolExtendingCnv< TRANS, PERS >

template<class TRANS, class PERS>

friend class T_AthenaPoolExtendingCnv< TRANS, PERS >

friend

need the extending converter class as friend, so clones can access the original converter methods

Definition at line 1 of file T_AthenaPoolCustomCnv.h.

Member Data Documentation

◆ ATLAS_THREAD_SAFE

std::atomic_flag m_initialized AthMessaging::ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT

mutableprivateinherited

Messaging initialized (initMessaging).

Definition at line 141 of file AthMessaging.h.

◆ m_athenaPoolCnvSvc

ServiceHandle<IAthenaPoolCnvSvc> AthenaPoolConverter::m_athenaPoolCnvSvc

protectedinherited

Definition at line 108 of file AthenaPoolConverter.h.

◆ m_classDesc

RootType T_AthenaPoolCnvBase< TRANS >::m_classDesc

protectedinherited

Definition at line 58 of file T_AthenaPoolCnvBase.h.

◆ m_classDescs

template<class TRANS, class PERS>

ClassMap T_AthenaPoolCustCnv< TRANS, PERS >::m_classDescs

privateinherited

Definition at line 87 of file T_AthenaPoolCustCnv.h.

◆ m_className

template<class TRANS, class PERS>

std::string T_AthenaPoolCustCnv< TRANS, PERS >::m_className

privateinherited

Definition at line 84 of file T_AthenaPoolCustCnv.h.

◆ m_conv_mut

CallMutex AthenaPoolConverter::m_conv_mut

protectedinherited

Definition at line 111 of file AthenaPoolConverter.h.

◆ m_detStore

ServiceHandle<StoreGateSvc> AthenaPoolConverter::m_detStore

protectedinherited

Definition at line 107 of file AthenaPoolConverter.h.

◆ m_imsg

std::atomic<IMessageSvc*> AthMessaging::m_imsg { nullptr }

mutableprivateinherited

MessageSvc pointer.

Definition at line 135 of file AthMessaging.h.

135{ nullptr };

◆ m_lvl

std::atomic<MSG::Level> AthMessaging::m_lvl { MSG::NIL }

mutableprivateinherited

Current logging level.

Definition at line 138 of file AthMessaging.h.

138{ MSG::NIL };

◆ m_msg_tls

boost::thread_specific_ptr<MsgStream> AthMessaging::m_msg_tls

mutableprivateinherited

MsgStream instance (a std::cout like with print-out levels).

Definition at line 132 of file AthMessaging.h.

◆ m_nm

std::string AthMessaging::m_nm

privateinherited

Message source name.

Definition at line 129 of file AthMessaging.h.

◆ m_persObjLists

template<class TRANS, class PERS>

SG::SlotSpecificObj<PersObjCache_t, SG::InvalidSlot::Enabled> T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::m_persObjLists

protected

Definition at line 117 of file T_AthenaPoolCustomCnv.h.

◆ m_pListMutex

template<class TRANS, class PERS>

std::mutex T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::m_pListMutex

protected

protection mutex for m_persObjLists

Definition at line 120 of file T_AthenaPoolCustomCnv.h.

The documentation for this class was generated from the following file:

T_AthenaPoolCustomCnv.h

Public Types

Public Member Functions

Static Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ BaseType

◆ CallMutex

◆ ClassMap

◆ PersObjCache_t

Constructor & Destructor Documentation

◆ T_AthenaPoolCustomCnvWithKey()

Member Function Documentation

◆ classID()

◆ cleanUp()

◆ compareClassGuid()

◆ createObj()

◆ createPersistentWithKey()

◆ createRep()

◆ createTransientWithKey()

◆ DataObjectToPool()

◆ detStore()

◆ fillRepRefs()

◆ finalize()

◆ initialize()

◆ initMessaging()

◆ keepPoolObj()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ objectToPool()

◆ persToTrans()

◆ poolReadObject() [1/2]

◆ poolReadObject() [2/2]

◆ PoolToDataObject()

◆ poolToObject()

◆ repSvcType()

◆ setLevel()

◆ setPlacement()

◆ setPlacementForP()

◆ setPlacementWithType()

◆ storageType()

◆ transToPers()

Friends And Related Symbol Documentation

◆ T_AthenaPoolExtendingCnv< TRANS, PERS >

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_athenaPoolCnvSvc

◆ m_classDesc

◆ m_classDescs

◆ m_className

◆ m_conv_mut

◆ m_detStore

◆ m_imsg

◆ m_lvl

◆ m_msg_tls

◆ m_nm

◆ m_persObjLists

◆ m_pListMutex