| The Gaudi Framework v29r1 (5cd95fa2)

- Main Page
- Related Pages
- Modules
- Namespaces
- Classes
- Files

- File List
- File Members

PoolTool.h
Go to the documentation of this file.
1 #include "RootCnv/PoolClasses.h"
2 #include <algorithm>
3 /*
4 * Gaudi namespace declaration
5 */
6 namespace Gaudi
7 {
8
18 class PoolTool : virtual public RootDataConnection::Tool
19 {
21 std::vector<Gaudi::RootRef> m_poolLinks;
22
23 public:
25 PoolTool( RootDataConnection* con ) { c = con; }
26
28 string _treeName( string t )
29 {
30 std::replace( std::begin( t ), std::end( t ), '/', '_' );
31 return t;
32 }
33
34 RootRef poolRef( size_t i ) const override { return m_poolLinks[i]; }
35
37 int loadRefs( CSTR /* section */, CSTR cnt, unsigned long entry, RootObjectRefs& refs ) override
38 {
39 TTree* t = sections()[cnt];
40 if ( !t ) {
41 t = (TTree*)c->file()->Get( _treeName( cnt ).c_str() );
42 }
43 if ( t ) {
44 TBranch* b1 = t->GetBranch( "Links" );
45 TBranch* b2 = t->GetBranch( "Refs" );
46 MsgStream& msg = msgSvc();
47 if ( b1 && b2 ) {
48 LinkManager lm, *plm = &lm;
49 PoolDbLinkManager mgr, *pmgr = &mgr;
50 b1->SetAutoDelete( kFALSE );
51 b2->SetAutoDelete( kFALSE );
52 b1->SetAddress( &plm );
53 b2->SetAddress( &pmgr );
54 int nb1 = b1->GetEvent( entry );
55 int nb2 = b2->GetEvent( entry );
56 if ( nb1 > 1 && nb2 > 1 ) {
57 size_t ref_size = mgr.references().size();
58 refs.refs.resize( ref_size );
59 msg << MSG::VERBOSE;
60 for ( size_t j = 0; j < ref_size; ++j ) {
61 const pair<int, int>& oid = mgr.references()[j]->m_oid;
62 string loc = mgr.links()[j].substr( 1 );
63 RootRef& r = refs.refs[j];
64 if ( oid.first >= 0 ) {
65 r = m_poolLinks[oid.first];
66 r.entry = oid.second;
67 r.link = c->makeLink( loc );
68 msg << "Add leaf:" << oid.first << "->" << loc << " from " << c->getDb( r.dbase ) << "#"
69 << c->getCont( r.container ) << " Link:" << c->getLink( r.link ) << " CLID:" << hex << r.clid
70 << " Typ:" << hex << int( r.svc ) << " Ent:" << dec << r.entry << endl;
71 }
72 }
73 for ( int i = 0, n = lm.size(); i < n; ++i ) {
74 LinkManager::Link* lnk = lm.link( i );
75 int link_id = c->makeLink( lnk->path() );
76 msg << "Add Link:" << lnk->path() << endl;
77 refs.links.push_back( link_id );
78 }
79 return nb1 + nb2;
80 }
81 }
82 msg << MSG::ERROR << "Failed to access POOL Ref/Link branches:" << cnt << " [" << _treeName( cnt ) << "]"
83 << endmsg;
84 t->Print();
85 }
86 return -1;
87 }
88
90 TBranch* getBranch( CSTR /* section */, CSTR branch_name ) override
91 {
92 TTree* t = sections()[branch_name];
93 if ( t ) {
94 return (TBranch*)t->GetListOfBranches()->At( 0 );
95 }
96 string tname = _treeName( branch_name );
97 t = (TTree*)c->file()->Get( tname.c_str() ); // c->getSection(tname);
98 if ( t ) {
99 TBranch* b = (TBranch*)t->GetListOfBranches()->At( 0 );
100 if ( b ) {
101 sections()[branch_name] = t;
102 return b;
103 }
104 msgSvc() << MSG::ERROR << "Failed to access POOL branch:" << branch_name << " [" << tname << "]" << endmsg;
105 t->Print();
106 }
107 return nullptr;
108 }
109
111 StatusCode saveRefs() override { return StatusCode::FAILURE; }
112
114 StatusCode readRefs() override
115 {
116 int i;
117 char text[2048];
118 msgSvc() << MSG::VERBOSE;
119
120 // First read ##Params
121 TTree* t = (TTree*)c->file()->Get( "##Params" );
122 if ( !t ) return StatusCode::FAILURE;
123 TBranch* b = t->GetBranch( "db_string" );
124 if ( !b ) return StatusCode::FAILURE;
125 for ( i = 0, b->SetAddress( text ); i < b->GetEntries(); ++i ) {
126 b->GetEvent( i );
127 char* id1 = strstr( text, "[NAME=" );
128 char* id2 = strstr( text, "[VALUE=" );
129 if ( id1 && id2 ) {
130 id1 += 6;
131 id2 += 7;
132 char* id11 = strstr( id1, "]" );
133 char* id22 = strstr( id2, "]" );
134 if ( id11 && id22 ) {
135 *id11 = 0;
136 *id22 = 0;
137 params().emplace_back( id1, id2 );
138 msgSvc() << "Param:" << id1 << "=" << id2 << "." << endmsg;
139 }
140 }
141 }
142
143 // Read ##Links
144 t = (TTree*)c->file()->Get( "##Links" );
145 if ( !t ) return StatusCode::FAILURE;
146 b = t->GetBranch( "db_string" );
147 if ( !b ) return StatusCode::FAILURE;
148 m_poolLinks.resize( (size_t)b->GetEntries() + 2 ); // Take into account the ##Links and ##Shapes entry of POOL!
149 for ( i = 0, b->SetAddress( text ); i < b->GetEntries(); ++i ) {
150 b->GetEvent( i );
151 std::string db, container;
152 int clid = 1, technology = 0, ipar[2] = {-1, -1};
153 for ( char* p1 = (char*)text; p1; p1 = ::strchr( ++p1, '[' ) ) {
154 char* p2 = ::strchr( p1, '=' );
155 char* p3 = ::strchr( p1, ']' );
156 if ( p2 && p3 ) {
157 if (::strncmp( "[DB=", p1, 4 ) == 0 ) {
158 *p3 = 0;
159 db = p1 + 4;
160 } else if (::strncmp( "[CNT=", p1, 5 ) == 0 ) {
161 *p3 = 0;
162 container = p1 + 5;
163 } else if (::strncmp( "[OID=", p1, 5 ) == 0 ) {
164 *p3 = 0;
165 ::sscanf( p1 + 5, "%08X,%08X", (unsigned int*)&ipar[0], (unsigned int*)&ipar[1] );
166 } else if (::strncmp( "[CLID=", p1, 6 ) == 0 ) {
167 *p3 = 0;
168 ::sscanf( p1 + 6, "%08X", (unsigned int*)&clid );
169 } else if (::strncmp( "[TECH=", p1, 6 ) == 0 ) {
170 *p3 = 0;
171 ::sscanf( p1 + 6, "%08X", (unsigned int*)&technology );
172 } else {
173 *p3 = *p2 = 0;
174 }
175 *p3 = ']';
176 *p2 = '=';
177 }
178 }
179 c->makeRef( "", clid, technology, db, container, -1, m_poolLinks[i + 2] );
180 RootRef& r = m_poolLinks[i];
181 msgSvc() << "Add link[" << i << "]:" << db << container << " [" << r.dbase << "," << r.container << "] "
182 << " tech:" << hex << setw( 8 ) << r.svc << " CLID:" << setw( 8 ) << r.clid << dec << endmsg;
183 }
184 return StatusCode::SUCCESS;
185 }
186 };
187 }
LinkManager::Link::path
const std::string & path() const
Access to path of object.
Definition: LinkManager.h:66
MsgStream
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
StatusCode::SUCCESS
Definition: StatusCode.h:31
StatusCode::FAILURE
Definition: StatusCode.h:31
Gaudi::PoolTool::saveRefs
StatusCode saveRefs() override
Save references section when closing data file (NOT SUPPORTED)
Definition: PoolTool.h:111
Gaudi::RootDataConnection::file
TFile * file() const
Direct access to TFile structure.
Definition: RootDataConnection.h:249
Gaudi::RootDataConnection::getDb
const std::string & getDb(int which) const
Access database/file name from saved index.
Definition: RootDataConnection.cpp:450
Gaudi::PoolTool::poolRef
RootRef poolRef(size_t i) const override
Internal overload to facilitate the access to POOL files.
Definition: PoolTool.h:34
PoolDbLinkManager::references
std::vector< pool::Token * > & references()
Access to token array.
Definition: PoolClasses.h:117
Gaudi::PoolTool::m_poolLinks
std::vector< Gaudi::RootRef > m_poolLinks
Image of the POOL ##Links table.
Definition: PoolTool.h:21
MSG::dec
MsgStream & dec(MsgStream &log)
Definition: MsgStream.h:299
PoolClasses.h
Gaudi::RootRef::container
int container
Definition: RootRefs.h:33
Gaudi::RootDataConnection::getLink
const std::string & getLink(int which) const
Access link name from saved index.
Definition: RootDataConnection.h:336
std::end
T end(T...args)
Gaudi::RootObjectRefs::refs
std::vector< RootRef > refs
The references corresponding to the next layer of items in the data store.
Definition: RootRefs.h:64
Gaudi::RootRef::entry
int entry
Definition: RootRefs.h:33
MSG::hex
MsgStream & hex(MsgStream &log)
Definition: MsgStream.h:304
MSG::VERBOSE
Definition: IMessageSvc.h:16
Gaudi::PoolTool::loadRefs
int loadRefs(CSTR, CSTR cnt, unsigned long entry, RootObjectRefs &refs) override
Load references object from file.
Definition: PoolTool.h:37
Gaudi::RootObjectRefs
Persistent reference object containing all leafs and links corresponding to a Gaudi DataObject...
Definition: RootRefs.h:60
std::vector::resize
T resize(T...args)
std::string
STL class.
Gaudi::RootDataConnection::Tool::params
ParamMap & params() const
Definition: RootDataConnection.h:214
GaudiPluginService.cpluginsvc.n
n
Definition: cpluginsvc.py:228
Gaudi::RootRef::dbase
int dbase
Data members to define object location in the persistent world.
Definition: RootRefs.h:33
PoolDbLinkManager::links
std::vector< std::string > & links()
Access to link array.
Definition: PoolClasses.h:119
Gaudi::RootRef
Persistent reference object.
Definition: RootRefs.h:31
std::vector::push_back
T push_back(T...args)
Gaudi::PoolTool::getBranch
TBranch * getBranch(CSTR, CSTR branch_name) override
Access data branch by name: Get existing branch in read only mode.
Definition: PoolTool.h:90
HiveAlgSequencer.p2
p2
Definition: HiveAlgSequencer.py:23
Gaudi::PoolTool::PoolTool
PoolTool(RootDataConnection *con)
Standard constructor.
Definition: PoolTool.h:25
Gaudi::RootDataConnection::Tool::sections
Sections & sections() const
Definition: RootDataConnection.h:217
std::replace
T replace(T...args)
PoolDbLinkManager
Description: PoolDbLinkManager class implementation definition.
Definition: PoolClasses.h:100
Gaudi::RootDataConnection::Tool
Helper class to facilitate an abstraction layer for reading POOL style files with this package...
Definition: RootDataConnection.h:195
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
Gaudi::RootDataConnection::makeRef
void makeRef(IRegistry *pA, RootRef &ref)
Create reference object from registry entry.
Definition: RootDataConnection.cpp:605
LinkManager::link
Link * link(long id)
Retrieve symbolic link identified by ID.
Definition: LinkManager.cpp:31
Gaudi::RootDataConnection::Tool::msgSvc
MsgStream & msgSvc() const
Definition: RootDataConnection.h:215
Gaudi::RootDataConnection::getCont
const std::string & getCont(int which) const
Access container name from saved index.
Definition: RootDataConnection.h:330
Gaudi::RootRef::clid
int clid
Definition: RootRefs.h:33
Gaudi::RootObjectRefs::links
std::vector< int > links
The links of the link manager.
Definition: RootRefs.h:62
std::vector::size
T size(T...args)
std::vector< Gaudi::RootRef >
Gaudi::RootDataConnection::makeLink
int makeLink(const std::string &p)
Convert path string to path index.
Definition: RootDataConnection.cpp:441
Gaudi::RootRef::link
int link
Definition: RootRefs.h:33
Gaudi::RootDataConnection::Tool::refs
TTree * refs() const
Definition: RootDataConnection.h:210
std::begin
T begin(T...args)
GaudiMP.FdsRegistry.msg
msg
Definition: FdsRegistry.py:8
HiveAlgSequencer.p1
p1
Definition: HiveAlgSequencer.py:22
Gaudi::PoolTool::_treeName
string _treeName(string t)
Convert TES object identifier to ROOT tree name.
Definition: PoolTool.h:28
MSG::ERROR
Definition: IMessageSvc.h:16
Gaudi::RootDataConnection::Tool::c
RootDataConnection * c
Pointer to containing data connection object.
Definition: RootDataConnection.h:207
Gaudi::RootRef::svc
int svc
Definition: RootRefs.h:33
Gaudi::PoolTool::readRefs
StatusCode readRefs() override
Internal helper to read reference tables ##Params and ##Links.
Definition: PoolTool.h:114
LinkManager::Link
Embedded class defining a symbolic link Note: No copy constructor; bitwise copy (done by the compiler...
Definition: LinkManager.h:32
Gaudi::RootDataConnection
Concrete implementation of the IDataConnection interface to access ROOT files.
Definition: RootDataConnection.h:94
LinkManager
A LinkManager is the object aggregated into a DataObject, which is responsible for the handling of no...
Definition: LinkManager.h:21
Gaudi
Helper functions to set/get the application return code.
Definition: __init__.py:1
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
LinkManager::size
long size() const
Retrieve number of link present.
Definition: LinkManager.h:105
Gaudi::PoolTool
Definition: PoolTool.h:18
std::vector::emplace_back
T emplace_back(T...args)