This class provides the converter to customize the saving of DataHeader. More...

#include <DataHeaderCnv.h>

Inheritance diagram for DataHeaderCnv:

Classes
struct	placementComp
	Cache for new DHForms created when writing, indexed by ref or placement. More...

Public Types
typedef T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >	BaseType

Public Member Functions
	DataHeaderCnv (ISvcLocator *svcloc)
	~DataHeaderCnv ()
virtual StatusCode	initialize () override
	Gaudi Service Interface method implementations:
virtual StatusCode	updateRep (IOpaqueAddress pAddress, DataObject pObject) override
	Extend base-class conversion methods.
virtual StatusCode	updateRepRefs (IOpaqueAddress pAddress, DataObject pObject) override
virtual StatusCode	DataObjectToPool (IOpaqueAddress pAddr, DataObject pObj) override
	Write an object into POOL.
std::unique_ptr< DataHeader_p5 >	poolReadObject_p5 (const Token *token)
std::unique_ptr< DataHeader_p6 >	poolReadObject_p6 (const Token *token)
DataHeader_p6 *	createPersistent (DataHeader transObj, DataHeaderForm_p6 )
virtual DataHeader *	createTransient (const Token *token) override
virtual DataHeader_p6 *	createPersistent (DataHeader *) override
virtual void	handle (const Incident &incident) override
	Incident service handle listening for EndInputFile.
void	clearInputDHFormCache (const std::string &dbGuid)
	Delete cached DHForms for a given input file GUID.
void	removeBadElements (DataHeader *dh)
	Remove DataHeaderElements with incomplete (dbID="") refs.
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 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 CLID	classID ()
static long	storageType ()

Protected Types
using	PersObjCache_t
	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 DataHeader_p6 *	createPersistentWithKey (DataHeader *obj, const std::string &) override
	method to be implemented by the developer.
virtual PERS *	createPersistentWithKey (TRANS *obj, const std::string &key)=0
	method to be implemented by the developer.
virtual DataHeader *	createTransientWithKey (const Token *token, const std::string &) override
	method to be implemented by the developer.
P *	poolReadObject (const Token *token)
	Read object of type 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 (DataHeader_p6 *obj, const std::string &output)
	Remember the POOL object to be written out (will be deleted after commit).
void	keepPoolObj (PERS *obj, const std::string &output)
	Remember the POOL object to be written out (will be deleted after commit).
virtual StatusCode	transToPers (DataHeader , DataHeader_p6 &) override
	Obsolete methods replaced by createPersistent() and createTransient() obsolete.
virtual StatusCode	persToTrans (DataHeader &, DataHeader_p6 ) override
	obsolete
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.
Placement	setPlacementForP (P &p, const std::string &key, const std::string &output)
	Set POOL placement for type 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.
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.
double	phiCorr (double phi)
void	ipCorr (double d0, double z0, double &d0c, double &z0c, double phi0, double eta, double pt)

Protected Attributes
DataHeaderCnv_p6	m_tpOutConverter
DataHeaderCnv_p6	m_tpInConverter
RootType	m_dhFormType
	cached shape of the DataHeaderForm_pN
bool	m_oneDHForm = true
	if true write only one DataHeaderForm at the end (stop, finalize, or WriteDataHeaderForms incident) the value is read from AthenaPoolCnvSvc OneDataHeaderForm property
std::map< std::string, std::unique_ptr< DataHeaderForm_p6 >, placementComp >	m_persFormMap
std::map< std::string, std::unique_ptr< DataHeaderForm_p6 > >	m_inputDHForms
	DHForm cache indexed by the DHForm reference (from DataHeader) that was used to read it.
std::map< std::string, unsigned >	m_inDHFormCount
	How many DHForms for an input file are in the cache.
unsigned	m_inDHFMapMaxsize {}
	Max DHForms to cache per input file.
std::map< std::string, std::string >	m_lastGoodDHFRef
DataHeaderCnv_p5	m_tpInConverter_p5
	for use when reading DataHeader_p5
std::unique_ptr< DataHeaderForm_p5 >	m_dhInForm5
std::string	m_dhFormMdx
DataHeader_p6 *	m_sharedWriterCachedDH = nullptr
	cached values for use with SharedWriter server
std::map< std::string, std::unique_ptr< DataHeaderForm_p6 > >	m_sharedWriterCachedDHForm
	map of cached DHForms for DataHeader ID
std::string	m_sharedWriterCachedDHKey
std::string	m_sharedWriterCachedDHToken
ServiceHandle< IPoolSvc >	m_poolSvc {"PoolSvc", "DataHeaderCnv"}
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
double	m_beamX
double	m_beamY
double	m_beamZ
std::vector< TIDA::Track * >	m_tracks

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
	MessageSvc pointer.
std::atomic< MSG::Level >	m_lvl
	Current logging level.
std::atomic_flag m_initialized	ATLAS_THREAD_SAFE
	Messaging initialized (initMessaging).

Friends
class	CnvFactory< DataHeaderCnv >

Detailed Description

This class provides the converter to customize the saving of DataHeader.

Definition at line 33 of file DataHeaderCnv.h.

Member Typedef Documentation

◆ BaseType

typedef T_AthenaPoolCustCnv<DataHeader, DataHeader_p6> T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::BaseType

inherited

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

typedef std::map<std::string, RootType> T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::ClassMap

privateinherited

Definition at line 86 of file T_AthenaPoolCustCnv.h.

◆ PersObjCache_t

using T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::PersObjCache_t

protectedinherited

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

◆ DataHeaderCnv()

DataHeaderCnv::DataHeaderCnv ( ISvcLocator * svcloc )

