ATLAS Offline Software
Loading...
Searching...
No Matches
TileRawChannelContainerCnv Class Reference

#include <TileRawChannelContainerCnv.h>

Inheritance diagram for TileRawChannelContainerCnv:
Collaboration diagram for TileRawChannelContainerCnv:

Public Types

typedef T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERSBaseType

Public Member Functions

 TileRawChannelContainerCnv (ISvcLocator *svcloc)
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

TileRawChannelContainer_PERScreatePersistent (TileRawChannelContainer *transCont)
TileRawChannelContainercreateTransient (const Token *token)
virtual TileRawChannelContainer_PERScreatePersistentWithKey (TileRawChannelContainer *obj, const std::string &) override
 method to be implemented by the developer.
virtual TileRawChannelContainercreateTransientWithKey (const Token *token, const std::string &) override
 method to be implemented by the developer.
PpoolReadObject (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 (TileRawChannelContainer_PERS *obj, const std::string &output)
 Remember the POOL object to be written out (will be deleted after commit).
virtual StatusCode transToPers (TileRawChannelContainer *, TileRawChannelContainer_PERS *&) override
 Obsolete methods replaced by createPersistent() and createTransient() obsolete.
virtual StatusCode transToPers (TileRawChannelContainer *, TileRawChannelContainer_PERS *&) override
 Obsolete methods replaced by createPersistent() and createTransient() obsolete.
virtual StatusCode persToTrans (TileRawChannelContainer *&, TileRawChannelContainer_PERS *) override
 obsolete
virtual StatusCode persToTrans (TileRawChannelContainer *&, TileRawChannelContainer_PERS *) override
 obsolete
virtual StatusCode DataObjectToPool (IOpaqueAddress *pAddr, DataObject *pObj) override
 Write an object into POOL.
virtual StatusCode PoolToDataObject (DataObject *&pObj, const Token *token, const std::string &key) override
 Read an object from POOL.
virtual StatusCode cleanUp (const std::string &output) override
 Callback from the CleanupSvc to delete persistent object in the local list.
virtual StatusCode initialize ()
 Gaudi Service Interface method implementations:
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

SG::SlotSpecificObj< PersObjCache_t, SG::InvalidSlot::Enabledm_persObjLists
std::mutex m_pListMutex
 protection mutex for m_persObjLists
RootType m_classDesc
ServiceHandle< StoreGateSvcm_detStore
ServiceHandle< IAthenaPoolCnvSvcm_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, RootTypeClassMap

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

Detailed Description

Definition at line 14 of file TileRawChannelContainerCnv.h.

Member Typedef Documentation

◆ BaseType

◆ CallMutex

typedef std::mutex AthenaPoolConverter::CallMutex
protectedinherited

Definition at line 110 of file AthenaPoolConverter.h.

◆ ClassMap

typedef std::map<std::string, RootType> T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::ClassMap
privateinherited

Definition at line 90 of file T_AthenaPoolCustCnv.h.

◆ PersObjCache_t

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

◆ TileRawChannelContainerCnv()

TileRawChannelContainerCnv::TileRawChannelContainerCnv ( ISvcLocator * svcloc)
inline

Definition at line 17 of file TileRawChannelContainerCnv.h.

17 :
18 T_AthenaPoolCustomCnv<TileRawChannelContainer, TileRawChannelContainer_PERS >( svcloc) {}

Member Function Documentation

◆ addTrack()

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

Definition at line 43 of file Converter.h.

43 {
44 m_tracks.push_back(t);
45 }
Compatibility for old converter classes that don't get passed the key.

◆ classID()

Returns
class ID.

◆ cleanUp()

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TileRawChannelContainer, TileRawChannelContainer_PERS >::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();}

◆ compareClassGuid()

virtual bool T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::compareClassGuid ( const Token * token,
const Guid & clid ) const
protectedvirtualinherited

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

Parameters
clid[IN] GUID to compare
Returns
true if the type of the object about to be read matches the GUID

◆ createObj()

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

Create a transient object from a POOL persistent representation.

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

Definition at line 55 of file AthenaPoolConverter.cxx.

