Compatibility for old converter classes that don't get passed the key. More...

#include <T_AthenaPoolCustomCnv.h>

Inherits T_AthenaPoolCustomCnvWithKey< TRANS, PERS >.

Inherited by LArRawEventContainerCnv< LArRawChannelContainer, LArRawChannelContainer_p4, LArRawChannelContainerCnv_p4 >, 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 >, T_AthenaPoolExtendingCnv< InDetTrack, InDetTrack_PERS >, T_AthenaPoolExtendingCnv< TPCnv::MuonMeasurements, MuonMeasurements_PERS >, T_AthenaPoolExtendingCnv< JetTagInfo, Analysis::JetTagInfo_tlp3 >, T_AthenaPoolExtendingCnv< TPCnv::MuonCaloEnergies, MuonCaloEnergies_PERS >, T_AthenaPoolExtendingCnv< MVFVxContainer, MVFVxContainer_PERS >, T_AthenaPoolExtendingCnv< TRANS, PERS >, and T_AthenaPoolLegacyCnv< TRANS, PERS, LEGACY >.

Collaboration diagram for T_AthenaPoolCustomCnv< TRANS, PERS >:

Public Types
typedef T_AthenaPoolCustCnv< TRANS, PERS >	BaseType

Public Member Functions
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.
void	addTrack (TIDA::Track *t)
const std::vector< TIDA::Track * > &	tracks () const
void	clear ()
void	selectTracks (const TrigInDetTrackCollection *trigtracks)
void	selectTracks (const Rec::TrackParticleContainer *trigtracks)
void	selectTracks (const Analysis::MuonContainer *muontracks)
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 const CLID &	classID ()
static long	storageType ()

Protected Types
typedef std::map< std::string, RootType >	ClassMap
typedef ClassMap::const_iterator	ClassMapIt
typedef std::mutex	CallMutex

Protected Member Functions
virtual PERS *	createPersistent (TRANS *obj)=0
virtual PERS *	createPersistentWithKey (TRANS *obj, const std::string &) override
	method to be implemented by the developer.
virtual TRANS *	createTransient ()=0
virtual TRANS *	createTransientWithKey (const std::string &) override
	method to be implemented by the developer.
template<class P>
P *	poolReadObject ()
	Read object of type P.
template<class P>
void	poolReadObject (TopLevelTPCnvBase &tlp_converter)
	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	DataObjectToPers (DataObject pObj, IOpaqueAddress &pAddr) override
	Convert an object into Persistent.
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 Guid &clid) const
	Compare POOL class GUID with the one of the object being read.
virtual void	setToken (const std::string &token)
	Set the token (in std::string representation) and classID for the object that will be read next.
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.
virtual const DataObject *	getDataObject () const
double	phiCorr (double phi)
void	ipCorr (double d0, double z0, double &d0c, double &z0c, double phi0, double eta, double pt)

Protected Attributes
std::map< std::string, std::vector< std::unique_ptr< PERS > > >	m_persObjLists
	Local cache for persistent objects created by this converter, grouped by processing slot These objects are deleted after a commit.
std::mutex	m_pListMutex
	protection mutex for m_persObjLists
Guid	m_classID
ServiceHandle< StoreGateSvc >	m_detStore
ServiceHandle< IAthenaPoolCnvSvc >	m_athenaPoolCnvSvc
RootType	m_classDesc
std::string	m_className
ClassMap	m_classDescs
std::string	m_containerPrefix
std::string	m_containerNameHint
std::string	m_branchNameHint
const DataObject *	m_dataObject
const Token *	m_i_poolToken
CallMutex	m_conv_mut
double	m_beamX
double	m_beamY
double	m_beamZ
std::vector< TIDA::Track * >	m_tracks

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

Private Attributes
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)

Detailed Description

template<class TRANS, class PERS>
class T_AthenaPoolCustomCnv< TRANS, PERS >

Compatibility for old converter classes that don't get passed the key.

Definition at line 130 of file T_AthenaPoolCustomCnv.h.

Member Typedef Documentation

◆ BaseType

template<class TRANS, class PERS>

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

inherited

Definition at line 41 of file T_AthenaPoolCustomCnv.h.

◆ CallMutex

typedef std::mutex AthenaPoolConverter::CallMutex

protectedinherited

Definition at line 132 of file AthenaPoolConverter.h.

◆ ClassMap

typedef std::map<std::string, RootType> AthenaPoolConverter::ClassMap

protectedinherited

Definition at line 120 of file AthenaPoolConverter.h.

◆ ClassMapIt

typedef ClassMap::const_iterator AthenaPoolConverter::ClassMapIt

protectedinherited

Definition at line 121 of file AthenaPoolConverter.h.

Member Function Documentation

◆ addTrack()

void Converter::addTrack ( TIDA::Track * t )

inlineinherited

Definition at line 45 of file Converter.h.

                              {
    m_tracks.push_back(t);
  }

◆ classID()

template<class TRANS, class PERS>

const 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 )

overrideprotectedvirtualinherited

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

Reimplemented from AthenaPoolConverter.

◆ clear()

void Converter::clear ( )

inlineinherited

Definition at line 53 of file Converter.h.

53{m_tracks.clear();}

◆ compareClassGuid()