Definition at line 33 of file DataHeaderCnv.cxx.

                                                :
      DataHeaderCnvBase(svcloc, "DataHeaderCnv")
{
   m_classDesc = RootType( "DataHeader_p6" );
}

◆ ~DataHeaderCnv()

DataHeaderCnv::~DataHeaderCnv ( )

Definition at line 40 of file DataHeaderCnv.cxx.

{
   // Remove itself from the IncidentSvc - if it is still around
   ServiceHandle<IIncidentSvc> incSvc("IncidentSvc", "DataHeaderCnv");
   if( incSvc.retrieve().isSuccess() ) {
   try{
      incSvc->removeListener(this, IncidentType::EndInputFile);
    } catch ( GaudiException & e){
       ATH_MSG_FATAL("Gaudi exception caught in DataHeaderCnv::~DataHeaderCnv");
    }
   }
}

Member Function Documentation

◆ addTrack()

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

inlineinherited

Definition at line 43 of file Converter.h.

                              {
    m_tracks.push_back(t);
  }

◆ classID()

CLID T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::classID ( )

staticinherited

Returns: class ID.

◆ cleanUp()

virtual StatusCode T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::cleanUp ( const std::string & output )

overrideprotectedvirtualinherited

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

◆ clear()

void Converter::clear ( )

inlineinherited

Definition at line 51 of file Converter.h.

51{m_tracks.clear();}

◆ clearInputDHFormCache()

void DataHeaderCnv::clearInputDHFormCache ( const std::string & dbGuid )

Delete cached DHForms for a given input file GUID.

Definition at line 155 of file DataHeaderCnv.cxx.

{
   auto iter = m_inputDHForms.begin();
   while( iter != m_inputDHForms.end() ) {
      size_t dbpos = iter->first.find("[DB=");
      if( dbpos != std::string::npos && iter->first.compare(dbpos+4, dbpos+36, dbGuid) == 0 ) {
         iter = m_inputDHForms.erase( iter );
      } else {
         iter++;
      }
   }
   m_inDHFormCount[ dbGuid ] = 0;
}

◆ compareClassGuid()

virtual bool T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::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 55 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;
}

◆ createPersistent() [1/2]

virtual DataHeader_p6 * DataHeaderCnv::createPersistent ( DataHeader * )

inlineoverridevirtual

Implements T_AthenaPoolCustomCnv< DataHeader, DataHeader_p6 >.

Definition at line 55 of file DataHeaderCnv.h.

55{ return nullptr; }

◆ createPersistent() [2/2]

DataHeader_p6 * DataHeaderCnv::createPersistent	(	DataHeader *	transObj,
		DataHeaderForm_p6 *	dh_form )

Definition at line 548 of file DataHeaderCnv.cxx.

{
   return m_tpOutConverter.createPersistent( transObj, *dh_form );
}

◆ createPersistentWithKey() [1/2]

virtual DataHeader_p6 * T_AthenaPoolCustomCnv< DataHeader, DataHeader_p6 >::createPersistentWithKey	(	DataHeader *	obj,
		const std::string &	)

overrideprotectedvirtualinherited

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)

◆ createPersistentWithKey() [2/2]

template<class TRANS, class PERS>

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

protectedpure virtualinherited

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

◆ createTransient()

DataHeader * DataHeaderCnv::createTransient ( const Token * token )

overridevirtual

Implements T_AthenaPoolCustomCnv< DataHeader, DataHeader_p6 >.

Definition at line 568 of file DataHeaderCnv.cxx.

                                                             {
   if (token == nullptr) {
      return(nullptr);
   }
   if (token->technology() == 0x00001000) { // Artificial ByteStream DataHeader Token
      DataHeader* dh = new DataHeader();
      std::string bestPfn, fileType;
      m_poolSvc->lookupBestPfn(token->dbID().toString(), bestPfn, fileType);
      DataHeaderElement dhe(ClassID_traits<DataHeader>::ID(), bestPfn, Token(token));
      dh->insert(dhe);
      return(dh);
   }
   static const Guid p6_guid("4DDBD295-EFCE-472A-9EC8-15CD35A9EB8D");
   static const Guid p5_guid("D82968A1-CF91-4320-B2DD-E0F739CBC7E6");
   static const Guid p4_guid("9630EB7B-CCD7-47D9-A39B-CBBF4133CDF2");
   static const Guid p3_guid("EC1318F0-8E28-45F8-9A2D-2597C1CC87A6");
   try {
      if( compareClassGuid(token,  p6_guid ) ) {
         std::unique_ptr<DataHeader_p6> header( poolReadObject_p6(token) );
         auto dhForm = m_inputDHForms[ header->dhFormToken() ].get();
         auto dh = m_tpInConverter.createTransient( header.get(), *dhForm, token );
         removeBadElements(dh);
         // To dump the DataHeader uncomment below
         // std::ostringstream ss;  dh->dump(ss); std::cout << ss.str() << std::endl;
         return dh;
      } else if (this->compareClassGuid(token,  p5_guid )) {
         std::unique_ptr<DataHeader_p5> obj_p5( poolReadObject_p5(token) );
         return m_tpInConverter_p5.createTransient( *obj_p5, *m_dhInForm5 ).release();
      } else if (this->compareClassGuid(token,  p4_guid )) {
         std::unique_ptr<DataHeader_p4> obj_p4(this->poolReadObject<DataHeader_p4>(token));
         DataHeaderCnv_p4 tPconverter_p4;
         return(tPconverter_p4.createTransient(obj_p4.get()));
      } else if (this->compareClassGuid(token,  p3_guid )) {
         std::unique_ptr<DataHeader_p3> obj_p3(this->poolReadObject<DataHeader_p3>(token));
         DataHeaderCnv_p3 tPconverter_p3;
         return(tPconverter_p3.createTransient(obj_p3.get()));
      }
   } catch (std::exception &e) {
      // upgrade all exceptions to runtime_error (who needs that? MN)
      std::string error = e.what();
      throw std::runtime_error(error);
   }
   return(nullptr);
}