52 {
53 TokenAddress* tokAddr = dynamic_cast<TokenAddress*>(pAddr);
54
55 bool ownTokAddr = false;
56 if (tokAddr == nullptr || tokAddr->getToken() == nullptr) {
57 ownTokAddr = true;
59 token->fromString(*(pAddr->par()));
60 GenericAddress* genAddr = dynamic_cast<GenericAddress*>(pAddr);
61 if (not genAddr){
62 ATH_MSG_ERROR("Dynamic cast failed in AthenaPoolConverter::createObj");
63 //clean up
65 }
67 }
68 if( tokAddr->ipar()[0] > 0 and tokAddr->getToken()->auxString().empty() ) {
69 tokAddr->getToken()->setAuxString(CxxUtils::HexString<"[CTXT={}]">(static_cast<int>(*(pAddr->ipar()))));
70 }
71 ATH_MSG_VERBOSE("createObj: " << tokAddr->getToken()->toString() << ", CTX=" << tokAddr->ipar()[0]
72 << ", auxStr=" << tokAddr->getToken()->auxString() );
73 try {
74 std::string key = pAddr->par()[1];
75 if (!PoolToDataObject(pObj, tokAddr->getToken(), key).isSuccess()) {
76 ATH_MSG_ERROR("createObj PoolToDataObject() failed, Token = " << (tokAddr->getToken() ? tokAddr->getToken()->toString() : "NULL"));
77 pObj = nullptr;
78 }
79 } catch (std::exception& e) {
80 ATH_MSG_ERROR("createObj - caught exception: " << e.what());
81 pObj = nullptr;
82 }
83 if (pObj == nullptr) {
84 ATH_MSG_ERROR("createObj failed to get DataObject, Token = " << (tokAddr->getToken() ? tokAddr->getToken()->toString() : "NULL"));
85 }
86 if (ownTokAddr) {
87 delete tokAddr; tokAddr = nullptr;
88 }
89 if (pObj == nullptr) {
91 }
93}
#define ATH_MSG_ERROR(x)
#define ATH_MSG_VERBOSE(x)
virtual StatusCode PoolToDataObject(DataObject *&pObj, const Token *token, const std::string &key) override

◆ createPersistent()

TileRawChannelContainer_PERS * TileRawChannelContainerCnv::createPersistent ( TileRawChannelContainer * transCont)
protectedvirtual

Implements T_AthenaPoolCustomCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >.

Definition at line 10 of file TileRawChannelContainerCnv.cxx.

10 {
11 MsgStream mlog(msgSvc(), "TileRawChannelContainerConverter" );
13 TileRawChannelContainer_PERS *persObj = converter.createPersistent( transCont, mlog );
14 return persObj;
15}
TileRawChannelContainer_p1 TileRawChannelContainer_PERS
T_TilePoolContainerCnv< TileRawChannelContainer, TileRawChannelContainer_p1, TileRawChannelCnv_p1 > TileRawChannelContainerCnv_p1
virtual PERS * createPersistent(const TRANS *transObj, MsgStream &log)

◆ createPersistentWithKey()

virtual TileRawChannelContainer_PERS * T_AthenaPoolCustomCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::createPersistentWithKey ( TileRawChannelContainer * 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)

Implements T_AthenaPoolCustomCnvWithKey< TileRawChannelContainer, TileRawChannelContainer_PERS >.

◆ createRep()

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

Create a POOL persistent representation for a transient object.

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

Definition at line 60 of file AthenaPoolConverter.cxx.

95 {
96 const SG::DataProxy* proxy = dynamic_cast<SG::DataProxy*>(pObj->registry());
97 if (proxy == nullptr) {
98 ATH_MSG_ERROR("AthenaPoolConverter CreateRep failed to cast DataProxy, key = " << pObj->name());
100 }
101 const CLID clid = proxy->clID();
102 if (pAddr == nullptr) {
103 // Create a IOpaqueAddress for this object.
104 pAddr = new TokenAddress(this->storageType(), clid, "", "", 0, 0);
105 } else {
106 GenericAddress* gAddr = dynamic_cast<GenericAddress*>(pAddr);
107 if (gAddr != nullptr) {
108 gAddr->setSvcType(this->storageType());
109 }
110 }
111 return StatusCode::SUCCESS;
112}

◆ createTransient()

