TStore.cxx

Go to the documentation of this file.

// Copyright (C) 2002-2023 CERN for the benefit of the ATLAS collaboration
 
#include <set>
 
// ROOT include(s):
#include <TError.h>
#include <TClass.h>
 
// EDM include(s):
#include "AthContainers/normalizedTypeinfoName.h"
#include "CxxUtils/checker_macros.h"
#include "CxxUtils/ConcurrentStrMap.h"
#include "CxxUtils/SimpleUpdater.h"
 
// Local include(s):
#include "xAODRootAccess/TStore.h"
#include "xAODRootAccess/TActiveStore.h"
#include "xAODRootAccess/tools/THolder.h"
#include "xAODRootAccess/tools/Message.h"
#include "xAODRootAccess/tools/Utils.h"
 
namespace xAOD {
 
   TStore::TStore()
      : m_objects(), m_keys() {
 
      setActive();
   }
 
   TStore::~TStore() {
 
      // Clear the store before being deleted:
      clear();
 
      // If this object is set up as the active store at the moment,
      // notify the active store object that this object will no longer
      // be available.
      if( TActiveStore::store() == this ) {
         TActiveStore::setStore( nullptr );
      }
   }
 
   void TStore::setActive() {
 
      TActiveStore::setStore( this );
      return;
   }
 
 
   const THolder* TStore::holder( const std::string& key ) const {
      // Look up this object:
      Objects_t::const_iterator itr = m_objects.find( key );
      return (itr != m_objects.end() ? itr->second : nullptr);
   }
 
 
   StatusCode TStore::remove( const std::string& key ) {
 
      // Look up this object:
      Objects_t::iterator itr = m_objects.find( key );
      if( itr == m_objects.end() ) {
         ::Warning( "xAOD::TStore::remove",
                    "Couldn't find object with key \"%s\"",
                    key.c_str() );
         return StatusCode::RECOVERABLE;
      }
 
      // Delete the hoder object:
      delete itr->second;
 
      // Now remove this element from the maps:
      m_objects.erase( itr );
      m_keys.erase( Utils::hash( key ) );
 
      // We were successful:
      return StatusCode::SUCCESS;
   }
 
   StatusCode TStore::remove( void* ptr ) {
 
      // Look for this object:
      Objects_t::iterator itr = m_objects.begin();
      Objects_t::iterator end = m_objects.end();
      for( ; itr != end; ++itr ) {
 
         // Check if this is the object in question:
         if( itr->second->get() != ptr ) {
            continue;
         }
 
         // Yes, it is...
         delete itr->second;
         m_keys.erase( Utils::hash( itr->first ) );
         m_objects.erase( itr );
         return StatusCode::SUCCESS;
      }
 
      // We didn't find the object in the store:
      ::Warning( "xAOD::TStore::remove",
                 "Couldn't find object with pointer %p",
                 ptr );
      return StatusCode::RECOVERABLE;
   }
 
   void TStore::clear() {
 
      // Delete all the managed objects:
      Objects_t::iterator itr = m_objects.begin();
      Objects_t::iterator end = m_objects.end();
      for( ; itr != end; ++itr ) {
         delete itr->second;
      }
 
      // And clear the maps:
      m_objects.clear();
      m_keys.clear();
 
      return;
   }
 
   void TStore::print() const {
 
      ::Info( "xAOD::TStore::print", "Contents of transient store:" );
      Objects_t::const_iterator itr = m_objects.begin();
      Objects_t::const_iterator end = m_objects.end();
      for( ; itr != end; ++itr ) {
         ::Info( "xAOD::TStore::print", "-----------------------------------" );
         ::Info( "xAOD::TStore::print", "  Name: %s", itr->first.c_str() );
         const ::TClass* cl = itr->second->getClass();
         const std::type_info* ti = itr->second->getTypeInfo();
         ::Info( "xAOD::TStore::print", "    Type: %s",
                 ( cl ? cl->GetName() :
                   ( ti ? SG::normalizedTypeinfoName( *ti ).c_str() :
                     "Unknown" ) ) );
         ::Info( "xAOD::TStore::print", "    Pointer: %p",
                 itr->second->get() );
         ::Info( "xAOD::TStore::print", "    IsOwner: %s",
                 ( itr->second->isOwner() ? "Yes" : "No" ) );
         ::Info( "xAOD::TStore::print", "    IsConst: %s",
                 ( itr->second->isConst() ? "Yes" : "No" ) );
         ::Info( "xAOD::TStore::print", "    HasDictionary: %s",
                 ( cl ? "Yes" : "No" ) );
      }
      ::Info( "xAOD::TStore::print", "-----------------------------------" );
 
      return;
   }
 