◆ createTransientWithKey()

virtual DataHeader * T_AthenaPoolCustomCnv< DataHeader, DataHeader_p6 >::createTransientWithKey	(	const Token *	token,
		const std::string &	key )

overrideprotectedvirtualinherited

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

◆ DataObjectToPool()

StatusCode DataHeaderCnv::DataObjectToPool	(	IOpaqueAddress *	pAddr,
		DataObject *	pObj )

overridevirtual

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_AthenaPoolCustomCnvWithKey< TRANS, PERS >.

Definition at line 295 of file DataHeaderCnv.cxx.

{
   std::lock_guard<AthenaPoolConverter::CallMutex> lock(this->m_conv_mut);
   DataHeader* obj = nullptr;
   if (!SG::fromStorable(pObj, obj) || obj == nullptr) {
      ATH_MSG_ERROR( "Failed to cast DataHeader to transient type" );
      return(StatusCode::FAILURE);
   }
   // DHForm placement:
   Placement dhf_placement = setPlacementWithType("DataHeaderForm", pObj->name(), *pAddr->par());
   std::string form_placement_str = dhf_placement.toString();
   // Find or create Form
   std::unique_ptr<DataHeaderForm_p6>& dhForm = m_persFormMap[form_placement_str];
   if (dhForm == nullptr) {
      // create new DHF for this file.  Every new file/container should get its own DHForm
      dhForm = std::make_unique<DataHeaderForm_p6>();
      dhForm->setProcessTag( obj->getProcessTag() );
   }
 
   // DH placement first:
   Placement dh_placement = setPlacementWithType("DataHeader", pObj->name(), *pAddr->par());
   // remember the connection string, it may get changed in registerForWrite by SharedWriter
   const std::string connection = dh_placement.fileName();
   // Create persistent DH and update Form
   DataHeader_p6* persObj = nullptr;
   try {
      persObj = createPersistent(obj, dhForm.get());
   } catch (std::exception &e) {
      ATH_MSG_FATAL("Failed to convert DataHeader to persistent type: " << e.what());
      return(StatusCode::FAILURE);
   }
   // Queue the DH for write
   std::unique_ptr<Token> dh_token(m_athenaPoolCnvSvc->registerForWrite(&dh_placement, persObj, m_classDesc));
   if (dh_token == nullptr) {
      ATH_MSG_FATAL("Failed to write DataHeader");
      return(StatusCode::FAILURE);
   }
   keepPoolObj(persObj, connection);
   // insert self reference - this updates DH and can modify the Form
   m_tpOutConverter.insertDHRef(persObj, obj->getProcessTag(), dh_token->toString(), *dhForm);
 
   if( !m_oneDHForm  ) {
      if( dhForm->isModified() ) {
         // Write DHForm if in legacy mode in case it was modified (or new)
         dhForm->setVersion( DataHeaderForm_p6::DHverFormRef );
         static const RootType dhFormType(typeid(*dhForm));
         Token* dhf_token = m_athenaPoolCnvSvc->registerForWrite(&dhf_placement, dhForm.get(), dhFormType);
         if (dhf_token  == nullptr) {
            ATH_MSG_FATAL("Failed to write " << dhFormType.Name());
            return(StatusCode::FAILURE);
         }
         if (dhf_token->technology() != 0) { // Only store DHF token if technology allows it to be appended to DH
            dhForm->setToken(dhf_token->toString());
         } else { // Otherwise keep string empty to cause DHF reading via DH token
            ATH_MSG_DEBUG("Technology does not support setting DHF token for: " << dh_token->toString());
            dhForm->setToken("");
         }
         ATH_MSG_DEBUG("wrote new DHForm with " << dhForm->sizeObj() << " SG object data");
         dhf_token->release(); dhf_token = nullptr;
         dhForm->clearModified();
      }
      // update the Ref to the DHForm 
      persObj->setDhFormToken( dhForm->getToken() );
   }
   else {
      // use the DHForm placement as a Ref, as the DHForm will be written out at the end only
      // but add DB ID to the placement str in case the filename is not unique between jobs
      if( dhForm->getToken().empty() ) {
         form_placement_str += std::format("[DB={}]", dh_token->dbID().toString());
         dhForm->setToken( form_placement_str );
      } else {
         form_placement_str = dhForm->getToken();
      }
      // remove the [FILE= part as the DBID will be enough for reading back
      auto b = form_placement_str.find("[FILE=");
      auto e = form_placement_str.find("]", b);
      form_placement_str.erase(b, e-b+1);
      // store the modified DHForm placement in place of the Ref in the DH
      persObj->setDhFormToken( form_placement_str );
   }
 
   const coral::AttributeList* list = obj->getAttributeList();
   if (list != nullptr) {
      static const std::string attributeListStr{"AttributeList"};
      obj->setEvtRefTokenStr(dh_token->toString());
      Placement attr_placement = this->setPlacementWithType(attributeListStr, "Token", *pAddr->par());
      const Token* ref_token = m_athenaPoolCnvSvc->registerForWrite(&attr_placement,
          obj->getEvtRefTokenStr().c_str(),
          RootType("Token"));
      delete ref_token; ref_token = nullptr;
      for (coral::AttributeList::const_iterator iter = list->begin(), last = list->end(); iter != last; ++iter) {
         attr_placement = this->setPlacementWithType(attributeListStr, (*iter).specification().name(), *pAddr->par());
         const Token* attr_token = m_athenaPoolCnvSvc->registerForWrite(&attr_placement,
             (*iter).addressOfData(),
                 RootType((*iter).specification().type()) );
         delete attr_token; attr_token = nullptr;
      }
   }
   TokenAddress* tokAddr = dynamic_cast<TokenAddress*>(pAddr);
   if (tokAddr != nullptr) {
      tokAddr->setToken(std::move(dh_token));
   } else {
      return(StatusCode::FAILURE);
   }
   return(StatusCode::SUCCESS);
}