TileRawChannelContainer * TileRawChannelContainerCnv::createTransient ( const Token * token)
protectedvirtual

Implements T_AthenaPoolCustomCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >.

Definition at line 17 of file TileRawChannelContainerCnv.cxx.

17 {
18 MsgStream mlog(msgSvc(), "TileRawChannelContainerConverter" );
20
21 TileRawChannelContainer *trans_cont(0);
22
23 static const pool::Guid p1_guid("BF727F06-9F94-4989-9C1F-9E59023988EA");
24 static const pool::Guid p0_guid("E18095F6-01D9-4E8B-AD51-A8628F92E7FF");
25
26 if( this->compareClassGuid(token, p1_guid)) {
27 std::unique_ptr< TileRawChannelContainer_p1 > cont( this->poolReadObject< TileRawChannelContainer_p1 >(token) );
28 trans_cont = converter_p1.createTransient( cont.get(), mlog );
29 }
30 else if( this->compareClassGuid(token, p0_guid)) {
31 // old version from before TP separation
32 TileRawChannelCollectionVec* rdoV = this->poolReadObject<TileRawChannelCollectionVec>(token);
33 bool lDebug = (mlog.level()<=MSG::DEBUG);
34
35 if (lDebug)
36 mlog << MSG::DEBUG << "Read IDC, size " << rdoV->size() << endmsg;
37
38 // fixing bug with units in 13.0.20 - should be removed once all RDO files produced with 13.0.20 disappear
39 if (rdoV->m_type == 104) {
40 if (lDebug)
41 mlog << MSG::DEBUG << "fixing units bug in 13.0.20 RDO data: if (type=104) type=4;" << endmsg;
42 rdoV->m_type = (TileFragHash::TYPE)4;
43 }
44
45 int hashType = rdoV->m_type & 0xF;
46 int type = (rdoV->m_type >> 4) & 0xF;
47 int unit = (rdoV->m_type >> 8) & 0xF;
48 uint32_t bsflags = rdoV->m_type & 0xFFFFF000;
49
50 if (lDebug)
51 mlog << MSG::DEBUG << MSG::hex << "m_type=" << rdoV->m_type
52 << " " << bsflags << " " << unit << " " << type << " " << hashType << MSG::dec << endmsg;
53
54 // create the Tile IdentifiableContainer to contain the rdo collections
55 trans_cont = new TileRawChannelContainer(false,hashType,unit,SG::OWN_ELEMENTS);
56 if (type != 0) trans_cont->set_type((TileFragHash::TYPE)type);
57 trans_cont->set_bsflags(bsflags);
58
61
62 for (; it != last; ++it) {
63
64 TileRawChannelCollection* rdoColl = *it;
66
67 // register the rdo collection in StoreGate
68 TileRawChannelCollection::ID id_coll = rdoColl->identify();
69 StatusCode sc = trans_cont->addCollection(rdoColl,trans_cont->hashFunc()(id_coll));
70 if(sc.isFailure()) {
71 mlog << MSG::ERROR << "Can't add collection " << id_coll << " to container" << endmsg;
72 }
73 }
74 delete rdoV;
75 } else {
76 throw std::runtime_error("Unsupported persistent version of Data container");
77 }
78 return trans_cont;
79}
const PlainObject unit() const
This is a plugin that makes Eigen look like CLHEP & defines some convenience methods.
#define endmsg
static Double_t sc
Athena::TPCnvVers::Old Athena::TPCnvVers::Old Athena::TPCnvVers::Current Athena::TPCnvVers::Old Athena::TPCnvVers::Current TileRawChannelContainer
DataModel_detail::iterator< DataVector > iterator
Definition DataVector.h:842
const_iterator end() const noexcept
Return a const_iterator pointing past the end of the collection.
const_iterator begin() const noexcept
Return a const_iterator pointing at the beginning of the collection.
size_type size() const noexcept
Returns the number of elements in the collection.
virtual TRANS * createTransient(const PERS *persObj, MsgStream &log)
virtual bool compareClassGuid(const Token *token, const Guid &clid) const
TYPE
initialize
void setOwnership(SG::OwnershipPolicy ownPolicy)
::StatusCode StatusCode
StatusCode definition for legacy code.
@ OWN_ELEMENTS
this data object owns its elements
setEventNumber uint32_t