template<class TRANS, class PERS>

virtual bool T_AthenaPoolCustCnv< TRANS, PERS >::compareClassGuid ( 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 62 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() ) {
      char text[32];
      const std::string contextStr = std::format("[CTXT={:08X}]", static_cast<int>(*(pAddr->ipar())));
      std::strncpy(text, contextStr.c_str(), sizeof(text) - 1);
      text[sizeof(text) - 1] = '\0';
      tokAddr->getToken()->setAuxString(text);
   }
   ATH_MSG_VERBOSE("createObj: " << tokAddr->getToken()->toString() << ", CTX=" << tokAddr->ipar()[0]
                   << ", auxStr=" << tokAddr->getToken()->auxString() );
   std::lock_guard<CallMutex> lock(m_conv_mut);
   m_i_poolToken = tokAddr->getToken();
   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;
   }
   m_i_poolToken = nullptr;
   if (pObj == nullptr) {
      return StatusCode::FAILURE;
   }
   return StatusCode::SUCCESS;
}

◆ createPersistent()

template<class TRANS, class PERS>

virtual PERS * T_AthenaPoolCustomCnv< TRANS, PERS >::createPersistent ( TRANS * obj )

protectedpure virtual

◆ createPersistentWithKey()

template<class TRANS, class PERS>

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

overrideprotectedvirtual

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)

Implements T_AthenaPoolCustomCnvWithKey< TRANS, PERS >.

◆ 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 112 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;
   }
   try {
      std::lock_guard<CallMutex> lock(m_conv_mut);
      if (!DataObjectToPers(pObj, pAddr).isSuccess()) {
         ATH_MSG_ERROR("CreateRep failed, key = " << pObj->name());
         return StatusCode::FAILURE;
      }
   } catch (std::exception& e) {
      ATH_MSG_ERROR("createRep - caught exception: " << e.what());
      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;
}

◆ createTransient()

template<class TRANS, class PERS>

virtual TRANS * T_AthenaPoolCustomCnv< TRANS, PERS >::createTransient ( )

protectedpure virtual