◆ detStore()

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

inlineinherited

Handle to DetectorStore.

Definition at line 68 of file AthenaPoolConverter.h.

68{ return m_detStore; }

T_AthenaPoolCustomCnv< DataHeader, DataHeader_p6 >::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 65 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 48 of file AthenaPoolConverter.cxx.

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

◆ handle()

void DataHeaderCnv::handle ( const Incident & incident )

overridevirtual

Incident service handle listening for EndInputFile.

Definition at line 95 of file DataHeaderCnv.cxx.

{
   if( incident.type() == "PreFork" ) {
      m_persFormMap.clear();
   }
   if( incident.type() == IncidentType::EndInputFile ) {
      // remove cached DHForms that came from the file that is now being closed
      const std::string& guid = static_cast<const FileIncident&>(incident).fileGuid();
      clearInputDHFormCache( guid );
   }
   if( incident.type() == "WriteDataHeaderForms" ) {
      // Issued from OutputStream MetaData write() or directly called from AthenaPoolCnvSvc
      const std::string& fileName = static_cast<const FileIncident*>(&incident)->fileName();
      // Write out all the cached DHForms before closing a given output stream
      std::vector<std::string> toWrite;
      auto pos = fileName.find("[OutputCollection=MetaDataHdr]");
      bool metaDataCommit = (pos != std::string::npos);
      std::string justFileName = fileName.substr(0, pos);
      ATH_MSG_DEBUG("Handling WriteDataHeaderForms incident for stream: " << fileName);
      // collect DHForms related to the stream
      for( const auto& elem : m_persFormMap ) {
         const std::string& placementStr = elem.first;
         Placement formPlacement;
         formPlacement.fromString( placementStr );
         ATH_MSG_VERBOSE("DatHeaderForm key in map=" << placementStr);
         if( formPlacement.fileName() == justFileName or fileName == "*" ) {
            // write only the Forms that correspond to the commit type (MetaData or others)
             if( (placementStr.find("[CONT=MetaData") != std::string::npos) == metaDataCommit ) {
               toWrite.push_back( placementStr );
            }
         }
      }
      // write the DHForms one by one (the only mode supported by RNTuple)
      for( std::size_t n = 0; const std::string& placementStr : toWrite ) {
         Placement formPlacement;
         formPlacement.fromString( placementStr );
         auto form_ptr = m_persFormMap[placementStr].get();
         if( form_ptr->isModified() ) {
            static const RootType dhFormType( typeid( *form_ptr ) );
            ATH_MSG_DEBUG("Writing DatHeaderForm " << placementStr);
            Token* form_token = m_athenaPoolCnvSvc->registerForWrite(&formPlacement, form_ptr, dhFormType);
            if( !form_token ) {
               std::string errmsg = std::format("Failed to write {} {}", dhFormType.Name(), placementStr);
               ATH_MSG_FATAL( errmsg );
               throw GaudiException(std::move(errmsg), "DataHeaderCnv::WriteDataHeaderForms", StatusCode::FAILURE);
            }
            ATH_MSG_DEBUG("Wrote DatHeaderForm, placeemnt was " << placementStr << "  token=" << form_token->toString());
            form_token->release(); form_token = nullptr;
            bool doCommit = (++n == toWrite.size());
            const std::string connection = ( fileName!="*"? fileName : formPlacement.fileName() );
            if( !m_athenaPoolCnvSvc->commitOutput(connection, doCommit).isSuccess() ) {
               throw GaudiException("WriteDataHeaderForms failed",  "DataHeaderCnv::WriteDataHeaderForms", StatusCode::FAILURE);
            }
         }
         m_persFormMap.erase( placementStr );
      }
   }   
}

◆ initialize()

StatusCode DataHeaderCnv::initialize ( )

overridevirtual

Gaudi Service Interface method implementations:

Reimplemented from T_AthenaPoolCustCnv< TRANS, PERS >.

Definition at line 53 of file DataHeaderCnv.cxx.

{
   ATH_CHECK(m_poolSvc.retrieve());
   // Read properties from the ConversionSvc
   m_inDHFMapMaxsize = 100;   // default DHForm cache size
   bool doFilterDHAliases = true;
   const std::string svcName = (serviceLocator()->existsService("AthenaPoolSharedIOCnvSvc") ? "AthenaPoolSharedIOCnvSvc" : "AthenaPoolCnvSvc");
   SmartIF<IProperty> cnvSvc{service(svcName, false)};
   if( cnvSvc ) {
      IntegerProperty sizeProp("maxDHFormCacheSize", m_inDHFMapMaxsize);
      if( cnvSvc->getProperty(&sizeProp).isSuccess() ) {
         m_inDHFMapMaxsize = sizeProp.value();
      }
      BooleanProperty aliasFilterProp("doFilterDHAliases", doFilterDHAliases);
      if( cnvSvc->getProperty(&aliasFilterProp).isSuccess() ) {
         doFilterDHAliases = aliasFilterProp.value();
      }
      BooleanProperty oneDHForm("OneDataHeaderForm", m_oneDHForm);
      if( cnvSvc->getProperty(&oneDHForm).isSuccess() ) {
         m_oneDHForm = oneDHForm.value();
      }
   }
   ATH_MSG_VERBOSE("Using DHForm cache size: " << m_inDHFMapMaxsize);
   if( doFilterDHAliases ) {
      ATH_MSG_VERBOSE("Will filter SG Aux aliases in DataHeader");
   } else {
      ATH_MSG_VERBOSE("Will NOT filter SG Aux aliases in DataHeader");
   }
   m_tpOutConverter.setSGAliasFiltering( doFilterDHAliases );
 
   // Get IncidentSvc
   ServiceHandle<IIncidentSvc> incSvc("IncidentSvc", "DataHeaderCnv");
   ATH_CHECK( incSvc.retrieve() );
   // Listen to EndInputFile incidents to clear old DataHeaderForms from the cache
   incSvc->addListener(this, IncidentType::EndInputFile, 0);
   incSvc->addListener(this, "PreFork", 0);
   // Listen to WriteDataHeaderForms incidents to flush DHForms after 
   incSvc->addListener(this, "WriteDataHeaderForms", 0);
   return DataHeaderCnvBase::initialize();
}

