SGTest::TestStore Class Reference

#include <TestStore.h>

Inheritance diagram for SGTest::TestStore:

Collaboration diagram for SGTest::TestStore:

Public Types
typedef std::unordered_map< const void *, SG::DataProxy * >	tmap_t
typedef SG::SGKeyMap< SG::DataProxy * >	kmap_t
typedef std::unordered_map< TestStoreRemap, TestStoreRemap, TestStoreRemapHash >	remap_t
typedef std::mutex	mutex_t
typedef std::lock_guard< mutex_t >	lock_t

Public Member Functions
virtual std::vector< const SG::DataProxy * >	proxies () const override
virtual const std::string *	keyToString (sgkey_t) const override
virtual void	registerKey (sgkey_t, const std::string &, CLID) override
virtual const std::string &	name () const override
virtual SG::DataProxy *	proxy (const void *const pTransient) const override
virtual SG::DataProxy *	proxy (const CLID &id, const std::string &key) const override
virtual SG::DataProxy *	proxy_exact (SG::sgkey_t sgkey) const override
virtual sgkey_t	stringToKey (const std::string &str, CLID clid) override
virtual const std::string *	keyToString (sgkey_t key, CLID &clid) const override
virtual bool	tryELRemap (sgkey_t sgkey_in, size_t index_in, sgkey_t &sgkey_out, size_t &index_out) override
virtual StatusCode	addToStore (CLID, SG::DataProxy *proxy) override
virtual void	boundHandle (IResetable *handle) override
virtual void	unboundHandle (IResetable *handle) override
virtual SG::DataProxy *	recordObject (SG::DataObjectSharedPtr< DataObject > obj, const std::string &key, bool allowMods, bool returnExisting) override
template<class T>
void	record (const T *p, const std::string &key)
template<class T>
void	record (std::unique_ptr< T > up, const std::string &key)
void	remap (sgkey_t sgkey_in, sgkey_t sgkey_out, size_t index_in=0, size_t index_out=0)
template<class T>
void	remap (const std::string &key_in, const std::string &key_out, size_t index_in=0, size_t index_out=0)
void	alias (SG::DataProxy *proxy, const std::string &newKey)
SG::DataProxy *	proxy (lock_t &, const void *const pTransient) const
SG::DataProxy *	proxy (lock_t &, const CLID &id, const std::string &key) const
SG::DataProxy *	record1 (lock_t &, const void *p, DataObject *obj, CLID clid, const std::string &key)

Public Attributes
tmap_t	m_tmap
kmap_t	m_kmap
remap_t	m_remap
SG::StringPool m_stringPool	ATLAS_THREAD_SAFE
std::vector< IResetable * >	m_boundHandles
std::vector< std::pair< CLID, std::string > > m_missedProxies	ATLAS_THREAD_SAFE
mutex_t	m_mutex

Detailed Description

Definition at line 50 of file TestStore.h.

Member Typedef Documentation

kmap_t

typedef SG::SGKeyMap<SG::DataProxy*> SGTest::TestStore::kmap_t

Definition at line 121 of file TestStore.h.

lock_t

typedef std::lock_guard<mutex_t> SGTest::TestStore::lock_t

Definition at line 135 of file TestStore.h.

mutex_t

typedef std::mutex SGTest::TestStore::mutex_t

Definition at line 134 of file TestStore.h.

remap_t

typedef std::unordered_map<TestStoreRemap, TestStoreRemap, TestStoreRemapHash> SGTest::TestStore::remap_t

Definition at line 124 of file TestStore.h.

tmap_t

typedef std::unordered_map<const void*, SG::DataProxy*> SGTest::TestStore::tmap_t

Definition at line 118 of file TestStore.h.

Member Function Documentation

addToStore()

StatusCode SGTest::TestStore::addToStore ( CLID , SG::DataProxy * proxy )

overridevirtual

Definition at line 176 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  proxy->setStore (this);
  m_kmap[proxy->sgkey()] = proxy;
  proxy->addRef();
  return StatusCode::SUCCESS;
}

alias()

void SGTest::TestStore::alias	(	SG::DataProxy *	proxy,
		const std::string &	newKey )

Definition at line 236 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  sgkey_t sgkey = m_stringPool.stringToKey (newKey, proxy->clID());
  m_kmap[sgkey] = proxy;
  proxy->addRef();
  proxy->setAlias (newKey);
}

boundHandle()

void SGTest::TestStore::boundHandle ( IResetable * handle )

overridevirtual

Definition at line 186 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  m_boundHandles.push_back (handle);
}