Implemented in AFP_SiDigiCollectionCnv, AFP_SIDLocRecoEvCollectionCnv, AFP_SIDSimHitCollectionCnv, AFP_TDDigiCollectionCnv, AFP_TDLocRecoEvCollectionCnv, AFP_TDSimHitCollectionCnv, ALFA_CLinkEventCnv, ALFA_DigitCollectionCnv, ALFA_GloRecEvCollectionCnv, ALFA_HitCollectionCnv, ALFA_LocRecCorrEvCollectionCnv, ALFA_LocRecCorrODEvCollectionCnv, ALFA_LocRecEvCollectionCnv, ALFA_LocRecODEvCollectionCnv, ALFA_ODDigitCollectionCnv, ALFA_ODHitCollectionCnv, ALFA_RawDataContainerCnv, ALFA_RawDataContainerCnv_charge, AthExDecayCnv, AthExElephantinoCnv, AthExFatObjectCnv, BCM_RDO_ContainerCnv, CaloCalibrationHitContainerCnv, CaloRingsContainerCnv, CaloTopoTowerContainerCnv, CaloTowerContainerCnv, ChamberT0sCnv, ClusterSplitProbabilityContainerCnv, CMMCPHitsCollectionCnv, CMMEtSumsCollectionCnv, CMMJetHitsCollectionCnv, CMMRoICnv, CMXCPHitsCollectionCnv, CMXCPTobCollectionCnv, CMXEtSumsCollectionCnv, CMXJetHitsCollectionCnv, CMXJetTobCollectionCnv, CMXRoICnv, CombinedMuonFeatureCnv, CombinedMuonFeatureContainerCnv, CPMHitsCollectionCnv, CPMRoICollectionCnv, CPMTobRoICollectionCnv, CPMTowerCollectionCnv, CscPrepDataContainerCnv, CscRawDataContainerCnv, CscSimDataCollectionCnv, CSCSimHitCollectionCnv, CscStripPrepDataContainerCnv, CTP_DecisionCnv, CTP_RDOCnv, DataHeaderCnv, DetailedTrackTruthCollectionCnv, eflowObjectContainerCnv, egammaContainerCnv, egDetailContainerCnv, ElectronContainerCnv, ElectronMuonTopoInfoContainerCnv, EventBookkeeperCnv, EventBookkeeperCollectionCnv, EventInfoCnv, EventShapeStoreCnv, GenericMuonSimHitCollectionCnv, HGTD_ALTIROC_RDO_ContainerCnv, HGTD_ClusterContainerCnv, HGTD_RDO_ContainerCnv, HLTResultCnv, IDCInDetBSErrContainerCnv, INav4MomAssocsCnv, INav4MomLinkContainerCnv, InDetBSErrContainerCnv, InDetLowBetaCandidateCnv, InDetLowBetaContainerCnv, InDetSimDataCollectionCnv, IParticleLinkContainerCnv, IsoMuonFeatureCnv, IsoMuonFeatureContainerCnv, JEMEtSumsCollectionCnv, JEMHitsCollectionCnv, JEMRoICollectionCnv, JEMTobRoICollectionCnv, JetCollectionCnv, JetElementCollectionCnv, LArDigitContainerCnv, LArFebErrorSummaryCnv, LArHitContainerCnv, LArHitFloatContainerCnv, LArLATOMEHeaderContainerCnv, LArNoisyROSummaryCnv, LArPedestalMCCnv, LArRawEventContainerCnv< T, P, C >, LArRawEventContainerCnv< LArRawChannelContainer, LArRawChannelContainer_p4, LArRawChannelContainerCnv_p4 >, LArTTL1ContainerCnv, LUCID_DigitContainerCnv, LUCID_RawDataContainerCnv, LUCID_SimHitCollectionCnv, LumiBlockCollectionCnv, LVL1_ROICnv, Lvl1ResultCnv, McEventCollectionCnv, MdtPrepDataContainerCnv, MDTSimHitCollectionCnv, MissingEtCaloCnv, MissingETCnv, MissingETCompositionCnv, MissingEtTruthCnv, MM_RawDataContainerCnv, MMPrepDataContainerCnv, MMSimHitCollectionCnv, MuCTPI_RDOCnv, MuCTPIL1TopoCnv, MuonCaloEnergyContainerCnv, MuonContainerCnv, MuonFeatureCnv, MuonFeatureContainerCnv, MuonFeatureDetailsCnv, MuonFeatureDetailsContainerCnv, 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 >, MuonSimDataCollectionCnv, MuonSpShowerContainerCnv, MVFVxContainerCnv, NSW_PadTriggerDataContainerCnv, NSW_TrigRawDataContainerCnv, PhotonContainerCnv, PixelClusterContainerCnv, PixelGangedClusterAmbiguitiesCnv, PixelRDO_ContainerCnv, PRD_MultiTruthCollectionCnv, RecoTimingObjCnv, RingerRingsCnv, RingerRingsContainerCnv, RODHeaderCollectionCnv, RoIBResultCnv, RpcByteStreamErrorContainerCnv, RpcCoinDataContainerCnv, RpcPrepDataContainerCnv, RpcSectorLogicContainerCnv, RPCSimHitCollectionCnv, SCT_ClusterContainerCnv, SCT_FlaggedCondDataCnv, SCT_RDO_ContainerCnv, SegmentCollectionCnv, SiHitCollectionCnv, SimulationHitCollectionCnv, SkimDecisionCnv, SkimDecisionCollectionCnv, STGC_RawDataContainerCnv, sTgcPrepDataContainerCnv, sTGCSimHitCollectionCnv, T_AthenaPoolExtendingCnv< TRANS, PERS >, T_AthenaPoolExtendingCnv< InDetTrack, InDetTrack_PERS >, T_AthenaPoolExtendingCnv< JetTagInfo, Analysis::JetTagInfo_tlp3 >, T_AthenaPoolExtendingCnv< MVFVxContainer, MVFVxContainer_PERS >, T_AthenaPoolExtendingCnv< TPCnv::MuonCaloEnergies, MuonCaloEnergies_PERS >, T_AthenaPoolExtendingCnv< TPCnv::MuonMeasurements, MuonMeasurements_PERS >, T_AthenaPoolLegacyCnv< TRANS, PERS, LEGACY >, T_AthenaPoolLegacyCnv< TRANS, PERS, LEGACY >::LegacyCnv, T_AthenaPoolViewVectorCnv< DV >, TauDetailsContainerCnv, TauJetContainerCnv, TBADCRawContCnv, TBBPCContCnv, TBEventInfoCnv, TBLArDigitContainerCnv, TBMWPCContCnv, TBPhaseCnv, TBScintillatorContCnv, TBTailCatcherCnv, TBTDCCnv, TBTDCRawContCnv, TBTrackCnv, TBTrackInfoCnv, TBTriggerPatternUnitCnv, TgcCoinDataContainerCnv, TgcPrepDataContainerCnv, TGCSimHitCollectionCnv, TileBeamElemContainerCnv, TileCellContainerCnv, TileCosmicMuonContainerCnv, TileDigitsContainerCnv, TileHitContainerCnv, TileHitVectorCnv, TileL2ContainerCnv, TileMuContainerCnv, TileMuFeatureCnv, TileMuFeatureContainerCnv, TileMuonReceiverContainerCnv, TileRawChannelContainerCnv, TileTrackMuFeatureContainerCnv, TileTTL1ContainerCnv, TrackParticleContainerCnv, TrackParticleTruthCollectionCnv, TrackParticleTruthCollectionContainerCnv, TrackRecordCollectionCnv, TrackTruthCollectionCnv, TrigCaloClusterContainerCnv, TrigCompositeCnv, TrigCompositeContainerCnv, TrigDecisionCnv, TrigEFBjetContainerCnv, TrigEFBphysContainerCnv, TrigElectronContainerCnv, TrigEMClusterCnv, TrigEMClusterContainerCnv, TriggerTowerCollectionCnv, TrigHisto1DCnv, TrigHisto1DContainerCnv, TrigHisto2DCnv, TrigHisto2DContainerCnv, TrigInDetTrackCollectionCnv, TrigInDetTrackTruthMapCnv, TrigL2BjetContainerCnv, TrigL2BphysContainerCnv, TrigMissingETCnv, TrigMissingETContainerCnv, TrigMonConfigCnv, TrigMonConfigCollectionCnv, TrigMonEventCnv, TrigMonEventCollectionCnv, TrigMuonClusterFeatureCnv, TrigMuonClusterFeatureContainerCnv, TrigMuonEFContainerCnv, TrigMuonEFInfoContainerCnv, TrigMuonEFIsolationContainerCnv, TrigOperationalInfoCnv, TrigOperationalInfoCollectionCnv, TrigPassBitsCnv, TrigPassBitsCollectionCnv, TrigPassFlagsCnv, TrigPassFlagsCollectionCnv, TrigPhotonContainerCnv, TrigRNNOutputCnv, TrigRNNOutputContainerCnv, TrigRoiDescriptorCnv, TrigRoiDescriptorCollectionCnv, TrigSpacePointCountsCnv, TrigSpacePointCountsCollectionCnv, TrigT2JetCnv, TrigT2JetContainerCnv, TrigT2MbtsBitsCnv, TrigT2MbtsBitsContainerCnv, TrigTauClusterCnv, TrigTauClusterContainerCnv, TrigTauClusterDetailsCnv, TrigTauClusterDetailsContainerCnv, TrigTauCnv, TrigTauContainerCnv, TrigTauTracksInfoCnv, TrigTauTracksInfoCollectionCnv, TrigTrackCountsCnv, TrigTrackCountsCollectionCnv, TrigTrtHitCountsCnv, TrigTrtHitCountsCollectionCnv, TrigVertexCollectionCnv, TrigVertexCountsCnv, TrigVertexCountsCollectionCnv, TRT_BSErrContainerCnv, TRT_BSIdErrContainerCnv, TRT_DriftCircleContainerCnv, TRT_RDO_ContainerCnv, TRTUncompressedHitCollectionCnv, TruthEtIsolationsContainerCnv, TruthParticleContainerCnv, V0ContainerCnv, VxContainerCnv, ZDC_SimFiberHit_CollectionCnv, ZdcDigitsCollectionCnv, and ZdcRawChannelCollectionCnv.