◆ initMessaging()

void AthMessaging::initMessaging ( ) const

privateinherited

Initialize our message level and MessageSvc.

This method should only be called once.

Definition at line 121 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 200 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() [1/2]

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

protectedinherited

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

Parameters

obj	[IN] persistent object

◆ keepPoolObj() [2/2]

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 92 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 99 of file AthMessaging.h.

183{ return msg() << lvl; }

T_AthenaPoolCustomCnv< DataHeader, DataHeader_p6 >::msg

MsgStream & msg() const

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

StatusCode T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::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()

virtual StatusCode T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::persToTrans	(	DataHeader *&	,
		DataHeader_p6 *	)

inlineoverrideprotectedvirtualinherited

obsolete

Definition at line 97 of file T_AthenaPoolCustomCnv.h.

97{ return(StatusCode::FAILURE); }

◆ phiCorr()

double Converter::phiCorr ( double phi )

inlineprotectedinherited

Definition at line 191 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]

P * T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::poolReadObject ( const Token * token )

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]

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

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

◆ poolReadObject_p5()

std::unique_ptr< DataHeader_p5 > DataHeaderCnv::poolReadObject_p5 ( const Token * token )

Definition at line 403 of file DataHeaderCnv.cxx.

{
   void* voidPtr1 = nullptr;
   m_athenaPoolCnvSvc->setObjPtr(voidPtr1, token);
   if (voidPtr1 == nullptr) {
      throw std::runtime_error("Could not get object for token = " + token->toString());
   }
   std::unique_ptr<DataHeader_p5> header( reinterpret_cast<DataHeader_p5*>(voidPtr1) );
 
   void* voidPtr2 = nullptr;
   Token mapToken;
   mapToken.fromString( header->dhFormToken() );
   mapToken.setAuxString( token->auxString() );  // set PersSvc context
   if (mapToken.classID() != Guid::null()) {
      if( header->dhFormMdx() != m_dhFormMdx ) {
         m_athenaPoolCnvSvc->setObjPtr(voidPtr2, &mapToken);
         if (voidPtr2 == nullptr) {
            throw std::runtime_error("Could not get object for token = " + mapToken.toString());
         }
         m_dhInForm5.reset( reinterpret_cast<DataHeaderForm_p5*>(voidPtr2) );
         m_dhFormMdx = header->dhFormMdx();
      }
   }
   return header;
}

◆ poolReadObject_p6()

std::unique_ptr< DataHeader_p6 > DataHeaderCnv::poolReadObject_p6 ( const Token * token )

Definition at line 432 of file DataHeaderCnv.cxx.