keyToString() [1/2]

const std::string * SGTest::TestStore::keyToString ( sgkey_t key, CLID & clid ) const

overridevirtual

Definition at line 157 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  return m_stringPool.keyToString (key, clid);
}

keyToString() [2/2]

const std::string * SGTest::TestStore::keyToString ( sgkey_t key ) const

overridevirtual

Definition at line 32 of file TestStore.cxx.

{
  return m_stringPool.keyToString (key);
}

name()

const std::string & SGTest::TestStore::name ( ) const

overridevirtual

Definition at line 97 of file TestStore.cxx.

{
  static const std::string nm = "TestStore";
  return nm;
}

proxies()

std::vector< const SG::DataProxy * > SGTest::TestStore::proxies ( ) const

overridevirtual

Definition at line 26 of file TestStore.cxx.

{
  std::cout << "proxies\n"; std::abort();
}

proxy() [1/4]

SG::DataProxy * SGTest::TestStore::proxy ( const CLID & id, const std::string & key ) const

overridevirtual

Definition at line 121 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  return proxy (lock, id, key);
}

proxy() [2/4]

SG::DataProxy * SGTest::TestStore::proxy ( const void *const pTransient ) const

overridevirtual

Definition at line 104 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  return proxy (lock, pTransient);
}

proxy() [3/4]

SG::DataProxy * SGTest::TestStore::proxy	(	lock_t &	,
		const CLID &	id,
		const std::string &	key ) const

Definition at line 129 of file TestStore.cxx.

{
  sgkey_t sgkey = m_stringPool.stringToKey (key, id);
  kmap_t::const_iterator i = m_kmap.find (sgkey);
  if (i != m_kmap.end())
    return i->second;
  m_missedProxies.emplace_back (id, key);
  return 0;
}

proxy() [4/4]

SG::DataProxy * SGTest::TestStore::proxy	(	lock_t &	,
		const void *const	pTransient ) const

Definition at line 112 of file TestStore.cxx.

{ 
  tmap_t::const_iterator i = m_tmap.find (pTransient);
  if (i != m_tmap.end())
    return i->second;
  return 0;
}

proxy_exact()

SG::DataProxy * SGTest::TestStore::proxy_exact ( SG::sgkey_t sgkey ) const

overridevirtual

Definition at line 140 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  kmap_t::const_iterator i = m_kmap.find (sgkey);
  if (i != m_kmap.end())
    return i->second;
  return 0;
}

record() [1/2]

template<class T>

void SGTest::TestStore::record ( const T * p, const std::string & key )

inline

Definition at line 81 of file TestStore.h.

  {
    lock_t lock (m_mutex);
    T* p_nc ATLAS_THREAD_SAFE = const_cast<T*>(p);
    DataObject* obj = SG::asStorable<T>(p_nc);
    CLID clid = ClassID_traits<T>::ID();
    record1 (lock, p, obj, clid, key);
  }

record() [2/2]

template<class T>

void SGTest::TestStore::record ( std::unique_ptr< T > up, const std::string & key )

inline

Definition at line 92 of file TestStore.h.

  {
    lock_t lock (m_mutex);
    T* p = up.get();
    DataObject* obj = SG::asStorable<T>(std::move (up));
    CLID clid = ClassID_traits<T>::ID();
    record1 (lock, p, obj, clid, key);
  }

record1()

SG::DataProxy * SGTest::TestStore::record1	(	lock_t &	,
		const void *	p,
		DataObject *	obj,
		CLID	clid,
		const std::string &	key )

Definition at line 203 of file TestStore.cxx.

{
  sgkey_t sgkey = m_stringPool.stringToKey (key, clid);
  if (m_kmap.find (sgkey) != m_kmap.end()) {
    SG::DataProxy* dp = m_kmap[sgkey];
    dp->setObject (obj);
    if (dp->clID() == CLID_NULL)
      dp->setID (clid, key);
    m_tmap[p] = dp;
    return dp;
  }
 
  SG::DataProxy* dp = new SG::DataProxy(obj, SG::TransientAddress(clid, key));
  dp->setStore (this);
  m_tmap[p] = dp;
 
  m_kmap[sgkey] = dp;
  dp->addRef();
  dp->setSGKey (sgkey);
  return dp;
}

recordObject()

SG::DataProxy * SGTest::TestStore::recordObject ( SG::DataObjectSharedPtr< DataObject > obj, const std::string & key, bool allowMods, bool returnExisting )

overridevirtual