   ::Bool_t TStore::contains( const std::string& key,
                              const std::type_info& ti ) const {
 
      // Look up this object:
      Objects_t::const_iterator itr = m_objects.find( key );
      if( itr == m_objects.end() ) {
         return kFALSE;
      }
 
      // Check if the object is of the right type:
      return itr->second->getAsConst( ti, kTRUE );
   }
 
   ::Bool_t TStore::isConst( const std::string& key,
                             const std::type_info& ti ) const {
 
      // Look up this object:
      Objects_t::const_iterator itr = m_objects.find( key );
      if( itr == m_objects.end() ) {
         ::Warning( "xAOD::TStore::isConst",
                    "Object with key \"%s\" not available in store",
                    key.c_str() );
         return kFALSE;
      }
 
      // Check if it can even be retrieved as a constant object of this type:
      if( ! itr->second->getAsConst( ti, kTRUE ) ) {
         const std::string typeName = SG::normalizedTypeinfoName( ti );
         ::Warning( "xAOD::TStore::isConst",
                    "Object with key \"%s\" can't be retrieved as type: %s",
                    key.c_str(), typeName.c_str() );
         return kFALSE;
      }
 
      // Now the question is just whether it can be retrieved as a non-const
      // object as well:
      return ( ! itr->second->getAs( ti, kTRUE ) );
   }
 
   void* TStore::getObject( const std::string& key,
                            const std::type_info& ti ) const {
 
      // Look up this object:
      Objects_t::const_iterator itr = m_objects.find( key );
      if( itr == m_objects.end() ) {
         return 0;
      }
 
      if( itr->second->isConst() ) {
         ::Error( "xAOD::TStore::getObject",
                  XAOD_MESSAGE( "Cannot retrieve object with key \"%s\" of type %s as non-const" ),
                  key.c_str(), SG::normalizedTypeinfoName( ti ).c_str() );
         return nullptr;
      }
 
      // Try to retrieve it as the requested type:
      return itr->second->getAs( ti );
   }
 
   const void* TStore::getConstObject( const std::string& key,
                                       const std::type_info& ti ) const {
 
      // Look up this object:
      Objects_t::const_iterator itr = m_objects.find( key );
      if( itr == m_objects.end() ) {
         return 0;
      }
 
      // Try to retrieve it as the requested type:
      return itr->second->getAsConst( ti );
   }
 
   StatusCode TStore::record( void* obj, const std::string& key,
                              const std::string& classname,
                              ::Bool_t isOwner, ::Bool_t isConst ) {
 
      // Cache
      using clCache_t = CxxUtils::ConcurrentStrMap<::TClass*, CxxUtils::SimpleUpdater>;
      static clCache_t clMap ATLAS_THREAD_SAFE {clCache_t::Updater_t()};
 
      // First check if we have this dictionary cached already:
      ::TClass* cl = 0;
      auto clItr = clMap.find( classname );
      if( clItr != clMap.end() ) {
         // If the cached value doesn't work, then bail now:
         if( ( ! clItr->second ) || ( ! clItr->second->IsLoaded() ) ) {
            return StatusCode::RECOVERABLE;
         }
         // Otherwise we're done:
         cl = clItr->second;
      }
 
      // If it's not cached, ask ROOT for it:
      if( ! cl ) {
         cl = ::TClass::GetClass( classname.c_str(), kTRUE, kTRUE );
         clMap.emplace( classname, cl );
      }
      if( ( ! cl ) || ( ! cl->IsLoaded() ) ) {
         return StatusCode::RECOVERABLE;
      }
 
      // Make sure that the key is not yet taken:
      if( m_objects.find( key ) != m_objects.end() ) {
         ::Error( "xAOD::TStore::record",
                  XAOD_MESSAGE( "Trying to overwrite object with key \"%s\"" ),
                  key.c_str() );
         return StatusCode::FAILURE;
      }
 
      // Register the new object:
      if( isConst )
         m_objects[ key ] = new THolder( const_cast<const void*>(obj), cl, isOwner );
      else
         m_objects[ key ] = new THolder( obj, cl, isOwner);
 
      m_keys[ Utils::hash( key ) ] = key;
      return StatusCode::SUCCESS;
   }
 
