This class provides the abstract converter to translate an object to/from its persistent POOL representation. More...

#include <AthenaPoolConverter.h>

Inherits Converter, AthMessaging, and IAthenaPoolCleanUp.

Collaboration diagram for AthenaPoolConverter:

Public Member Functions
virtual	~AthenaPoolConverter ()
	Destructor. More...

virtual StatusCode	initialize () override
	Gaudi Service Interface method implementations: More...

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

virtual StatusCode	createRep (DataObject pObj, IOpaqueAddress &pAddr) override
	Create a POOL persistent representation for a transient object. More...

virtual StatusCode	fillRepRefs (IOpaqueAddress pAddr, DataObject pObj) override
	Create a POOL persistent representation for a transient object. More...

const ServiceHandle< StoreGateSvc > &	detStore () const
	Handle to DetectorStore. More...

virtual StatusCode	cleanUp (const std::string &output) override
	Implement cleanUp for AthenaPoolConverter to do nothing. More...

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

MsgStream &	msg () const
	The standard message stream. More...

MsgStream &	msg (const MSG::Level lvl) const
	The standard message stream. More...

void	setLevel (MSG::Level lvl)
	Change the current logging level. More...

Static Public Member Functions
static long	storageType ()

static const CLID &	classID ()

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

typedef ClassMap::const_iterator	ClassMapIt

typedef std::mutex	CallMutex

Protected Member Functions
	AthenaPoolConverter (const CLID &id, ISvcLocator pSvcLocator, const char name=nullptr)
	Standard Service Constructor. More...

virtual StatusCode	DataObjectToPers (DataObject pObj, IOpaqueAddress &pAddr)=0
	Convert an object into Persistent. More...

virtual StatusCode	DataObjectToPool (IOpaqueAddress pAddr, DataObject pObj)=0
	Write an object into POOL. More...

virtual StatusCode	PoolToDataObject (DataObject &pObj, const Token token, const std::string &key)=0
	Read an object from POOL. More...

virtual Placement	setPlacementWithType (const std::string &tname, const std::string &key, const std::string &output)
	Set POOL placement hint for a given type. More...

virtual Placement	setPlacement (const std::string &key, const std::string &output)=0
	Set POOL placement hint; pure virtual method implemented by classes templated by type. More...

virtual const DataObject *	getDataObject () const

bool	compareClassGuid (const Guid &guid) const

double	phiCorr (double phi)

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

Protected Attributes
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. More...

Private Attributes
std::string	m_nm
	Message source name. More...

boost::thread_specific_ptr< MsgStream >	m_msg_tls
	MsgStream instance (a std::cout like with print-out levels) More...

std::atomic< IMessageSvc * >	m_imsg { nullptr }
	MessageSvc pointer. More...

std::atomic< MSG::Level >	m_lvl { MSG::NIL }
	Current logging level. More...

std::atomic_flag m_initialized	ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT
	Messaging initialized (initMessaging) More...

Detailed Description

This class provides the abstract converter to translate an object to/from its persistent POOL representation.

Definition at line 41 of file AthenaPoolConverter.h.

Member Typedef Documentation

◆ CallMutex

typedef std::mutex AthenaPoolConverter::CallMutex

protected

Definition at line 132 of file AthenaPoolConverter.h.

◆ ClassMap

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

protected

Definition at line 120 of file AthenaPoolConverter.h.

◆ ClassMapIt

typedef ClassMap::const_iterator AthenaPoolConverter::ClassMapIt

protected

Definition at line 121 of file AthenaPoolConverter.h.

Constructor & Destructor Documentation

◆ ~AthenaPoolConverter()

AthenaPoolConverter::~AthenaPoolConverter ( )

virtual

Destructor.

Definition at line 23 of file AthenaPoolConverter.cxx.

                                           {
    delete m_i_poolToken; m_i_poolToken = nullptr;
 }

◆ AthenaPoolConverter()

AthenaPoolConverter::AthenaPoolConverter	(	const CLID &	id,
		ISvcLocator *	pSvcLocator,
		const char *	name = `nullptr`
	)

protected

Standard Service Constructor.

Definition at line 157 of file AthenaPoolConverter.cxx.

                                                              :
         ::Converter(POOL_StorageType, myCLID, pSvcLocator),
         ::AthMessaging((pSvcLocator != nullptr ? msgSvc() : nullptr),
                                name ? name : "AthenaPoolConverter"),
     m_detStore("DetectorStore", name ? name : "AthenaPoolConverter"),
     m_athenaPoolCnvSvc("AthenaPoolCnvSvc", name ? name : "AthenaPoolConverter"),
     m_classDesc(),
     m_className(),
     m_classDescs(),
     m_containerPrefix(""),
     m_containerNameHint(""),
     m_branchNameHint(""),
     m_dataObject(nullptr),
     m_i_poolToken(nullptr) {
 }

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