{
   void* voidPtr1 = nullptr;
   std::string error_message;
   try {
      m_athenaPoolCnvSvc->setObjPtr(voidPtr1, token);
   } catch(const std::exception& err) {
      voidPtr1 = nullptr;
      error_message = err.what();
   }
   if (voidPtr1 == nullptr) {
      throw std::runtime_error("Could not get object for token = " + token->toString() + ", " + error_message);
   }
   std::unique_ptr<DataHeader_p6> header( reinterpret_cast<DataHeader_p6*>(voidPtr1) );
 
   std::string dhFormToken =  header->dhFormToken();
   Token formToken;
   if( !dhFormToken.empty() and dhFormToken.find("[OID=") == std::string::npos) {
      // OneForm format of Form Ref (without OID)
      // we need to reconstruct the real Ref before checking in the Ref cache
      Placement dhf_placement;
      dhf_placement.fromString( dhFormToken );
      formToken.setDb( token->dbID() );
      formToken.setCont( dhf_placement.containerName() );
      formToken.setTechnology( dhf_placement.technology() );
      formToken.setAuxString( dhf_placement.auxString() );
      formToken.setClassID( DHForm_p6_Guid );
      std::int64_t oid2 =  token->oid().second;
      oid2 >>= 32; oid2 <<= 32;
      std::string swn = getSWNFromStr( dhFormToken );
      // add the row number from the SHForm Ref
      if( !swn.empty() ) oid2 += std::stoul( swn ) - 1;
      formToken.setOid( {0,oid2} );
      ATH_MSG_DEBUG("Constructed DHForm Ref=" << formToken.toString() << " from " << dhFormToken );
      dhFormToken = formToken.toString();
      header->setDhFormToken( dhFormToken );
   }
   // see if the DataHeaderForm is already cached
   if( dhFormToken.empty() || m_inputDHForms.find(dhFormToken) == m_inputDHForms.end() ) {
      // no cached DHForm
      size_t dbpos = dhFormToken.find("[DB=");
      if( dbpos != std::string::npos ) {
         const std::string dbGuid = dhFormToken.substr(dbpos+4, dbpos+36);
         if( ++m_inDHFormCount[dbGuid] > m_inDHFMapMaxsize ) {
            // prevent the input DHFMap from growing too large
            clearInputDHFormCache( dbGuid );
            m_inDHFormCount[dbGuid] = 1;
         }
      }
      // we need to read a new DHF
      void* voidPtr2 = nullptr;
      if( dhFormToken.empty() ) {
         // Some technologies can't set DHF token, use DH token with new CLID.
         token->setData(&formToken);
         formToken.setClassID( DHForm_p6_Guid );
      } else {
         formToken.fromString( dhFormToken );
         formToken.setAuxString( token->auxString() );  // set PersSvc context
      }
      if (formToken.classID() != Guid::null()) {
         try {
            m_athenaPoolCnvSvc->setObjPtr(voidPtr2, &formToken);
         } catch(const std::exception& err) {
            voidPtr2 = nullptr;
            error_message = err.what();
         }
         if (voidPtr2 == nullptr) {
            // if there is no good lastGoodDHFRef then try reading DataHeaderForm Token from the first DataHeader
            if( m_lastGoodDHFRef.find(token->contID()) == m_lastGoodDHFRef.end() ) {
               Token firstToken;
               token->setData(&firstToken);
               firstToken.setOid(Token::OID_t(firstToken.oid().first, 0));
               void* firstPtr1 = nullptr;
               try {
                  m_athenaPoolCnvSvc->setObjPtr(firstPtr1, &firstToken);
               } catch(const std::exception& err) {
                  firstPtr1 = nullptr;
                  error_message = err.what();
               }
               if (firstPtr1 == nullptr) throw std::runtime_error("Could not get first DataHeader for token = " + firstToken.toString() + ", " + error_message);
 
               // Get DataHeaderForm Token from the first DataHeader
               std::unique_ptr<DataHeader_p6> firstHeader( reinterpret_cast<DataHeader_p6*>(firstPtr1) );
               dhFormToken = firstHeader->dhFormToken();
 
               // Read DataHeaderForm and insert it to the cache
               formToken.fromString( dhFormToken );
               formToken.setAuxString( token->auxString() );  // set PersSvc context
               try {
                  m_athenaPoolCnvSvc->setObjPtr(voidPtr2, &formToken);
               } catch(const std::exception& err) {
                  voidPtr2 = nullptr;
                  error_message = err.what();
               }
               if (voidPtr2 == nullptr) throw std::runtime_error("Could not get DataHeaderForm for token = " + formToken.toString() + ", " + error_message);
               m_lastGoodDHFRef[token->contID()] = dhFormToken;
               m_inputDHForms[dhFormToken].reset( reinterpret_cast<DataHeaderForm_p6*>(voidPtr2) );
               ATH_MSG_WARNING("DataHeaderForm read exception: " << error_message << " - reusing the last good DHForm");
            } else {
               // try to reuse the last good DHForm Ref (object is already cached)
               ATH_MSG_WARNING("DataHeaderForm read exception: " << error_message << " - reusing the last good DHForm");
            }
            header->setDhFormToken(m_lastGoodDHFRef[token->contID()]);
            return header;
         }
         if (voidPtr2 == nullptr) {
            throw std::runtime_error("Could not get object for token = " + formToken.toString());
         }
         m_lastGoodDHFRef[token->contID()] = dhFormToken;
      }
      m_inputDHForms[dhFormToken].reset( reinterpret_cast<DataHeaderForm_p6*>(voidPtr2) );
   }
   return header;
}

◆ PoolToDataObject()

virtual StatusCode T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::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.

◆ poolToObject()

StatusCode T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::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.

◆ removeBadElements()

void DataHeaderCnv::removeBadElements ( DataHeader * dh )

Remove DataHeaderElements with incomplete (dbID="") refs.

Definition at line 554 of file DataHeaderCnv.cxx.

{
   auto iter = dh->m_inputDataHeader.begin();
   while( iter != dh->m_inputDataHeader.end() ) {
      if( iter->getToken()->dbID() == Guid::null() ) {
         ATH_MSG_WARNING("Removed incomplete Input Element");
         iter = dh->m_inputDataHeader.erase(iter);
      } else {
         ++iter;
      }
   }
}

◆ repSvcType()

long AthenaPoolConverter::repSvcType ( ) const

overridevirtualinherited

Definition at line 50 of file AthenaPoolConverter.cxx.

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

◆ selectTracks() [1/2]

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

inlineinherited

Definition at line 120 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/2]

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

inlineinherited

Definition at line 54 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++;
    }
    
  }

◆ 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 108 of file AthMessaging.cxx.

{
  m_lvl = lvl;
}

◆ setPlacement()

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

protectedvirtualinherited

Set POOL placement.

◆ setPlacementForP()

Placement T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::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 100 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 71 of file AthenaPoolConverter.cxx.

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

◆ tracks()

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

inlineinherited

Definition at line 48 of file Converter.h.

48{return m_tracks;}

◆ transToPers()

virtual StatusCode T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::transToPers	(	DataHeader *	,
		DataHeader_p6 *&	)

inlineoverrideprotectedvirtualinherited

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

Definition at line 95 of file T_AthenaPoolCustomCnv.h.

95{ return(StatusCode::FAILURE); }

◆ updateRep()

StatusCode DataHeaderCnv::updateRep	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject )

overridevirtual

Extend base-class conversion methods.

Definition at line 215 of file DataHeaderCnv.cxx.