   StatusCode TStore::record( void* obj, const std::string& key,
                              const std::type_info& ti,
                              ::Bool_t isOwner, ::Bool_t isConst ) {
 
      // Make sure that the key is not yet taken:
      if( m_objects.find( key ) != m_objects.end() ) {
         ::Error( "xAOD::TStore::record",
                  XAOD_MESSAGE( "Trying to overwrite object with key \"%s\"" ),
                  key.c_str() );
         return StatusCode::FAILURE;
      }
 
      // Register the new object:
      if( isConst )
         m_objects[ key ] = new THolder( const_cast<const void*>(obj), ti, isOwner );
      else
         m_objects[ key ] = new THolder( obj, ti, isOwner );
 
      m_keys[ Utils::hash( key ) ] = key;
      return StatusCode::SUCCESS;
   }
 
   StatusCode TStore::record( THolder* hldr, const std::string& key ) {
 
      // Make sure that the key is not yet taken:
      if( m_objects.find( key ) != m_objects.end() ) {
         ::Error( "xAOD::TStore::record",
                  XAOD_MESSAGE( "Trying to overwrite object with key \"%s\"" ),
                  key.c_str() );
         // We delete the holder object at this point. It's quite ugly in terms
         // of code readibility, but it results in fewer characters in the
         // template code...
         delete hldr;
         return StatusCode::FAILURE;
      }
 
      // Register the new object:
      m_objects[ key ] = hldr;
      m_keys[ Utils::hash( key ) ] = key;
      return StatusCode::SUCCESS;
   }
 
   ::Bool_t TStore::contains( SG::sgkey_t hash ) const {
 
      // Do the check quickly:
      return ( m_keys.find( hash ) != m_keys.end() );
   }
 
   ::Bool_t TStore::contains( const void* ptr ) const {
 
      // Loop over all the managed objects:
      Objects_t::const_iterator itr = m_objects.begin();
      Objects_t::const_iterator end = m_objects.end();
      for( ; itr != end; ++itr ) {
         // Check if this is the right object:
         if( itr->second->get() == ptr ) {
            return kTRUE;
         }
      }
 
      // We didn't find it:
      return kFALSE;
   }
 
   const std::string& TStore::getName( SG::sgkey_t hash ) const {
 
      // Try to find the name associated with this key:
      HashedKeys_t::const_iterator itr = m_keys.find( hash );
      if( itr != m_keys.end() ) {
         // We found it:
         return itr->second;
      }
 
      // We didn't find it:
      ::Warning( "xAOD::TStore::getName", "Key 0x%08x not known by the store",
                 hash );
      static const std::string dummy( "" );
      return dummy;
   }
 
   const std::string& TStore::getName( const void* ptr ) const {
 
      // Loop over all the managed objects:
      Objects_t::const_iterator itr = m_objects.begin();
      Objects_t::const_iterator end = m_objects.end();
      for( ; itr != end; ++itr ) {
         // Check if this is the right object:
         if( itr->second->get() == ptr ) {
            return itr->first;
         }
      }
      
      // We didn't find the object:
      ::Warning( "xAOD::TStore::getName", "Object %p is not held by the store",
                 ptr );
      static const std::string dummy( "" );
      return dummy;
   }
 
   void TStore::getNames( const std::string& targetTypeName,
                          std::vector< std::string >& vkeys ) const {
      std::set< std::string > keys;
 
      for ( const auto& pair : m_objects ) {
         const std::string& key = pair.first;
         const ::TClass* cl = pair.second->getClass();
         const std::type_info* ti = pair.second->getTypeInfo();
         std::string typeName;
         if (cl)
            typeName = cl->GetName();
         else if (ti)
            typeName = SG::normalizedTypeinfoName( *ti );
 
         if (!typeName.empty() && typeName == targetTypeName)
            keys.insert( key );
      }
 
      vkeys.insert( vkeys.end(), keys.begin(), keys.end() );
   }
 
} // namespace xAOD