static const CLID& AthenaPoolConverter::classID ( )

static

Returns: class ID.

◆ cleanUp()

StatusCode AthenaPoolConverter::cleanUp ( const std::string & output )

overridevirtual

Implement cleanUp for AthenaPoolConverter to do nothing.

Implements IAthenaPoolCleanUp.

Definition at line 275 of file AthenaPoolConverter.cxx.

                                                           {
    ATH_MSG_DEBUG("AthenaPoolConverter cleanUp called for base class.");
    return(StatusCode::SUCCESS);
 }

◆ clear()

void Converter::clear ( )

inlineinherited

Definition at line 53 of file Converter.h.

53 {m_tracks.clear();}

◆ compareClassGuid()

bool AthenaPoolConverter::compareClassGuid ( const Guid & guid ) const

protected

Definition at line 271 of file AthenaPoolConverter.cxx.

                                                                  {
    return(m_i_poolToken ? (guid == m_i_poolToken->classID()) : false);
 }

◆ createObj()

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

overridevirtual

Create a transient object from a POOL persistent representation.

Parameters

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

Reimplemented in T_AthenaPoolCoolMultChanCnv< COLL_T, ELEM_T, ELEM_P >, T_AthenaPoolCoolMultChanCnv< LArHVScaleCorrComplete, LArConditionsSubset< LArSingleFloatP >, LArSingleFloatSubset_p1 >, and T_AthenaPoolCoolMultChanCnv< TransientClass, LArConditionsSubset< LArSingleFloatP >, LArSingleFloatSubset_p1 >.

Definition at line 61 of file AthenaPoolConverter.cxx.

                                                                                   {
    TokenAddress* tokAddr = dynamic_cast<TokenAddress*>(pAddr);
    
    bool ownTokAddr = false;
    if (tokAddr == nullptr || tokAddr->getToken() == nullptr) {
       ownTokAddr = true;
       Token* token = new 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
         delete token;
         return StatusCode::FAILURE;
       }
       tokAddr = new TokenAddress(*genAddr, token);
    }
    if( tokAddr->ipar()[0] > 0 and tokAddr->getToken()->auxString().empty() ) {
       char text[32];
       ::sprintf(text, "[CTXT=%08X]", static_cast<int>(*(pAddr->ipar())));
       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);
 }

◆ createRep()

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

overridevirtual

Create a POOL persistent representation for a transient object.

Parameters

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

Reimplemented in T_AthenaPoolCoolMultChanCnv< COLL_T, ELEM_T, ELEM_P >, T_AthenaPoolCoolMultChanCnv< LArHVScaleCorrComplete, LArConditionsSubset< LArSingleFloatP >, LArSingleFloatSubset_p1 >, and T_AthenaPoolCoolMultChanCnv< TransientClass, LArConditionsSubset< LArSingleFloatP >, LArSingleFloatSubset_p1 >.

Definition at line 110 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);
 }

◆ DataObjectToPers()

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

protectedpure virtual

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

◆ DataObjectToPool()

virtual StatusCode AthenaPoolConverter::DataObjectToPool	(	IOpaqueAddress *	pAddr,
		DataObject *	pObj
	)

protectedpure virtual

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

◆ detStore()

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

inline

Handle to DetectorStore.

Definition at line 69 of file AthenaPoolConverter.h.

69 { return m_detStore; }

◆ fillRepRefs()

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

overridevirtual

Create a POOL persistent representation for a transient object.

Parameters

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

Reimplemented in T_AthenaPoolCoolMultChanCnv< COLL_T, ELEM_T, ELEM_P >, T_AthenaPoolCoolMultChanCnv< LArHVScaleCorrComplete, LArConditionsSubset< LArSingleFloatP >, LArSingleFloatSubset_p1 >, and T_AthenaPoolCoolMultChanCnv< TransientClass, LArConditionsSubset< LArSingleFloatP >, LArSingleFloatSubset_p1 >.

Definition at line 139 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 ( )

overridevirtual

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

protectedvirtual

Returns: data object from the converter.

Definition at line 267 of file AthenaPoolConverter.cxx.

                                                            {
    return(m_dataObject);
 }

◆ initialize()

StatusCode AthenaPoolConverter::initialize ( )

overridevirtual

Gaudi Service Interface method implementations:

Definition at line 27 of file AthenaPoolConverter.cxx.

                                            {
    ATH_CHECK(::Converter::initialize());
  
    // We do not retrieve m_detStore as that store may not always be available!
  
    ATH_CHECK( m_athenaPoolCnvSvc.retrieve() );
  
    IProperty* propertyServer(dynamic_cast<IProperty*>(m_athenaPoolCnvSvc.get()));
    StringProperty containerPrefixProp("PoolContainerPrefix", "CollectionTree");
    StringProperty containerNameHintProp("TopLevelContainerName", "");
    StringProperty branchNameHintProp("SubLevelBranchName", "<type>/<key>");
    if (propertyServer != nullptr) {
       propertyServer->getProperty(&containerPrefixProp).ignore();
       propertyServer->getProperty(&containerNameHintProp).ignore();
       propertyServer->getProperty(&branchNameHintProp).ignore();
    }
    m_containerPrefix = containerPrefixProp.value();
    m_containerNameHint = containerNameHintProp.value();
    m_branchNameHint = branchNameHintProp.value();
    return(StatusCode::SUCCESS);
 }