◆ createTransientWithKey()

template<class TRANS, class PERS>

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

overrideprotectedvirtual

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.

Implements T_AthenaPoolCustomCnvWithKey< TRANS, PERS >.

◆ DataObjectToPers()

template<class TRANS, class PERS>

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

overrideprotectedvirtualinherited

Convert an object into Persistent.

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 >.

◆ DataObjectToPool()

template<class TRANS, class PERS>

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

overrideprotectedvirtualinherited

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, and T_AthenaPoolLegacyCnv< TRANS, PERS, LEGACY >.

◆ detStore()

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

inlineinherited

Handle to DetectorStore.

Definition at line 69 of file AthenaPoolConverter.h.

69{ return m_detStore; }

AthenaPoolConverter::m_detStore

ServiceHandle< StoreGateSvc > m_detStore

Definition AthenaPoolConverter.h:116

◆ 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 141 of file AthenaPoolConverter.cxx.

                                                                                   {
   std::lock_guard<CallMutex> lock(m_conv_mut);
   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 50 of file AthenaPoolConverter.cxx.

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

◆ getDataObject()

const DataObject * AthenaPoolConverter::getDataObject ( ) const

protectedvirtualinherited

Returns: data object from the converter.

Definition at line 272 of file AthenaPoolConverter.cxx.

                                                           {
   return(m_dataObject);
}

◆ 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, JetCollectionCnv, JetTagInfoCnv, LArDigitContainerCnv, LArLATOMEHeaderContainerCnv, LArTTCellMapCnv, LayerMaterialMapCnv, MdtPrepDataContainerCnv, MM_RawDataContainerCnv, MMPrepDataContainerCnv, MuonCaloEnergiesCnv, MuonContainerCnv, 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, PixelClusterContainerCnv, PixelRDO_ContainerCnv, RpcCoinDataContainerCnv, RpcPrepDataContainerCnv, SCT_ClusterContainerCnv, SCT_RDO_ContainerCnv, STGC_RawDataContainerCnv, sTgcPrepDataContainerCnv, T_AthenaPoolViewVectorCnv< DV >, TgcCoinDataContainerCnv, TgcPrepDataContainerCnv, TileCellContainerCnv, TrackCollectionCnv, TrackParticleContainerCnv, TrigInDetTrackTruthMapCnv, 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;
  }
}

◆ ipCorr()

void Converter::ipCorr	(	double	d0,
		double	z0,
		double &	d0c,
		double &	z0c,
		double	phi0,
		double	eta,
		double	pt )

inlineprotectedinherited

