#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
	TestStore (StoreID::type id=StoreID::EVENT_STORE)
virtual StoreID::type	storeID () const override
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
StoreID::type	m_id

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 123 of file TestStore.h.

◆ lock_t

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

Definition at line 137 of file TestStore.h.

◆ mutex_t

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

Definition at line 136 of file TestStore.h.

◆ remap_t

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

Definition at line 126 of file TestStore.h.

◆ tmap_t

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

Definition at line 120 of file TestStore.h.

Constructor & Destructor Documentation

◆ TestStore()

SGTest::TestStore::TestStore ( StoreID::type id = StoreID::EVENT_STORE )

Definition at line 25 of file TestStore.cxx.

  : m_id (id)
{
}

Member Function Documentation

◆ addToStore()

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

overridevirtual

Definition at line 187 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 247 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 197 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 168 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 43 of file TestStore.cxx.

{
  return m_stringPool.keyToString (key);
}

◆ name()

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

overridevirtual

Definition at line 108 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 37 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 132 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 115 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 140 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 123 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 151 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 83 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 94 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 214 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 57 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 49 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 109 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 238 of file TestStore.cxx.

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

◆ storeID()

StoreID::type SGTest::TestStore::storeID ( ) const

overridevirtual

Definition at line 31 of file TestStore.cxx.

{
  return m_id;
}

◆ stringToKey()

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

overridevirtual

Definition at line 161 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 175 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 204 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]

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

mutable

Definition at line 134 of file TestStore.h.

◆ ATLAS_THREAD_SAFE [2/2]

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

mutable

Definition at line 129 of file TestStore.h.

◆ m_boundHandles

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

Definition at line 131 of file TestStore.h.

◆ m_id

StoreID::type SGTest::TestStore::m_id

Definition at line 140 of file TestStore.h.

◆ m_kmap

kmap_t SGTest::TestStore::m_kmap

Definition at line 124 of file TestStore.h.

◆ m_mutex

mutex_t SGTest::TestStore::m_mutex

mutable

Definition at line 138 of file TestStore.h.

◆ m_remap

remap_t SGTest::TestStore::m_remap

Definition at line 127 of file TestStore.h.

◆ m_tmap

tmap_t SGTest::TestStore::m_tmap

Definition at line 121 of file TestStore.h.

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

Public Types

Public Member Functions

Public Attributes

Detailed Description

Member Typedef Documentation

◆ kmap_t

◆ lock_t

◆ mutex_t

◆ remap_t

◆ tmap_t

Constructor & Destructor Documentation

◆ TestStore()

Member Function Documentation

◆ addToStore()

◆ alias()

◆ boundHandle()

◆ keyToString() [1/2]

◆ keyToString() [2/2]

◆ name()

◆ proxies()

◆ proxy() [1/4]

◆ proxy() [2/4]

◆ proxy() [3/4]

◆ proxy() [4/4]

◆ proxy_exact()

◆ record() [1/2]

◆ record() [2/2]

◆ record1()

◆ recordObject()

◆ registerKey()

◆ remap() [1/2]

◆ remap() [2/2]

◆ storeID()

◆ stringToKey()

◆ tryELRemap()

◆ unboundHandle()

Member Data Documentation

◆ ATLAS_THREAD_SAFE [1/2]

◆ ATLAS_THREAD_SAFE [2/2]

◆ m_boundHandles

◆ m_id

◆ m_kmap

◆ m_mutex

◆ m_remap

◆ m_tmap