◆ 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();
   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;
       
     }
   }

◆ 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 164 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 179 of file AthMessaging.h.

180 { return msg() << lvl; }

◆ 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_initialized.test_and_set()) initMessaging();
   if (m_lvl <= lvl) {
     msg() << lvl;
     return true;
   } else {
     return false;
   }
 }

◆ 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;
   }

◆ PoolToDataObject()

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

protectedpure virtual

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.

◆ repSvcType()

long AthenaPoolConverter::repSvcType ( ) const

overridevirtual

Definition at line 57 of file AthenaPoolConverter.cxx.

                                            {
    return(POOL_StorageType);
 }

◆ 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 AthenaPoolConverter::setPlacement	(	const std::string &	key,
		const std::string &	output
	)

protectedpure virtual

Set POOL placement hint; pure virtual method implemented by classes templated by type.

◆ setPlacementWithType()

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

protectedvirtual

Set POOL placement hint for a given type.

Parameters

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

Definition at line 174 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;
    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 = value;
       } else if (thisKey == "PoolContainerPrefix") {
          containerPrefix = value;
       } else if (thisKey == "TopLevelContainerName") {
          containerNameHint = value;
       } else if (thisKey == "SubLevelBranchName") {
          branchNameHint = value;
       } else if (thisKey == "PoolContainerFriendPostfix") {
          containerFriendPostfix = 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);
 }

◆ storageType()

long AthenaPoolConverter::storageType ( )

static

Returns: storage type.

Definition at line 153 of file AthenaPoolConverter.cxx.

                                       {
    return(POOL_StorageType);
 }

◆ tracks()

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

inlineinherited

Definition at line 50 of file Converter.h.

50 {return m_tracks;}

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

protected

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

protected

Definition at line 127 of file AthenaPoolConverter.h.

◆ m_classDesc

RootType AthenaPoolConverter::m_classDesc

protected

Definition at line 118 of file AthenaPoolConverter.h.

◆ m_classDescs

ClassMap AthenaPoolConverter::m_classDescs

protected

Definition at line 123 of file AthenaPoolConverter.h.

◆ m_className

std::string AthenaPoolConverter::m_className

protected

Definition at line 122 of file AthenaPoolConverter.h.

◆ m_containerNameHint

std::string AthenaPoolConverter::m_containerNameHint

protected

Definition at line 126 of file AthenaPoolConverter.h.

◆ m_containerPrefix

std::string AthenaPoolConverter::m_containerPrefix

protected

Definition at line 125 of file AthenaPoolConverter.h.

◆ m_conv_mut

CallMutex AthenaPoolConverter::m_conv_mut

protected

Definition at line 133 of file AthenaPoolConverter.h.

◆ m_dataObject

const DataObject* AthenaPoolConverter::m_dataObject

protected

Definition at line 129 of file AthenaPoolConverter.h.

◆ m_detStore

ServiceHandle<StoreGateSvc> AthenaPoolConverter::m_detStore

protected

Definition at line 116 of file AthenaPoolConverter.h.

◆ m_i_poolToken

const Token* AthenaPoolConverter::m_i_poolToken

protected

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.

◆ m_lvl

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

mutableprivateinherited

Current logging level.

Definition at line 138 of file AthMessaging.h.

◆ 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_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 files:

Public Member Functions

Static Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ CallMutex

◆ ClassMap

◆ ClassMapIt

Constructor & Destructor Documentation

◆ ~AthenaPoolConverter()

◆ AthenaPoolConverter()

Member Function Documentation

◆ addTrack()

◆ classID()

◆ cleanUp()

◆ clear()

◆ compareClassGuid()

◆ createObj()

◆ createRep()

◆ DataObjectToPers()

◆ DataObjectToPool()

◆ detStore()

◆ fillRepRefs()

◆ finalize()

◆ getDataObject()

◆ initialize()

◆ initMessaging()

◆ ipCorr()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ phiCorr()

◆ PoolToDataObject()

◆ repSvcType()

◆ selectTracks() [1/3]

◆ selectTracks() [2/3]

◆ selectTracks() [3/3]

◆ setLevel()

◆ setPlacement()

◆ setPlacementWithType()

◆ storageType()

◆ tracks()

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_athenaPoolCnvSvc

◆ m_beamX

◆ m_beamY

◆ m_beamZ

◆ m_branchNameHint

◆ m_classDesc

◆ m_classDescs

◆ 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_tracks