{
   auto dataHeader = reinterpret_cast<DataHeader_p6*>( pObject );
   const std::string dhRef = pAddress->par()[0];
   const std::string dhPlacementStr = pAddress->par()[1];
   const std::string dhFile = getFILEFromStr( dhPlacementStr );
   Placement dhFormPlacement;
   dhFormPlacement.fromString( dataHeader->dhFormToken() );
   dhFormPlacement.setFileName( dhFile );
   const std::string clientN = getSWNFromStr( dhPlacementStr );
   if( !clientN.empty() ) {
      // Client num in the DHForm ref means it's OneDataHeaderForm mode
      std::string dhFormNewRef = dhFormPlacement.toString() + storeSWNInStr( clientN );
      ATH_MSG_DEBUG("Setting DH formRef to: " << dhFormNewRef);
      dataHeader->setDhFormToken( dhFormNewRef );
   } else {
      /* DH is received by the SharedWriter first and needs the DHForm object both for
         reference (Token) and to add DHElem with the ref to itself.
         These updates will be handled by updateRepRefs() - cache the DH info so it can
         by used later by updateRepRefs
      */
       if( m_sharedWriterCachedDH ) {
         ATH_MSG_ERROR( "updateRep called but the previous DataHeader was not yet processed."
                         << " cached DH Key=" << m_sharedWriterCachedDHKey
                         << " cached DH Ref=" << m_sharedWriterCachedDHToken );
         return StatusCode::FAILURE;
      }
      // remember this DH and finish processing in updateRepRefs()
      m_sharedWriterCachedDH = dataHeader;
      m_sharedWriterCachedDHToken = std::move(dhRef);
      std::size_t tagBeg = dhPlacementStr.find("[KEY=") + 5;
      std::size_t tagSize = dhPlacementStr.find(']', tagBeg) - tagBeg;
      m_sharedWriterCachedDHKey = dhPlacementStr.substr( tagBeg, tagSize );
   }
   return StatusCode::SUCCESS;
}

◆ updateRepRefs()

StatusCode DataHeaderCnv::updateRepRefs	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject )

overridevirtual

Definition at line 253 of file DataHeaderCnv.cxx.

{
   if( m_sharedWriterCachedDH ) {
      /* Attach a DHForm to the previous DataHeader (in SharedWriter server mode)
         Finish writing of the DataHeader by attaching the DHForm to it and by adding
         the self reference. DHForm is passed as pObject and is cached until a new one
         arrives. This method is called for each event after the DH is received.
         pObject is null if there is no new DHForm for this event - in this case the old
         one is used
      */
      std::string dhid = pAddress->par()[1];
      if( pObject ) {
         Token poolToken;
     poolToken.fromString( pAddress->par()[0] );
     if( !compareClassGuid(&poolToken,  DHForm_p6_Guid ) ) {
            ATH_MSG_ERROR( "updateRepRefs called without DataHeaderForm" );
            return StatusCode::FAILURE;
         }
         // replace the old DHForm
         // will keep this DHForm  until a new one arrives 
         m_sharedWriterCachedDHForm[dhid].reset( reinterpret_cast<DataHeaderForm_p6*>( pObject ) );
         m_sharedWriterCachedDHForm[dhid]->setToken( pAddress->par()[0] );
      }
      if( m_sharedWriterCachedDHForm.find(dhid) == m_sharedWriterCachedDHForm.end() ) {
         ATH_MSG_ERROR( "updateRepRefs: missing DataHeaderForm for DH ID=" << dhid );
         return StatusCode::FAILURE;
      }
      // update the cached DataHeader (can be done until a commit is called)
      m_sharedWriterCachedDH->setDhFormToken( m_sharedWriterCachedDHForm[dhid]->getToken() );
      m_tpOutConverter.insertDHRef( m_sharedWriterCachedDH, m_sharedWriterCachedDHKey,
                                    m_sharedWriterCachedDHToken, *m_sharedWriterCachedDHForm[dhid] );
      // this DataHeader object is now fully processed, so forget it
      m_sharedWriterCachedDH = nullptr;
   }
   else {
      // In OneDataHeaderForm mode - keep the DHForms from all clients and write them out at the end
      m_persFormMap[ pAddress->par()[1] ].reset( reinterpret_cast<DataHeaderForm_p6*>( pObject ) );
   }
   return(StatusCode::SUCCESS);
}

◆ CnvFactory< DataHeaderCnv >

friend class CnvFactory< DataHeaderCnv >

friend

Definition at line 32 of file DataHeaderCnv.h.

Member Data Documentation

◆ ATLAS_THREAD_SAFE

std::atomic_flag m_initialized AthMessaging::ATLAS_THREAD_SAFE

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_beamX

double Converter::m_beamX

protectedinherited

Definition at line 263 of file Converter.h.

◆ m_beamY

double Converter::m_beamY

protectedinherited

Definition at line 263 of file Converter.h.

◆ m_beamZ

double Converter::m_beamZ

protectedinherited

Definition at line 263 of file Converter.h.

◆ m_classDesc

RootType T_AthenaPoolCnvBase< DataHeader >::m_classDesc

protectedinherited

Definition at line 58 of file T_AthenaPoolCnvBase.h.

◆ m_classDescs

ClassMap T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::m_classDescs

privateinherited

Definition at line 87 of file T_AthenaPoolCustCnv.h.

◆ m_className

std::string T_AthenaPoolCustCnv< DataHeader, DataHeader_p6 >::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_dhFormMdx

std::string DataHeaderCnv::m_dhFormMdx

protected

Definition at line 91 of file DataHeaderCnv.h.

◆ m_dhFormType

RootType DataHeaderCnv::m_dhFormType

protected

cached shape of the DataHeaderForm_pN

Definition at line 71 of file DataHeaderCnv.h.

◆ m_dhInForm5

std::unique_ptr<DataHeaderForm_p5> DataHeaderCnv::m_dhInForm5

protected

Definition at line 90 of file DataHeaderCnv.h.

◆ m_imsg

std::atomic<IMessageSvc*> AthMessaging::m_imsg

mutableprivateinherited

MessageSvc pointer.