Definition at line 257 of file Converter.h.

                                                                                                  {
    
    double sn  = sin(phi0);
    double cs  = cos(phi0);
    double sd0 = (d0 != 0 ? d0/fabs(d0) : 1);
    double spt = (pt != 0 ? pt/fabs(pt) : 1);
    
    if (fabs(pt) >= 1*CLHEP::TeV) {
 
      d0c = d0 + m_beamX*sn - m_beamY*cs;
 
    } else {
      
      double rc = fabs(pt)*15.0/(9.0*1.042);
      
      double xc = (fabs(d0)-spt*sd0*rc)*cos(phi0+M_PI/2*sd0) - m_beamX;
      double yc = (fabs(d0)-spt*sd0*rc)*sin(phi0+M_PI/2*sd0) - m_beamY;
      
      double newphi;
      double xd01,yd01,xd02,yd02;
      
      if (xc == 0) {
    xd01 = 0; yd01 = rc+yc;
    xd02 = 0; yd02 = -rc+yc; 
      } else {
    xd01 = xc+yc/xc*yc+sqrt(pow((xc+yc/xc*yc),2)-xc*xc-yc*yc+rc*rc); yd01 = yc/xc*xd01;
    xd02 = xc+yc/xc*yc-sqrt(pow((xc+yc/xc*yc),2)-xc*xc-yc*yc+rc*rc); yd02 = yc/xc*xd02;
      }
      
      double r1 = sqrt(xd01*xd01+yd01*yd01);
      double r2 = sqrt(xd02*xd02+yd02*yd02);
      
      double phiV;
      
      if (r1 < r2)
    phiV = atan2(yd01,xd01); 
      else
    phiV = atan2(yd02,xd02); 
      
      double phi1 = phiCorr(phiV+M_PI/2);
      double phi2 = phiCorr(phiV-M_PI/2);
      
      if (fabs(phiCorr(phi1-phi0))<=fabs(phiCorr(phi2-phi0)))
    newphi = phi1;
      else
    newphi = phi2;
      
      d0c = fabs(sqrt(xc*xc+yc*yc)-rc)*sin(phiV-newphi);
      
      double theta=2*atan2(exp(-eta),1);
      double theta_save=theta;
      theta = theta - (1+spt)/2*M_PI;
      if (theta>0) theta = theta_save;
      
      double deltaz0= -spt*rc/tan(theta)*phiCorr(phiCorr(newphi)-phiCorr(phi0));
      z0c = z0 + deltaz0;
      
    }
  }

◆ keepPoolObj()

template<class TRANS, class PERS>

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

protectedinherited

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 163 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 178 of file AthMessaging.h.

179{ return msg() << lvl; }

AthMessaging::msg

MsgStream & msg() const

The standard message stream.

Definition AthMessaging.h:163

◆ 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 (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 *	)

inlineoverrideprotectedvirtualinherited

obsolete

Implements T_AthenaPoolCustCnv< TRANS, PERS >.

Definition at line 96 of file T_AthenaPoolCustomCnv.h.

96{ return(StatusCode::FAILURE); }

T_AthenaPoolCustomCnvWithKey

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

Definition T_AthenaPoolCustomCnv.h:35

◆ phiCorr()

double Converter::phiCorr ( double phi )

inlineprotectedinherited

Definition at line 248 of file Converter.h.

                            {
    
    if (phi < -TMath::Pi()) phi += 2*TMath::Pi();
    if (phi >  TMath::Pi()) phi -= 2*TMath::Pi();
    
    return phi;
  }

◆ poolReadObject() [1/2]

template<class TRANS, class PERS>

template<class P>

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

protectedinherited

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 )

protectedinherited

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 )

overrideprotectedvirtualinherited

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 58 of file AthenaPoolConverter.cxx.

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

◆ selectTracks() [1/3]

void Converter::selectTracks ( const Analysis::MuonContainer * muontracks )

inlineinherited

Definition at line 177 of file Converter.h.

                                                               {
    
    static int hpmap[20] = { 0, 1, 2,  7, 8, 9,  3, 4, 5, 6, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 };
    
    Analysis::MuonContainer::const_iterator muonitr = muontracks->begin();
    Analysis::MuonContainer::const_iterator muonend = muontracks->end();
    
    while(muonitr!=muonend) { 
      
      bool hasInDet = (*muonitr)->hasInDetTrackParticle();
      const Rec::TrackParticle *trackitr=NULL; 
      if(hasInDet) trackitr=(*muonitr)->inDetTrackParticle();
      muonitr++;
      if(!hasInDet) continue;
      
      const Trk::MeasuredPerigee* measPer = trackitr->measuredPerigee();
      
      CLHEP::HepVector perigeeParams = measPer->parameters();    
      double pT    = measPer->pT(); 
      double eta   = measPer->eta();
      double phi   = perigeeParams[Trk::phi0];
      double z0    = perigeeParams[Trk::z0];
      double d0    = perigeeParams[Trk::d0];
      //double theta = perigeeParams[Trk::theta];
      
      double deta = 1;
      double dphi = 1;
      double dz0  = 1;
      double dd0  = 1;
      double dpT  = 1;    
      
      // Check number of hits
      // NB: a spacepoint is two offline "hits", so a pixel spacepoint is really 
      // 2 "hits" and an offline SCT "hit" is really a 1D cluster, so two intersetcting
      // stereo clusters making a spacepoint are two "hits"
      const Trk::TrackSummary *summary = trackitr->trackSummary();
      int nBlayerHits = 2*summary->get(Trk::numberOfBLayerHits); 
      int nPixelHits  = 2*summary->get(Trk::numberOfPixelHits);  
      int nSctHits    = summary->get(Trk::numberOfSCTHits); 
      int nStrawHits  = summary->get(Trk::numberOfTRTHits);
      int nTrHits     = summary->get(Trk::numberOfTRTHighThresholdHits);
      
      int nSiHits     = nPixelHits + nSctHits;
      
      const Trk::FitQuality *quality   = trackitr->fitQuality();
      double chi2 = quality->chiSquared();
      double dof  = quality->quality->numberDoF();
 
      unsigned bitmap = 0;
      
      for ( int ih=0 ; ih<20 ; ih++ ) {
    if ( summary->isHit(Trk::DetectorType(ih)) ) bitmap |= ( 1<<hpmap[ih] );    
      }
      
      // Shift d0 and z0 according to beam position
      ipCorr(d0, z0, d0, z0, phi, eta, pT);
      
      // Create and save Track  
      TIDA::Track* t = new TIDA::Track(eta, phi, z0, d0, pT, chi2, dof,
                                 deta, dphi, dz0, dd0, dpT,
                                 nBlayerHits, nPixelHits, nSctHits, nSiHits,
                                 nStrawHits, nTrHits, bitmap, 0,
                                 -1) ;
      
      addTrack(t);
    }
    
  }

