Gaudi::PoolTool Class Reference

#include </builds/gaudi/Gaudi/RootCnv/src/PoolTool.h>

Inheritance diagram for Gaudi::PoolTool:

Collaboration diagram for Gaudi::PoolTool:

Public Member Functions
	PoolTool (RootDataConnection *con)
	Standard constructor.
string	_treeName (std::string_view sr)
	Convert TES object identifier to ROOT tree name.
RootRef	poolRef (size_t i) const override
	Internal overload to facilitate the access to POOL files.
int	loadRefs (std::string_view, std::string_view cnt, unsigned long entry, RootObjectRefs &refs) override
	Load references object from file.
TBranch *	getBranch (std::string_view, std::string_view branch_name) override
	Access data branch by name: Get existing branch in read only mode.
StatusCode	saveRefs () override
	Save references section when closing data file (NOT SUPPORTED)
StatusCode	readRefs () override
	Internal helper to read reference tables ##Params and ##Links.
Public Member Functions inherited from Gaudi::RootDataConnection::Tool
TTree *	refs () const
StringVec &	dbs () const
StringVec &	conts () const
StringVec &	links () const
ParamMap &	params () const
MsgStream &	msgSvc () const
IIncidentSvc *	incidentSvc () const
const std::string &	name () const
Sections &	sections () const
LinkSections &	linkSections () const
MergeSections &	mergeSections () const
virtual	~Tool ()=default
	Default destructor.

Private Attributes
std::vector< Gaudi::RootRef >	m_poolLinks
	Image of the POOL ##Links table.

Additional Inherited Members
Protected Types inherited from Gaudi::RootDataConnection::Tool
typedef RootDataConnection::StringVec	StringVec
typedef RootDataConnection::ParamMap	ParamMap
typedef RootDataConnection::Sections	Sections
typedef RootDataConnection::MergeSections	MergeSections
typedef RootDataConnection::LinkSections	LinkSections
typedef RootDataConnection::ContainerSection	ContainerSection
typedef RootDataConnection::ContainerSections	ContainerSections
Protected Attributes inherited from Gaudi::RootDataConnection::Tool
RootDataConnection *	c
	Pointer to containing data connection object.

Detailed Description

Definition at line 30 of file PoolTool.h.

Constructor & Destructor Documentation

PoolTool()

Gaudi::PoolTool::PoolTool ( RootDataConnection * con )

inline

Standard constructor.

Definition at line 36 of file PoolTool.h.

{ c = con; }

Member Function Documentation

_treeName()

string Gaudi::PoolTool::_treeName ( std::string_view sr )

inline

Convert TES object identifier to ROOT tree name.

Definition at line 39 of file PoolTool.h.

                                          {
      std::string t{ sr };
      std::replace( begin( t ), end( t ), '/', '_' );
      return t;
    }

getBranch()

TBranch * Gaudi::PoolTool::getBranch ( std::string_view , std::string_view branch_name )

inlineoverridevirtual

Access data branch by name: Get existing branch in read only mode.

Implements Gaudi::RootDataConnection::Tool.

Definition at line 100 of file PoolTool.h.

                                                                                {
      auto   ti = sections().find( branch_name );
      TTree* t  = ( ti != sections().end() ? ti->second : nullptr );
      if ( t ) { return (TBranch*)t->GetListOfBranches()->At( 0 ); }
      string tname = _treeName( branch_name );
      t            = (TTree*)c->file()->Get( tname.c_str() ); // c->getSection(tname);
      if ( t ) {
        TBranch* b = (TBranch*)t->GetListOfBranches()->At( 0 );
        if ( b ) {
          sections()[std::string{ branch_name }] = t;
          return b;
        }
        incidentSvc()->fireIncident( Incident( c->pfn(), IncidentType::CorruptedInputFile ) );
        msgSvc() << MSG::ERROR << "Failed to access POOL branch:" << branch_name << " [" << tname << "]" << endmsg;
        t->Print();
      }
      return nullptr;
    }

loadRefs()

int Gaudi::PoolTool::loadRefs ( std::string_view , std::string_view cnt, unsigned long entry, RootObjectRefs & refs )

inlineoverridevirtual

Load references object from file.

Implements Gaudi::RootDataConnection::Tool.

Definition at line 48 of file PoolTool.h.

                                                  {
      auto   ti = sections().find( cnt );
      TTree* t  = ( ti != sections().end() ? ti->second : nullptr );
      if ( !t ) { t = (TTree*)c->file()->Get( _treeName( cnt ).c_str() ); }
      if ( t ) {
        TBranch*   b1  = t->GetBranch( "Links" );
        TBranch*   b2  = t->GetBranch( "Refs" );
        MsgStream& msg = msgSvc();
        if ( b1 && b2 ) {
          LinkManager       lm, *plm   = &lm;
          PoolDbLinkManager mgr, *pmgr = &mgr;
          b1->SetAutoDelete( kFALSE );
          b2->SetAutoDelete( kFALSE );
          b1->SetAddress( &plm );
          b2->SetAddress( &pmgr );
          int nb1 = b1->GetEvent( entry );
          int nb2 = b2->GetEvent( entry );
          if ( nb1 > 1 && nb2 > 1 ) {
            size_t ref_size = mgr.references().size();
            refs.refs.resize( ref_size );
            msg << MSG::VERBOSE;
            for ( size_t j = 0; j < ref_size; ++j ) {
              const pair<int, int>& oid = mgr.references()[j]->m_oid;
              string                loc = mgr.links()[j].substr( 1 );
              RootRef&              r   = refs.refs[j];
              if ( oid.first >= 0 ) {
                r       = m_poolLinks[oid.first];
                r.entry = oid.second;
                r.link  = c->makeLink( loc );
                msg << "Add leaf:" << oid.first << "->" << loc << " from " << c->getDb( r.dbase ) << "#"
                    << c->getCont( r.container ) << " Link:" << c->getLink( r.link ) << " CLID:" << hex << r.clid
                    << " Typ:" << hex << int( r.svc ) << " Ent:" << dec << r.entry << endl;
              }
            }
            for ( int i = 0, n = lm.size(); i < n; ++i ) {
              const LinkManager::Link* lnk     = lm.link( i );
              int                      link_id = c->makeLink( lnk->path() );
              msg << "Add Link:" << lnk->path() << endl;
              refs.links.push_back( link_id );
            }
            return nb1 + nb2;
          }
        }
        msg << MSG::ERROR << "Failed to access POOL Ref/Link branches:" << cnt << " [" << _treeName( cnt ) << "]"
            << endmsg;
        t->Print();
      }
      return -1;
    }