Definition at line 135 of file AthMessaging.h.

135{ nullptr };

◆ m_inDHFMapMaxsize

unsigned DataHeaderCnv::m_inDHFMapMaxsize {}

protected

Max DHForms to cache per input file.

Definition at line 84 of file DataHeaderCnv.h.

84{};

◆ m_inDHFormCount

std::map<std::string, unsigned> DataHeaderCnv::m_inDHFormCount

protected

How many DHForms for an input file are in the cache.

Definition at line 82 of file DataHeaderCnv.h.

◆ m_inputDHForms

std::map<std::string, std::unique_ptr<DataHeaderForm_p6> > DataHeaderCnv::m_inputDHForms

protected

DHForm cache indexed by the DHForm reference (from DataHeader) that was used to read it.

Definition at line 79 of file DataHeaderCnv.h.

◆ m_lastGoodDHFRef

std::map< std::string, std::string> DataHeaderCnv::m_lastGoodDHFRef

protected

Definition at line 86 of file DataHeaderCnv.h.

◆ m_lvl

std::atomic<MSG::Level> AthMessaging::m_lvl

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_oneDHForm

bool DataHeaderCnv::m_oneDHForm = true

protected

if true write only one DataHeaderForm at the end (stop, finalize, or WriteDataHeaderForms incident) the value is read from AthenaPoolCnvSvc OneDataHeaderForm property

Definition at line 74 of file DataHeaderCnv.h.

◆ m_persFormMap

std::map<std::string, std::unique_ptr<DataHeaderForm_p6>, placementComp > DataHeaderCnv::m_persFormMap

protected

Definition at line 77 of file DataHeaderCnv.h.

◆ m_persObjLists

SG::SlotSpecificObj<PersObjCache_t, SG::InvalidSlot::Enabled> T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::m_persObjLists

protectedinherited

Definition at line 117 of file T_AthenaPoolCustomCnv.h.

◆ m_pListMutex

std::mutex T_AthenaPoolCustomCnvWithKey< DataHeader, DataHeader_p6 >::m_pListMutex

protectedinherited

protection mutex for m_persObjLists

Definition at line 120 of file T_AthenaPoolCustomCnv.h.

◆ m_poolSvc

ServiceHandle<IPoolSvc> DataHeaderCnv::m_poolSvc {"PoolSvc", "DataHeaderCnv"}

protected

Definition at line 99 of file DataHeaderCnv.h.

99{"PoolSvc", "DataHeaderCnv"};

◆ m_sharedWriterCachedDH

DataHeader_p6* DataHeaderCnv::m_sharedWriterCachedDH = nullptr

protected

cached values for use with SharedWriter server

Definition at line 94 of file DataHeaderCnv.h.

◆ m_sharedWriterCachedDHForm

std::map< std::string, std::unique_ptr<DataHeaderForm_p6> > DataHeaderCnv::m_sharedWriterCachedDHForm

protected

map of cached DHForms for DataHeader ID

Definition at line 96 of file DataHeaderCnv.h.

◆ m_sharedWriterCachedDHKey

std::string DataHeaderCnv::m_sharedWriterCachedDHKey

protected

Definition at line 97 of file DataHeaderCnv.h.

◆ m_sharedWriterCachedDHToken

std::string DataHeaderCnv::m_sharedWriterCachedDHToken

protected

Definition at line 98 of file DataHeaderCnv.h.

◆ m_tpInConverter

DataHeaderCnv_p6 DataHeaderCnv::m_tpInConverter

protected

Definition at line 68 of file DataHeaderCnv.h.

◆ m_tpInConverter_p5

DataHeaderCnv_p5 DataHeaderCnv::m_tpInConverter_p5

protected

for use when reading DataHeader_p5

Definition at line 89 of file DataHeaderCnv.h.

◆ m_tpOutConverter

DataHeaderCnv_p6 DataHeaderCnv::m_tpOutConverter

protected

Definition at line 67 of file DataHeaderCnv.h.

◆ m_tracks

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

protectedinherited

Definition at line 264 of file Converter.h.

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

Classes

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

◆ DataHeaderCnv()

◆ ~DataHeaderCnv()

Member Function Documentation

◆ addTrack()

◆ classID()

◆ cleanUp()

◆ clear()

◆ clearInputDHFormCache()

◆ compareClassGuid()

◆ createObj()

◆ createPersistent() [1/2]

◆ createPersistent() [2/2]

◆ createPersistentWithKey() [1/2]

◆ createPersistentWithKey() [2/2]

◆ createRep()

◆ createTransient()

◆ createTransientWithKey()

◆ DataObjectToPool()

◆ detStore()

◆ fillRepRefs()

◆ finalize()

◆ handle()

◆ initialize()

◆ initMessaging()

◆ ipCorr()

◆ keepPoolObj() [1/2]

◆ keepPoolObj() [2/2]

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ objectToPool()

◆ persToTrans()

◆ phiCorr()

◆ poolReadObject() [1/2]

◆ poolReadObject() [2/2]

◆ poolReadObject_p5()

◆ poolReadObject_p6()

◆ PoolToDataObject()

◆ poolToObject()

◆ removeBadElements()

◆ repSvcType()

◆ selectTracks() [1/2]

◆ selectTracks() [2/2]

◆ setLevel()

◆ setPlacement()

◆ setPlacementForP()

◆ setPlacementWithType()

◆ storageType()

◆ tracks()

◆ transToPers()

◆ updateRep()

◆ updateRepRefs()

Friends And Related Symbol Documentation

◆ CnvFactory< DataHeaderCnv >

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_athenaPoolCnvSvc

◆ m_beamX

◆ m_beamY

◆ m_beamZ

◆ m_classDesc

◆ m_classDescs