◆ selectTracks() [2/3]

void Converter::selectTracks ( const Rec::TrackParticleContainer * trigtracks )

inlineinherited

Definition at line 111 of file Converter.h.

                                                                   { 
    
    Rec::TrackParticleContainer::const_iterator  trackitr = trigtracks->begin();
    Rec::TrackParticleContainer::const_iterator  trackend = trigtracks->end();
    
    static int hpmap[20] = { 0, 1, 2,  7, 8, 9,  3, 4, 5, 6, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 };
 
    while ( trackitr!=trackend ) { 
        
      const Trk::MeasuredPerigee* measPer = (*trackitr)->measuredPerigee();
 
      CLHEP::HepVector perigeeParams = measPer->parameters();    
      double pT    = measPer->pT(); 
      double eta   = measPer->eta();
      double phi   = perigeeParams[Trk::phi0];
      double z0    = perigeeParams[Trk::z0];
      double d0    = perigeeParams[Trk::d0];
      //double theta = perigeeParams[Trk::theta];
    
      double deta = 1;
      double dphi = 1;
      double dz0  = 1;
      double dd0  = 1;
      double dpT  = 1;    
 
      // Check number of hits
      // NB: a spacepoint is two offline "hits", so a pixel spacepoint is really 
      // 2 "hits" and an offline SCT "hit" is really a 1D cluster, so two intersetcting
      // stereo clusters making a spacepoint are two "hits"
      const Trk::TrackSummary *summary = (*trackitr)->trackSummary();
      int nBlayerHits = 2*summary->get(Trk::numberOfBLayerHits); 
      int nPixelHits  = 2*summary->get(Trk::numberOfPixelHits);  
      int nSctHits    = summary->get(Trk::numberOfSCTHits); 
      int nStrawHits  = summary->get(Trk::numberOfTRTHits);
      int nTrHits     = summary->get(Trk::numberOfTRTHighThresholdHits);
      int nSiHits     = nPixelHits + nSctHits;
      bool expectBL   = false; // Not stored for Rec::TrackParticle
 
      const Trk::FitQuality *quality   = (*trackitr)->fitQuality();
      double chi2 = quality->chiSquared();
      double dof  = quality->numberDoF();
 
      unsigned bitmap = 0;
      
      for ( int ih=0 ; ih<20 ; ih++ ) {
    if ( summary->isHit(Trk::DetectorType(ih)) ) bitmap |= ( 1<<hpmap[ih] );    
      }
 
      // Shift d0 and z0 according to beam position
      ipCorr(d0, z0, d0, z0, phi, eta, pT);
 
      // Create and save Track  
      TIDA::Track* t = new TIDA::Track(eta, phi, z0, d0, pT, chi2, dof, 
                                 deta, dphi, dz0, dd0, dpT,
                                 nBlayerHits, nPixelHits, nSctHits, nSiHits,
                                 nStrawHits, nTrHits, bitmap, 0,
                                 -1,
                                 expectBL) ;
  
      addTrack(t);
      trackitr++;
    }
    
  }

◆ selectTracks() [3/3]

void Converter::selectTracks ( const TrigInDetTrackCollection * trigtracks )

inlineinherited