poolRef()

RootRef Gaudi::PoolTool::poolRef ( size_t ) const

inlineoverridevirtual

Internal overload to facilitate the access to POOL files.

Reimplemented from Gaudi::RootDataConnection::Tool.

Definition at line 45 of file PoolTool.h.

{ return m_poolLinks[i]; }

readRefs()

StatusCode Gaudi::PoolTool::readRefs ( )

inlineoverridevirtual

Internal helper to read reference tables ##Params and ##Links.

Implements Gaudi::RootDataConnection::Tool.

Definition at line 123 of file PoolTool.h.

                                   {
      int  i;
      char text[2048];
      msgSvc() << MSG::VERBOSE;
 
      // First read ##Params
      TTree* t = (TTree*)c->file()->Get( "##Params" );
      if ( !t ) return StatusCode::FAILURE;
      TBranch* b = t->GetBranch( "db_string" );
      if ( !b ) return StatusCode::FAILURE;
      for ( i = 0, b->SetAddress( text ); i < b->GetEntries(); ++i ) {
        b->GetEvent( i );
        char* id1 = strstr( text, "[NAME=" );
        char* id2 = strstr( text, "[VALUE=" );
        if ( id1 && id2 ) {
          id1 += 6;
          id2 += 7;
          char* id11 = strstr( id1, "]" );
          char* id22 = strstr( id2, "]" );
          if ( id11 && id22 ) {
            *id11 = 0;
            *id22 = 0;
            params().emplace_back( id1, id2 );
            msgSvc() << "Param:" << id1 << "=" << id2 << "." << endmsg;
          }
        }
      }
 
      // Read ##Links
      t = (TTree*)c->file()->Get( "##Links" );
      if ( !t ) return StatusCode::FAILURE;
      b = t->GetBranch( "db_string" );
      if ( !b ) return StatusCode::FAILURE;
      m_poolLinks.resize( (size_t)b->GetEntries() + 2 ); // Take into account the ##Links and ##Shapes entry of POOL!
      for ( i = 0, b->SetAddress( text ); i < b->GetEntries(); ++i ) {
        b->GetEvent( i );
        std::string db, container;
        int         clid = 1, technology = 0, ipar[2] = { -1, -1 };
        for ( char* p1 = (char*)text; p1; p1 = ::strchr( ++p1, '[' ) ) {
          char* p2 = ::strchr( p1, '=' );
          char* p3 = ::strchr( p1, ']' );
          if ( p2 && p3 ) {
            if ( ::strncmp( "[DB=", p1, 4 ) == 0 ) {
              *p3 = 0;
              db  = p1 + 4;
            } else if ( ::strncmp( "[CNT=", p1, 5 ) == 0 ) {
              *p3       = 0;
              container = p1 + 5;
            } else if ( ::strncmp( "[OID=", p1, 5 ) == 0 ) {
              *p3 = 0;
              ::sscanf( p1 + 5, "%08X,%08X", (unsigned int*)&ipar[0], (unsigned int*)&ipar[1] );
            } else if ( ::strncmp( "[CLID=", p1, 6 ) == 0 ) {
              *p3 = 0;
              ::sscanf( p1 + 6, "%08X", (unsigned int*)&clid );
            } else if ( ::strncmp( "[TECH=", p1, 6 ) == 0 ) {
              *p3 = 0;
              ::sscanf( p1 + 6, "%08X", (unsigned int*)&technology );
            } else {
              *p3 = *p2 = 0;
            }
            *p3 = ']';
            *p2 = '=';
          }
        }
        c->makeRef( "", clid, technology, db, container, -1, m_poolLinks[i + 2] );
        RootRef& r = m_poolLinks[i];
        msgSvc() << "Add link[" << i << "]:" << db << container << " [" << r.dbase << "," << r.container << "] "
                 << " tech:" << hex << setw( 8 ) << r.svc << " CLID:" << setw( 8 ) << r.clid << dec << endmsg;
      }
      return StatusCode::SUCCESS;
    }

saveRefs()

StatusCode Gaudi::PoolTool::saveRefs ( )

inlineoverridevirtual

Save references section when closing data file (NOT SUPPORTED)

Implements Gaudi::RootDataConnection::Tool.

Definition at line 120 of file PoolTool.h.

{ return StatusCode::FAILURE; }

Member Data Documentation

m_poolLinks

std::vector<Gaudi::RootRef> Gaudi::PoolTool::m_poolLinks

private

Image of the POOL ##Links table.

Definition at line 32 of file PoolTool.h.

---

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

• RootCnv/src/PoolTool.h