Definition at line 46 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  const void* raw_ptr = obj.get();
  if (DataBucketBase* bucket = dynamic_cast<DataBucketBase*> (obj.get())) {
    raw_ptr = bucket->object();
  }
 
  CLID clid = obj->clID();
  SG::DataProxy* proxy = this->proxy (lock, clid, key);
  if (proxy) {
    if (returnExisting)
      return proxy;
    else
      return nullptr;
  }
 
  proxy = this->proxy (lock, raw_ptr);
  if (proxy) {
    sgkey_t sgkey = m_stringPool.stringToKey (key, obj->clID());
    if (!returnExisting)
      return nullptr;
    if (obj->clID() == proxy->clID()) {
      // Alias?
      m_kmap[sgkey] = proxy;
      proxy->addRef();
      proxy->setAlias (key);
      return proxy;
    }
    if (key == proxy->name()) {
      // Symlink?
      m_kmap[sgkey] = proxy;
      proxy->addRef();
      proxy->setTransientID (obj->clID());
      return proxy;
    }
 
    // Error.
    return nullptr;
  }
  
  proxy = record1 (lock, raw_ptr, obj.get(), clid, key);
  if (!allowMods)
    proxy->setConst();
  return proxy;
}

registerKey()

void SGTest::TestStore::registerKey ( sgkey_t , const std::string & , CLID  )

overridevirtual

Definition at line 38 of file TestStore.cxx.

{
  std::cout << "registerKey\n"; std::abort();
}

remap() [1/2]

template<class T>

void SGTest::TestStore::remap ( const std::string & key_in, const std::string & key_out, size_t index_in = 0, size_t index_out = 0 )

inline

Definition at line 107 of file TestStore.h.

  {
    CLID clid = ClassID_traits<T>::ID();
    sgkey_t sgkey_in = stringToKey (key_in, clid);
    sgkey_t sgkey_out = stringToKey (key_out, clid);
    remap (sgkey_in, sgkey_out, index_in, index_out);
  }

remap() [2/2]

void SGTest::TestStore::remap	(	sgkey_t	sgkey_in,
		sgkey_t	sgkey_out,
		size_t	index_in = 0,
		size_t	index_out = 0 )

Definition at line 227 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  m_remap[TestStoreRemap(sgkey_in, index_in)] =
    TestStoreRemap(sgkey_out, index_out);
}

stringToKey()

sgkey_t SGTest::TestStore::stringToKey ( const std::string & str, CLID clid )

overridevirtual

Definition at line 150 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  return m_stringPool.stringToKey (str, clid);
}

tryELRemap()

bool SGTest::TestStore::tryELRemap ( sgkey_t sgkey_in, size_t index_in, sgkey_t & sgkey_out, size_t & index_out )

overridevirtual

Definition at line 164 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  remap_t::iterator i = m_remap.find (TestStoreRemap (sgkey_in, index_in));
  if (i == m_remap.end()) return false;
  sgkey_out = i->second.key;
  index_out = i->second.index;
  return true;
}

unboundHandle()

void SGTest::TestStore::unboundHandle ( IResetable * handle )

overridevirtual

Definition at line 193 of file TestStore.cxx.

{
  lock_t lock (m_mutex);
  std::vector<IResetable*>::iterator it =
    std::find (m_boundHandles.begin(), m_boundHandles.end(), handle);
  if (it != m_boundHandles.end())
    m_boundHandles.erase (it);
}

Member Data Documentation

ATLAS_THREAD_SAFE [1/2]

SG::StringPool m_stringPool SGTest::TestStore::ATLAS_THREAD_SAFE

mutable

Definition at line 127 of file TestStore.h.

ATLAS_THREAD_SAFE [2/2]

std::vector<std::pair<CLID, std::string> > m_missedProxies SGTest::TestStore::ATLAS_THREAD_SAFE

mutable

Definition at line 132 of file TestStore.h.

m_boundHandles

std::vector<IResetable*> SGTest::TestStore::m_boundHandles

Definition at line 129 of file TestStore.h.

m_kmap

kmap_t SGTest::TestStore::m_kmap

Definition at line 122 of file TestStore.h.

m_mutex

mutex_t SGTest::TestStore::m_mutex

mutable

Definition at line 136 of file TestStore.h.

m_remap

remap_t SGTest::TestStore::m_remap

Definition at line 125 of file TestStore.h.

m_tmap

tmap_t SGTest::TestStore::m_tmap

Definition at line 119 of file TestStore.h.

---

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

• TestStore.h
• TestStore.cxx