Definition at line 56 of file Converter.h.

                                                                {
    
    TrigInDetTrackCollection::const_iterator  trackitr = trigtracks->begin();
    TrigInDetTrackCollection::const_iterator  trackend = trigtracks->end();
 
    while ( trackitr!=trackend ) { 
 
    double eta    = (*trackitr)->param()->eta();
    double phi    = (*trackitr)->param()->phi0();
    double z0     = (*trackitr)->param()->z0(); 
    double pT     = (*trackitr)->param()->pT(); 
    double d0     = (*trackitr)->param()->a0();
    //double theta  = 2*atan2(exp(-(*trackitr)->param()->eta()),1);
 
    double deta    = (*trackitr)->param()->eeta();
    double dphi    = (*trackitr)->param()->ephi0();
    double dz0     = (*trackitr)->param()->ez0(); 
    double dpT     = (*trackitr)->param()->epT(); 
    double dd0     = (*trackitr)->param()->ea0();
 
    int   algoid  = (*trackitr)->algorithmId();           
 
    int nBlayerHits = ((*trackitr)->HitPattern() & 0x1);
    int nPixelHits  = 2*(*trackitr)->NPixelSpacePoints();  // NB: for comparison with offline 
    int nSctHits    = 2*(*trackitr)->NSCT_SpacePoints();   //     a spacepoint is 2 "hits"
    int nStrawHits  = (*trackitr)->NStrawHits();
    int nTrHits     = (*trackitr)->NTRHits();
               
    int nSiHits     = nPixelHits + nSctHits;
    bool expectBL   = false;                               //not available with TrigInDetTrack
 
    unsigned hitPattern = (*trackitr)->HitPattern();
    unsigned multiPattern = 0;
 
    double chi2    = (*trackitr)->chi2();
    double dof     = 0;
 
    // Shift d0 and z0 according to beam position
    ipCorr(d0, z0, d0, z0, phi, eta, pT);
    
    // Create and save Track  
    TIDA::Track* t = new TIDA::Track(eta,  phi,  z0,  d0,  pT, chi2, dof, 
                                   deta, dphi, dz0, dd0, dpT, 
                                   nBlayerHits, nPixelHits, nSctHits, nSiHits, 
                                   nStrawHits, nTrHits, hitPattern, multiPattern, 
                                   algoid,
                                   expectBL ) ; 
 
    addTrack(t);
    trackitr++; 
    }
  }

◆ 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 176 of file AthenaPoolConverter.cxx.

                                                                                                                         {
   Placement placement;
   // Override streaming parameters from StreamTool if requested.
   std::string::size_type pos1 = output.find('[');
   std::string outputConnectionSpec = output.substr(0, pos1);
   int tech = 0;
   m_athenaPoolCnvSvc->decodeOutputSpec(outputConnectionSpec, tech).ignore();
   // Set DB and Container names
   placement.setFileName(outputConnectionSpec);
 
   std::string containerPrefix = m_containerPrefix;
   if( containerPrefix == "Default" ) {
      containerPrefix = pool::ROOTRNTUPLE_StorageType.exactMatch(tech) ? APRDefaults::RNTupleNames::EventData : APRDefaults::TTreeNames::EventData;
   }
   std::string dhContainerPrefix = pool::ROOTRNTUPLE_StorageType.exactMatch(tech) ? APRDefaults::RNTupleNames::DataHeader : APRDefaults::TTreeNames::DataHeader;
   std::string containerName;
 
   // Get Technology from containerPrefix
   std::size_t colonPos = containerPrefix.find(':');
   if (colonPos != std::string::npos) {
      dhContainerPrefix = containerPrefix.substr(0, colonPos + 1) + dhContainerPrefix;
   }
 
   // Override streaming parameters from StreamTool if requested.
   std::string containerNameHint = m_containerNameHint;
   std::string branchNameHint = m_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);
   }
 
   // ---  Special types:   DataHeader & Form
   if( tname.compare(0, 10, "DataHeader") == 0 ) {
      if( tname.compare(10, 4, "Form") == 0 ) {
         containerName = dhContainerPrefix + "Form" + "(" + tname + ")";
      } else {
         if (key[key.size() - 1] == '/') {
            containerName = dhContainerPrefix + "(" + key + tname + ")";
         } else {
            containerName = dhContainerPrefix + "(" + tname + ")";
         }
      }
   }
   // AttributeList - writing attributes separately to EventTag container group
   else if (tname.compare(0, 13, "AttributeList") == 0) {
      // Find the right storage type and name for EventTag values
      if( pool::ROOTRNTUPLE_StorageType.exactMatch(tech) ) {
         containerName = std::string(APRDefaults::RNTupleNames::EventTag) + "(" + key + ")";
      } else {
         // no indexing needed (nothing points to Tags)
         // safe to set tech here - it will not be overwritten by decodeOutput
         tech = pool::ROOTTREE_StorageType.type();
         containerName = std::string(APRDefaults::TTreeNames::EventTag) + "(" + key + ")";
      }
   }
   // all other object types
   else {
      const std::string typeTok = "<type>", keyTok = "<key>";
      containerName = containerPrefix + containerFriendPostfix + containerNameHint;
      if (!branchNameHint.empty()) {
         containerName += "(" + branchNameHint + ")";
      }
      const std::size_t pos1 = containerName.find(typeTok);
      if (pos1 != std::string::npos) {
         containerName.replace(pos1, typeTok.size(), tname);
      }
      const std::size_t pos2 = containerName.find(keyTok);
      if (pos2 != std::string::npos) {
         if (key.empty()) {
            containerName.replace(pos2, keyTok.size(), tname);
         } else {
            containerName.replace(pos2, keyTok.size(), key);
         }
      }
   }
   m_athenaPoolCnvSvc->decodeOutputSpec(containerName, tech).ignore();
   placement.setContainerName(containerName);
   placement.setTechnology(tech);
   return(placement);
}

◆ setToken()

template<class TRANS, class PERS>

virtual void T_AthenaPoolCustCnv< TRANS, PERS >::setToken ( const std::string & token )

protectedvirtualinherited

Set the token (in std::string representation) and classID for the object that will be read next.

Required by compareClassGuid() and poolReadObject(). Only extending converter needs to call this method explicitely