◆ createTransientWithKey()

virtual TileRawChannelContainer * T_AthenaPoolCustomCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::createTransientWithKey ( const Token * token,
const std::string &  )
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< TileRawChannelContainer, TileRawChannelContainer_PERS >.

◆ DataObjectToPool()

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TileRawChannelContainer, TileRawChannelContainer_PERS >::DataObjectToPool ( IOpaqueAddress * pAddr,
DataObject * pObj )
overrideprotectedvirtualinherited

Write an object into POOL.

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

◆ detStore()

Handle to DetectorStore.

Definition at line 68 of file AthenaPoolConverter.h.

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

114 {
115 try {
117 ATH_MSG_ERROR("FillRepRefs failed, key = " << pObj->name());
118 return StatusCode::FAILURE;
119 }
120 } catch (std::exception& e) {
121 ATH_MSG_ERROR("fillRepRefs - caught exception: " << e.what());
122 return StatusCode::FAILURE;
123 }
124 return StatusCode::SUCCESS;
125}
virtual StatusCode DataObjectToPool(IOpaqueAddress *pAddr, DataObject *pObj) override

◆ finalize()

StatusCode AthenaPoolConverter::finalize ( )
overridevirtualinherited

Definition at line 48 of file AthenaPoolConverter.cxx.

40 {
41 // Release AthenaPoolCnvSvc
42 if (!m_athenaPoolCnvSvc.release().isSuccess()) {
43 ATH_MSG_WARNING("Cannot release AthenaPoolCnvSvc.");
44 }
45 return(::Converter::finalize());
46}
#define ATH_MSG_WARNING(x)

◆ initialize()

virtual StatusCode T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::initialize ( void )
protectedvirtualinherited

Gaudi Service Interface method implementations:

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

40{
42 // If user did not set an explicit level, set a default
43 if (m_lvl == MSG::NIL) {
44 m_lvl = m_imsg ?
45 static_cast<MSG::Level>( m_imsg.load()->outputLevel(m_nm) ) :
46 MSG::INFO;
47 }
48}
IMessageSvc * getMessageSvc(bool quiet=false)

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

200 {
201
202 double sn = sin(phi0);
203 double cs = cos(phi0);
204 double sd0 = (d0 != 0 ? d0/fabs(d0) : 1);
205 double spt = (pt != 0 ? pt/fabs(pt) : 1);
206
207 if (fabs(pt) >= 1*CLHEP::TeV) {
208
209 d0c = d0 + m_beamX*sn - m_beamY*cs;
210
211 } else {
212
213 double rc = fabs(pt)*15.0/(9.0*1.042);
214
215 double xc = (fabs(d0)-spt*sd0*rc)*cos(phi0+M_PI/2*sd0) - m_beamX;
216 double yc = (fabs(d0)-spt*sd0*rc)*sin(phi0+M_PI/2*sd0) - m_beamY;
217
218 double newphi;
219 double xd01,yd01,xd02,yd02;
220
221 if (xc == 0) {
222 xd01 = 0; yd01 = rc+yc;
223 xd02 = 0; yd02 = -rc+yc;
224 } else {
225 xd01 = xc+yc/xc*yc+sqrt(pow((xc+yc/xc*yc),2)-xc*xc-yc*yc+rc*rc); yd01 = yc/xc*xd01;
226 xd02 = xc+yc/xc*yc-sqrt(pow((xc+yc/xc*yc),2)-xc*xc-yc*yc+rc*rc); yd02 = yc/xc*xd02;
227 }
228
229 double r1 = sqrt(xd01*xd01+yd01*yd01);
230 double r2 = sqrt(xd02*xd02+yd02*yd02);
231
232 double phiV;
233
234 if (r1 < r2)
235 phiV = atan2(yd01,xd01);
236 else
237 phiV = atan2(yd02,xd02);
238
239 double phi1 = phiCorr(phiV+M_PI/2);
240 double phi2 = phiCorr(phiV-M_PI/2);
241
243 newphi = phi1;
244 else
245 newphi = phi2;
246
248
249 double theta=2*atan2(exp(-eta),1);
250 double theta_save=theta;
251 theta = theta - (1+spt)/2*M_PI;
252 if (theta>0) theta = theta_save;
253
255 z0c = z0 + deltaz0;
256
257 }
258 }

