#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
typedef void	deleter_f(const void *p)

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

◆ deleter_f

typedef void EventContainers::I_InternalIDC::deleter_f(const void *p)

inherited

Definition at line 14 of file I_InternalIDC.h.

◆ hashPair

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

inherited

Definition at line 37 of file I_InternalIDC.h.

◆ InternalConstItr

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

inherited

Definition at line 38 of file I_InternalIDC.h.

Constructor & Destructor Documentation

◆ InternalOfflineMap()

InternalOfflineMap::InternalOfflineMap ( size_t max )

Definition at line 11 of file InternalOfflineMap.cxx.

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

max

#define max(a, b)

Definition cfImp.cxx:41

EventContainers::InternalOfflineMap::m_maxsize

const size_t m_maxsize

Definition InternalOfflineMap.h:47

◆ ~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 100 of file InternalOfflineMap.cxx.

                                                                             {
    bool added = insert(hashId, ptr);
    if (!added) [[unlikely]] {
      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 63 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 52 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 79 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 125 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 120 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 117 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 94 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 35 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 57 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 68 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 86 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 75 of file InternalOfflineMap.cxx.

                                                     {
    return m_fullMap.size();
}

◆ removeCollection()

void * InternalOfflineMap::removeCollection ( IdentifierHash hashId )

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 108 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 18 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 14 of file InternalOfflineMap.cxx.

                                                                                                 {
    return m_fullMap.count(hash);
}

◆ wait()

void InternalOfflineMap::wait ( ) const

overridevirtual

Implements EventContainers::I_InternalIDC.

Definition at line 23 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::atomic<bool> m_needsupdate EventContainers::InternalOfflineMap::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 46 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::vector<I_InternalIDC::hashPair> m_map EventContainers::InternalOfflineMap::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 43 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

◆ deleter_f

◆ 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