Parameters

token [IN] token for the object to be read

◆ storageType()

long AthenaPoolConverter::storageType ( )

staticinherited

Returns: storage type.

Definition at line 155 of file AthenaPoolConverter.cxx.

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

◆ tracks()

const std::vector< TIDA::Track * > & Converter::tracks ( ) const

inlineinherited

Definition at line 50 of file Converter.h.

50{return m_tracks;}

◆ transToPers()

template<class TRANS, class PERS>

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

inlineoverrideprotectedvirtualinherited

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

Implements T_AthenaPoolCustCnv< TRANS, PERS >.

Definition at line 94 of file T_AthenaPoolCustomCnv.h.

94{ return(StatusCode::FAILURE); }

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 117 of file AthenaPoolConverter.h.

◆ m_beamX

double Converter::m_beamX

protectedinherited

Definition at line 320 of file Converter.h.

◆ m_beamY

double Converter::m_beamY

protectedinherited

Definition at line 320 of file Converter.h.

◆ m_beamZ

double Converter::m_beamZ

protectedinherited

Definition at line 320 of file Converter.h.

◆ m_branchNameHint

std::string AthenaPoolConverter::m_branchNameHint

protectedinherited

Definition at line 127 of file AthenaPoolConverter.h.

◆ m_classDesc

RootType AthenaPoolConverter::m_classDesc

protectedinherited

Definition at line 118 of file AthenaPoolConverter.h.

◆ m_classDescs

ClassMap AthenaPoolConverter::m_classDescs

protectedinherited

Definition at line 123 of file AthenaPoolConverter.h.

◆ m_classID

template<class TRANS, class PERS>

Guid T_AthenaPoolCustCnv< TRANS, PERS >::m_classID

protectedinherited

Definition at line 96 of file T_AthenaPoolCustCnv.h.

◆ m_className

std::string AthenaPoolConverter::m_className

protectedinherited

Definition at line 122 of file AthenaPoolConverter.h.

◆ m_containerNameHint

std::string AthenaPoolConverter::m_containerNameHint

protectedinherited

Definition at line 126 of file AthenaPoolConverter.h.

◆ m_containerPrefix

std::string AthenaPoolConverter::m_containerPrefix

protectedinherited

Definition at line 125 of file AthenaPoolConverter.h.

◆ m_conv_mut

CallMutex AthenaPoolConverter::m_conv_mut

protectedinherited

Definition at line 133 of file AthenaPoolConverter.h.

◆ m_dataObject

const DataObject* AthenaPoolConverter::m_dataObject

protectedinherited

Definition at line 129 of file AthenaPoolConverter.h.

◆ m_detStore

ServiceHandle<StoreGateSvc> AthenaPoolConverter::m_detStore

protectedinherited

Definition at line 116 of file AthenaPoolConverter.h.

◆ m_i_poolToken

const Token* AthenaPoolConverter::m_i_poolToken

protectedinherited

Definition at line 130 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>

std::map<std::string, std::vector< std::unique_ptr<PERS> > > T_AthenaPoolCustomCnvWithKey< TRANS, PERS >::m_persObjLists

protectedinherited

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

Definition at line 120 of file T_AthenaPoolCustomCnv.h.

◆ m_pListMutex

template<class TRANS, class PERS>

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

protectedinherited

protection mutex for m_persObjLists

Definition at line 123 of file T_AthenaPoolCustomCnv.h.

◆ m_tracks

std::vector<TIDA::Track*> Converter::m_tracks

protectedinherited

Definition at line 321 of file Converter.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 Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ BaseType

◆ CallMutex

◆ ClassMap

◆ ClassMapIt

Member Function Documentation

◆ addTrack()

◆ classID()

◆ cleanUp()

◆ clear()

◆ compareClassGuid()

◆ createObj()

◆ createPersistent()

◆ createPersistentWithKey()

◆ createRep()

◆ createTransient()

◆ createTransientWithKey()

◆ DataObjectToPers()

◆ DataObjectToPool()

◆ detStore()

◆ fillRepRefs()

◆ finalize()

◆ getDataObject()

◆ initialize()

◆ initMessaging()

◆ ipCorr()

◆ keepPoolObj()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ objectToPool()

◆ persToTrans()

◆ phiCorr()

◆ poolReadObject() [1/2]

◆ poolReadObject() [2/2]

◆ PoolToDataObject()

◆ poolToObject()

◆ repSvcType()

◆ selectTracks() [1/3]

◆ selectTracks() [2/3]

◆ selectTracks() [3/3]

◆ setLevel()

◆ setPlacement()

◆ setPlacementForP()

◆ setPlacementWithType()

◆ setToken()

◆ storageType()

◆ tracks()

◆ transToPers()

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_athenaPoolCnvSvc

◆ m_beamX

◆ m_beamY

◆ m_beamZ

◆ m_branchNameHint

◆ m_classDesc

◆ m_classDescs

◆ m_classID

◆ m_className

◆ m_containerNameHint

◆ m_containerPrefix

◆ m_conv_mut

◆ m_dataObject

◆ m_detStore

◆ m_i_poolToken

◆ m_imsg

◆ m_lvl

◆ m_msg_tls

◆ m_nm

◆ m_persObjLists