◆ keepPoolObj()

void T_AthenaPoolCustomCnvWithKey< TileRawChannelContainer, TileRawChannelContainer_PERS >::keepPoolObj ( TileRawChannelContainer_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.

168{
169 MsgStream* ms = m_msg_tls.get();
170 if (!ms) {
171 if (!m_initialized.test_and_set()) initMessaging();
172 ms = new MsgStream(m_imsg,m_nm);
173 m_msg_tls.reset( ms );
174 }
175
176 ms->setLevel (m_lvl);
177 return *ms;
178}
void setLevel(MSG::Level lvl)
Change the current logging level.

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

◆ msgLvl()

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

Test the output level.

Parameters
lvlThe message level to test against
Returns
boolean Indicating if messages at given level will be printed
Return values
trueMessages at level "lvl" will be printed

Definition at line 86 of file AthMessaging.h.

152{
153 // If user did not set explicit message level we have to initialize
154 // the messaging and retrieve the default via the MessageSvc.
155 if (m_lvl==MSG::NIL && !m_initialized.test_and_set()) initMessaging();
156
157 if (m_lvl <= lvl) {
158 msg() << lvl;
159 return true;
160 } else {
161 return false;
162 }
163}

◆ objectToPool()

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

Write an object into POOL returning its token.

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

◆ persToTrans() [1/2]

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TileRawChannelContainer, TileRawChannelContainer_PERS >::persToTrans ( TileRawChannelContainer *& ,
TileRawChannelContainer_PERS *  )
inlineoverrideprotectedvirtualinherited

obsolete

Definition at line 97 of file T_AthenaPoolCustomCnv.h.

97{ return(StatusCode::FAILURE); }

◆ persToTrans() [2/2]

obsolete

Implements T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >.

Definition at line 97 of file T_AthenaPoolCustomCnv.h.

97{ return(StatusCode::FAILURE); }
This templated class extends T_AthenaPoolCustCnv to provide management of the persistent objects crea...

◆ phiCorr()

double Converter::phiCorr ( double phi)
inlineprotectedinherited

Definition at line 191 of file Converter.h.

191 {
192
193 if (phi < -TMath::Pi()) phi += 2*TMath::Pi();
194 if (phi > TMath::Pi()) phi -= 2*TMath::Pi();
195
196 return phi;
197 }

◆ poolReadObject() [1/2]

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< TileRawChannelContainer, TileRawChannelContainer_PERS >::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

◆ PoolToDataObject()

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

Read an object from POOL.

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

◆ poolToObject()

StatusCode T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::poolToObject ( const Token * token,
P *& pObj )
protectedinherited

Read an object from POOL.

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

◆ repSvcType()

long AthenaPoolConverter::repSvcType ( ) const
overridevirtualinherited

Definition at line 50 of file AthenaPoolConverter.cxx.

48 {
49 return pool::POOL_StorageType.type();
50}

◆ selectTracks() [1/2]

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

Definition at line 120 of file Converter.h.

120 {
121
122 static int hpmap[20] = { 0, 1, 2, 7, 8, 9, 3, 4, 5, 6, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 };
123
126
127 while(muonitr!=muonend) {
128
129 bool hasInDet = (*muonitr)->hasInDetTrackParticle();
131 if(hasInDet) trackitr=(*muonitr)->inDetTrackParticle();
132 muonitr++;
133 if(!hasInDet) continue;
134
135 const Trk::MeasuredPerigee* measPer = trackitr->measuredPerigee();
136
137 CLHEP::HepVector perigeeParams = measPer->parameters();
138 double pT = measPer->pT();
139 double eta = measPer->eta();
140 double phi = perigeeParams[Trk::phi0];
141 double z0 = perigeeParams[Trk::z0];
142 double d0 = perigeeParams[Trk::d0];
143 //double theta = perigeeParams[Trk::theta];
144
145 double deta = 1;
146 double dphi = 1;
147 double dz0 = 1;
148 double dd0 = 1;
149 double dpT = 1;
150
151 // Check number of hits
152 // NB: a spacepoint is two offline "hits", so a pixel spacepoint is really
153 // 2 "hits" and an offline SCT "hit" is really a 1D cluster, so two intersetcting
154 // stereo clusters making a spacepoint are two "hits"
155 const Trk::TrackSummary *summary = trackitr->trackSummary();
161
163
164 const Trk::FitQuality *quality = trackitr->fitQuality();
165 double chi2 = quality->chiSquared();
166 double dof = quality->quality->numberDoF();
167
168 unsigned bitmap = 0;
169
170 for ( int ih=0 ; ih<20 ; ih++ ) {
171 if ( summary->isHit(Trk::DetectorType(ih)) ) bitmap |= ( 1<<hpmap[ih] );
172 }
173
174 // Shift d0 and z0 according to beam position
175 ipCorr(d0, z0, d0, z0, phi, eta, pT);
176
177 // Create and save Track
178 TIDA::Track* t = new TIDA::Track(eta, phi, z0, d0, pT, chi2, dof,
179 deta, dphi, dz0, dd0, dpT,
182 -1) ;
183
184 addTrack(t);
185 }
186
187 }
void ipCorr(double d0, double z0, double &d0c, double &z0c, double phi0, double eta, double pt)
Definition Converter.h:200

◆ selectTracks() [2/2]

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

Definition at line 54 of file Converter.h.

54 {
55
58
59 static int hpmap[20] = { 0, 1, 2, 7, 8, 9, 3, 4, 5, 6, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 };
60
61 while ( trackitr!=trackend ) {
62
63 const Trk::MeasuredPerigee* measPer = (*trackitr)->measuredPerigee();
64
65 CLHEP::HepVector perigeeParams = measPer->parameters();
66 double pT = measPer->pT();
67 double eta = measPer->eta();
68 double phi = perigeeParams[Trk::phi0];
69 double z0 = perigeeParams[Trk::z0];
70 double d0 = perigeeParams[Trk::d0];
71 //double theta = perigeeParams[Trk::theta];
72
73 double deta = 1;
74 double dphi = 1;
75 double dz0 = 1;
76 double dd0 = 1;
77 double dpT = 1;
78
79 // Check number of hits
80 // NB: a spacepoint is two offline "hits", so a pixel spacepoint is really
81 // 2 "hits" and an offline SCT "hit" is really a 1D cluster, so two intersetcting
82 // stereo clusters making a spacepoint are two "hits"
83 const Trk::TrackSummary *summary = (*trackitr)->trackSummary();
90 bool expectBL = false; // Not stored for Rec::TrackParticle
91
92 const Trk::FitQuality *quality = (*trackitr)->fitQuality();
93 double chi2 = quality->chiSquared();
94 double dof = quality->numberDoF();
95
96 unsigned bitmap = 0;
97
98 for ( int ih=0 ; ih<20 ; ih++ ) {
99 if ( summary->isHit(Trk::DetectorType(ih)) ) bitmap |= ( 1<<hpmap[ih] );
100 }
101
102 // Shift d0 and z0 according to beam position
103 ipCorr(d0, z0, d0, z0, phi, eta, pT);
104
105 // Create and save Track
106 TIDA::Track* t = new TIDA::Track(eta, phi, z0, d0, pT, chi2, dof,
107 deta, dphi, dz0, dd0, dpT,
110 -1,
111 expectBL) ;
112
113 addTrack(t);
114 trackitr++;
115 }
116
117 }

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

29{
30 m_lvl = lvl;
31}

◆ setPlacement()

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

Set POOL placement.

◆ setPlacementForP()

Placement T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::setPlacementForP ( P & p,
const std::string & key,
const std::string & output )
protectedinherited

Set POOL placement for type P.

◆ setPlacementWithType()

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

Set POOL placement hint for a given type.

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

Definition at line 100 of file AthenaPoolConverter.cxx.

140 {
141 // Resulting placement
143
144 // Extract the file name and global technology (if available)
147 placement.setFileName(outputConnectionSpec);
148
149 // Override streaming parameters from StreamTool if requested.
156 while (pos1 != std::string::npos) {
157 const std::string::size_type pos2 = output.find('=', pos1);
158 const std::string thisKey = output.substr(pos1 + 1, pos2 - pos1 - 1);
159 const std::string::size_type pos3 = output.find(']', pos2);
160 const std::string value = output.substr(pos2 + 1, pos3 - pos2 - 1);
161 if (thisKey == "OutputCollection") {
163 } else if (thisKey == "PoolContainerPrefix") {
165 } else if (thisKey == "TopLevelContainerName") {
167 } else if (thisKey == "SubLevelBranchName") {
169 } else if (thisKey == "PoolContainerFriendPostfix") {
171 }
172 pos1 = output.find('[', pos3);
173 }
174
175 // Extract the technology from the container prefix (if available)
176 if (auto colonPost = containerPrefix.find(':'); colonPost != std::string::npos) {
177 placement.setTechnology(pool::DbType::getType(containerPrefix.substr(0, colonPost)).type());
178 containerPrefix.erase(0, colonPost + 1); // Note that DataHeader and EventTag bypass this...
179 }
180
181 // --- Special types: DataHeader & Form
182 if ( tname.starts_with(APRDefaults::DataHeaderTypeName) ) {
183 containerName = std::format("{}{}({}{})",
185 tname.starts_with(APRDefaults::DataHeaderFormTypeName) ? "Form" : "",
186 key.back() == '/' ? key : "",
187 tname);
188 }
189 // AttributeList - writing attributes separately to EventTag container group
190 else if ( tname.starts_with(APRDefaults::EventTagTypeName) ) {
191 containerName = std::format("{}({})",
193 key);
194 }
195 // all other object types
196 else {
197 constexpr std::string_view typeTok = "<type>", keyTok = "<key>";
198 containerName = std::format("{}{}{}{}",
202 branchNameHint.empty() ? "" : std::format("({})", branchNameHint));
203 if (auto pos = containerName.find(typeTok); pos != std::string::npos) {
204 containerName.replace(pos, typeTok.size(), tname);
205 }
206 if (auto pos = containerName.find(keyTok); pos != std::string::npos) {
207 containerName.replace(pos, keyTok.size(), key.empty() ? tname : key);
208 }
209 }
210
211 // Set the container name
212 placement.setContainerName(containerName);
213 return(placement);
214}
const char * getEventDataName()
const char * getDataHeaderName()

◆ storageType()

long AthenaPoolConverter::storageType ( )
staticinherited
Returns
storage type.

Definition at line 71 of file AthenaPoolConverter.cxx.

127 {
128 return pool::POOL_StorageType.type();
129}

◆ tracks()

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

Definition at line 48 of file Converter.h.

48{return m_tracks;}

◆ transToPers() [1/2]

virtual StatusCode T_AthenaPoolCustomCnvWithKey< TileRawChannelContainer, TileRawChannelContainer_PERS >::transToPers ( TileRawChannelContainer * ,
TileRawChannelContainer_PERS *&  )
inlineoverrideprotectedvirtualinherited

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

Definition at line 95 of file T_AthenaPoolCustomCnv.h.

95{ return(StatusCode::FAILURE); }

◆ transToPers() [2/2]

◆ CnvFactory< TileRawChannelContainerCnv >

friend class CnvFactory< TileRawChannelContainerCnv >
friend

Definition at line 12 of file TileRawChannelContainerCnv.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

◆ 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< TileRawChannelContainer >::m_classDesc
protectedinherited

Definition at line 58 of file T_AthenaPoolCnvBase.h.

◆ m_classDescs

Definition at line 91 of file T_AthenaPoolCustCnv.h.

◆ m_className

std::string T_AthenaPoolCustCnv< TileRawChannelContainer, TileRawChannelContainer_PERS >::m_className
privateinherited

Definition at line 88 of file T_AthenaPoolCustCnv.h.

◆ m_conv_mut

Definition at line 111 of file AthenaPoolConverter.h.

◆ m_detStore

Definition at line 107 of file AthenaPoolConverter.h.

◆ m_imsg

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

MessageSvc pointer.

Definition at line 135 of file AthMessaging.h.

135{ nullptr };

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

◆ m_pListMutex

protection mutex for m_persObjLists

Definition at line 120 of file T_AthenaPoolCustomCnv.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: