#include <InternalOfflineMap.h>

Inheritance diagram for EventContainers::InternalOfflineMap:

Collaboration diagram for EventContainers::InternalOfflineMap:

Public Types
typedef EventContainers::hashPair< void >	hashPair

typedef std::vector< hashPair >::const_iterator	InternalConstItr

Public Member Functions
	InternalOfflineMap (size_t max)

virtual	~InternalOfflineMap ()=default

virtual InternalConstItr	cbegin () const override

virtual InternalConstItr	cend () const override

virtual InternalConstItr	indexFind (IdentifierHash hashId) const override

virtual const std::vector< hashPair > &	getAllHashPtrPair () const override

virtual bool	tryAddFromCache (IdentifierHash hashId, EventContainers::IDC_WriteHandleBase &lock) override

virtual bool	tryAddFromCache (IdentifierHash hashId) override

virtual void	wait () const override

virtual std::vector< IdentifierHash >	getAllCurrentHashes () const override

virtual size_t	numberOfCollections () const override

virtual void	cleanUp (deleter_f *deleter) noexcept override

virtual size_t	fullSize () const noexcept override

virtual StatusCode	fetchOrCreate (IdentifierHash hashId) override

virtual StatusCode	fetchOrCreate (const std::vector< IdentifierHash > &hashIds) override

virtual bool	insert (IdentifierHash hashId, const void *ptr) override

virtual const void *	findIndexPtr (IdentifierHash hashId) const noexcept override

virtual StatusCode	addLock (IdentifierHash hashId, const void *ptr) override

virtual void *	removeCollection (IdentifierHash hashId) override

virtual void	destructor (deleter_f *) noexcept override

Private Attributes
std::vector< I_InternalIDC::hashPair > m_map	ATLAS_THREAD_SAFE

std::unordered_map< IdentifierHash::value_type, const void * >	m_fullMap

std::mutex m_waitMutex	ATLAS_THREAD_SAFE

std::atomic< bool > m_needsupdate	ATLAS_THREAD_SAFE

const size_t	m_maxsize

Detailed Description

Definition at line 20 of file InternalOfflineMap.h.

Member Typedef Documentation

◆ hashPair

typedef EventContainers::hashPair<void> EventContainers::I_InternalIDC::hashPair

inherited

Definition at line 36 of file I_InternalIDC.h.

◆ InternalConstItr

typedef std::vector< hashPair >::const_iterator EventContainers::I_InternalIDC::InternalConstItr

inherited

Definition at line 37 of file I_InternalIDC.h.

Constructor & Destructor Documentation

◆ InternalOfflineMap()

InternalOfflineMap::InternalOfflineMap ( size_t max )

Definition at line 12 of file InternalOfflineMap.cxx.

12 : m_needsupdate(false), m_maxsize(max) {}

◆ ~InternalOfflineMap()

virtual EventContainers::InternalOfflineMap::~InternalOfflineMap ( )

virtualdefault

Member Function Documentation

◆ addLock()

StatusCode InternalOfflineMap::addLock	(	IdentifierHash	hashId,
		const void *	ptr
	)

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 101 of file InternalOfflineMap.cxx.

                                                                              {
     bool added = insert(hashId, ptr);
     if(ATH_UNLIKELY(!added)) {
       throw std::runtime_error("IDC WARNING Deletion shouldn't occur in addLock paradigm");
     }
     return StatusCode::SUCCESS;
 }

◆ cbegin()

InternalConstItr InternalOfflineMap::cbegin ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 64 of file InternalOfflineMap.cxx.

                                   {
     if(m_needsupdate.load(std::memory_order_acquire)) wait();
     return m_map.cbegin();
 }

◆ cend()

InternalConstItr InternalOfflineMap::cend ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 53 of file InternalOfflineMap.cxx.

                                 {
     if(m_needsupdate.load(std::memory_order_acquire)) wait();
     return m_map.cend();
 }

◆ cleanUp()

void InternalOfflineMap::cleanUp ( deleter_f * deleter )

overridevirtualnoexcept

Implements EventContainers::I_InternalIDC.

Definition at line 80 of file InternalOfflineMap.cxx.

                                                             {
     destructor(deleter);
     m_map.clear();
     m_fullMap.clear();
     m_needsupdate.store(false, std::memory_order_release);
 }

◆ destructor()

void InternalOfflineMap::destructor ( deleter_f * deleter )

overridevirtualnoexcept

Implements EventContainers::I_InternalIDC.

Definition at line 126 of file InternalOfflineMap.cxx.

                                                                {
     if(!m_needsupdate.load(std::memory_order_acquire)) for(const auto& x : m_map)  deleter(x.second);
     else {
       for(const auto &pair : m_fullMap) {  deleter(pair.second);  }
     }
 }

◆ fetchOrCreate() [1/2]

StatusCode InternalOfflineMap::fetchOrCreate ( const std::vector< IdentifierHash > & hashIds )

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 121 of file InternalOfflineMap.cxx.

 {
     throw std::runtime_error("Not implemented in offline mode");
 }

◆ fetchOrCreate() [2/2]

StatusCode InternalOfflineMap::fetchOrCreate ( IdentifierHash hashId )

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 118 of file InternalOfflineMap.cxx.

                                                            {
     throw std::runtime_error("Not implemented in offline mode");
 }

◆ findIndexPtr()

const void * InternalOfflineMap::findIndexPtr ( IdentifierHash hashId ) const

overridevirtualnoexcept

Implements EventContainers::I_InternalIDC.

Definition at line 95 of file InternalOfflineMap.cxx.

                                                                                 {
     auto search = m_fullMap.find(hashId);
     if(search!=m_fullMap.cend()) return search->second;
     return nullptr;
 }

◆ fullSize()

virtual size_t EventContainers::InternalOfflineMap::fullSize ( ) const

inlineoverridevirtualnoexcept

Implements EventContainers::I_InternalIDC.

Definition at line 34 of file InternalOfflineMap.h.

34 {return m_maxsize;}

◆ getAllCurrentHashes()

std::vector< IdentifierHash > InternalOfflineMap::getAllCurrentHashes ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 36 of file InternalOfflineMap.cxx.

                                                                         {
     std::vector<IdentifierHash> ids;
     ids.reserve(m_fullMap.size());
     if(m_needsupdate.load(std::memory_order_acquire) == true){
        for(const auto &pair : m_fullMap){
          ids.emplace_back(pair.first);
        }
        std::sort(ids.begin(), ids.end());
     }else{
        for(const auto &pair : m_map){
           ids.emplace_back(pair.first);
        }
     }
     return ids;
 }

◆ getAllHashPtrPair()

const std::vector< I_InternalIDC::hashPair > & InternalOfflineMap::getAllHashPtrPair ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 58 of file InternalOfflineMap.cxx.

                                                                                       {
     if(m_needsupdate.load(std::memory_order_acquire)) wait();
     return m_map;
 }

◆ indexFind()

InternalConstItr InternalOfflineMap::indexFind ( IdentifierHash hashId ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 69 of file InternalOfflineMap.cxx.

                                                                            {
    if(m_needsupdate.load(std::memory_order_acquire)) wait();
    auto itr = std::lower_bound( m_map.cbegin(), m_map.cend(), hashId.value(), [](const hashPair &lhs,  IdentifierHash::value_type rhs) -> bool { return lhs.first < rhs; } );
    if(itr!= m_map.cend() && itr->first==hashId) return itr;
    return m_map.cend();
 }

◆ insert()

bool InternalOfflineMap::insert	(	IdentifierHash	hashId,
		const void *	ptr
	)

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 87 of file InternalOfflineMap.cxx.

                                                                       {
     auto &mapptr = m_fullMap[hashId];
     if(mapptr!=nullptr) return false; //already present
     mapptr = ptr;
     m_needsupdate.store(true, std::memory_order_relaxed);
     return true;
 }

◆ numberOfCollections()

size_t InternalOfflineMap::numberOfCollections ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 76 of file InternalOfflineMap.cxx.

                                                      {
     return m_fullMap.size();
 }

◆ removeCollection()

void * InternalOfflineMap::removeCollection ( IdentifierHash hashId )

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 109 of file InternalOfflineMap.cxx.

                                                                   {
    auto search = m_fullMap.find(hashId);
    if(search==m_fullMap.cend()) return nullptr;
    void* ptr = const_cast< void* > (search->second);
    m_fullMap.erase(search);
    m_needsupdate.store(true, std::memory_order_relaxed);
    return ptr;
 }

◆ tryAddFromCache() [1/2]

bool InternalOfflineMap::tryAddFromCache ( IdentifierHash hashId )

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 19 of file InternalOfflineMap.cxx.

 {
     return m_fullMap.count(hash);
 }

◆ tryAddFromCache() [2/2]

bool InternalOfflineMap::tryAddFromCache	(	IdentifierHash	hashId,
		EventContainers::IDC_WriteHandleBase &	lock
	)

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 15 of file InternalOfflineMap.cxx.

                                                                                                  {
     return m_fullMap.count(hash);
 }

◆ wait()

void InternalOfflineMap::wait ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 24 of file InternalOfflineMap.cxx.

                                     {
    std::scoped_lock lock (m_waitMutex);
    if(m_needsupdate.load(std::memory_order_acquire) == false) return;
    m_map.clear();
    m_map.reserve(m_fullMap.size());
    for(const auto &pair : m_fullMap){
      m_map.emplace_back(pair.first, pair.second);
    }
    std::sort(m_map.begin(), m_map.end());
    m_needsupdate.store(false, std::memory_order_release);
 }

Member Data Documentation

◆ ATLAS_THREAD_SAFE [1/3]

std::vector<I_InternalIDC::hashPair> m_map EventContainers::InternalOfflineMap::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 43 of file InternalOfflineMap.h.

◆ ATLAS_THREAD_SAFE [2/3]

std::mutex m_waitMutex EventContainers::InternalOfflineMap::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 45 of file InternalOfflineMap.h.

◆ ATLAS_THREAD_SAFE [3/3]

std::atomic<bool> m_needsupdate EventContainers::InternalOfflineMap::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 46 of file InternalOfflineMap.h.

◆ m_fullMap

std::unordered_map<IdentifierHash::value_type, const void*> EventContainers::InternalOfflineMap::m_fullMap

private

Definition at line 44 of file InternalOfflineMap.h.

◆ m_maxsize

const size_t EventContainers::InternalOfflineMap::m_maxsize

private

Definition at line 47 of file InternalOfflineMap.h.

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

Public Types

Public Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ hashPair

◆ InternalConstItr

Constructor & Destructor Documentation

◆ InternalOfflineMap()

◆ ~InternalOfflineMap()

Member Function Documentation

◆ addLock()

◆ cbegin()

◆ cend()

◆ cleanUp()

◆ destructor()

◆ fetchOrCreate() [1/2]

◆ fetchOrCreate() [2/2]

◆ findIndexPtr()

◆ fullSize()

◆ getAllCurrentHashes()

◆ getAllHashPtrPair()

◆ indexFind()

◆ insert()

◆ numberOfCollections()

◆ removeCollection()

◆ tryAddFromCache() [1/2]

◆ tryAddFromCache() [2/2]

◆ wait()

Member Data Documentation

◆ ATLAS_THREAD_SAFE [1/3]

◆ ATLAS_THREAD_SAFE [2/3]

◆ ATLAS_THREAD_SAFE [3/3]

◆ m_fullMap

◆ m_maxsize