ItemListSvc Class Reference

This implementes the methods for IItemListSvc. More...

#include <ItemListSvc.h>

Inheritance diagram for ItemListSvc:

Collaboration diagram for ItemListSvc:

Public Member Functions
	ItemListSvc (const std::string &name, ISvcLocator *pSvcLocator)
	Constructor. More...
virtual	~ItemListSvc ()
	Destructor. More...
StatusCode	initialize () override
	Gaudi Service Implementation. More...
StatusCode	finalize () override
virtual StatusCode	addStreamItem (const std::string &stream, const std::string &itemname) override
virtual StatusCode	removeStreamItem (const std::string &stream, const std::string &itemname) override
virtual bool	containsItem (const std::string &itemname, const std::string &stream="ANY") const override
virtual std::vector< std::string >	getStreamsForItem (const std::string &itemname) const override
virtual std::vector< std::string >	getItemsForStream (const std::string &stream) const override

Private Types
typedef std::lock_guard< std::mutex >	lock_t

Private Member Functions
	ItemListSvc (const ItemListSvc &)
ItemListSvc &	operator= (const ItemListSvc &)

Private Attributes
std::map< std::string, std::set< std::string > >	m_streamItems
float	m_verboseThresh
std::mutex	m_mutex

Detailed Description

This implementes the methods for IItemListSvc.

Definition at line 55 of file ItemListSvc.h.

Member Typedef Documentation

lock_t

typedef std::lock_guard<std::mutex> ItemListSvc::lock_t

private

Definition at line 95 of file ItemListSvc.h.

Constructor & Destructor Documentation

ItemListSvc() [1/2]

ItemListSvc::ItemListSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Constructor.

Definition at line 20 of file ItemListSvc.cxx.

                                          : 
  base_class(name, pSvcLocator),
  m_verboseThresh(0.20)
{
  declareProperty("VerboseThreshold",m_verboseThresh,"overlaps above this fraction print their items, def=0.2");
  assert( pSvcLocator );
}

~ItemListSvc()

ItemListSvc::~ItemListSvc ( )

virtual

Destructor.

Definition at line 29 of file ItemListSvc.cxx.

{
}

ItemListSvc() [2/2]

ItemListSvc::ItemListSvc ( const ItemListSvc &  )

private

Member Function Documentation

addStreamItem()

StatusCode ItemListSvc::addStreamItem ( const std::string &  stream, const std::string &  itemname  )

overridevirtual

Definition at line 74 of file ItemListSvc.cxx.

{
  lock_t lock (m_mutex);
  // Add to stream list
  // Check if item is already present
  std::map<std::string, std::set<std::string> >::iterator it = m_streamItems.find(stream);
  // if so, then add stream name for that item
  if (it != m_streamItems.end()) {
     it->second.insert(itemname);
  }
  // otherwise add item and stream
  else {
     std::set<std::string> start;
     start.insert(itemname);
     std::pair<std::map<std::string, std::set<std::string> >::iterator,bool> retc = m_streamItems.insert(std::make_pair(stream,start));
     if (!retc.second) {
        ATH_MSG_ERROR("Problem inserting " << retc.first->first);
     }
  }
  return StatusCode::SUCCESS;
}

containsItem()

bool ItemListSvc::containsItem ( const std::string &  itemname, const std::string &  stream = "ANY"  ) const

overridevirtual

Definition at line 113 of file ItemListSvc.cxx.

{
  lock_t lock (m_mutex);
  bool contains=false;
  std::map<std::string, std::set<std::string> >::const_iterator it = m_streamItems.begin();
  while (it != m_streamItems.end()) {
    if (it->first == stream || stream == "ANY") { 
      if (it->second.find(itemname) != it->second.end()) contains = true;
    }
    ++it;
  }
  return contains;
}

finalize()

StatusCode ItemListSvc::finalize ( )

override

Definition at line 39 of file ItemListSvc.cxx.

{
  ATH_MSG_DEBUG("ItemListSvc finalize");
  std::map<std::string, std::set<std::string> >::const_iterator it = m_streamItems.begin();
  ATH_MSG_DEBUG("-- OUTPUT STREAM ITEM OVERLAP SUMMARY --");
  while (it != m_streamItems.end()) {
    ATH_MSG_DEBUG("STREAM " << it->first << " has (" << it->second.size() << ") items");
    std::set<std::string>::const_iterator iprint = it->second.begin();
    while (iprint != it->second.end()) {
      ATH_MSG_DEBUG("   - " << *iprint);
      ++iprint;
    }
    std::map<std::string, std::set<std::string> >::const_iterator it2 = m_streamItems.begin();
    float inv_size = 1. / static_cast<float> (it->second.size());
    while (it2 != m_streamItems.end()) {
      if (it2->first != it->first) {
        std::set<std::string> olist;
        std::set_intersection(it->second.begin(),it->second.end(),it2->second.begin(),it2->second.end(),std::inserter(olist,olist.begin()));
        if (olist.size()>0) { 
          ATH_MSG_DEBUG(" --> Overlap with " << it2->first << " (" << olist.size() << ") items"); 
          if (float(olist.size()) * inv_size > m_verboseThresh) {
            for (const std::string& ol : olist) {
              ATH_MSG_DEBUG(" ----> item: " << ol);
            }
          } 
        }
      }
      ++it2;
    }
    ++it;
  }
  return StatusCode::SUCCESS;
}

getItemsForStream()

std::vector< std::string > ItemListSvc::getItemsForStream ( const std::string &  stream ) const

overridevirtual

Definition at line 141 of file ItemListSvc.cxx.

{
  lock_t lock (m_mutex);
  std::vector<std::string> t;
  std::map<std::string, std::set<std::string> >::const_iterator it = m_streamItems.find(stream);
  if (it != m_streamItems.end()) std::copy(it->second.begin(), it->second.end(),t.begin());
  return t;
}

getStreamsForItem()

std::vector< std::string > ItemListSvc::getStreamsForItem ( const std::string &  itemname ) const

overridevirtual

Definition at line 128 of file ItemListSvc.cxx.

{
  lock_t lock (m_mutex);
  std::vector<std::string> t;
  std::map<std::string, std::set<std::string> >::const_iterator it = m_streamItems.begin();
  while (it != m_streamItems.end()) {
    if (it->second.find(itemname) != it->second.end()) t.push_back(it->first);
    ++it;
  }
  return t;
}

initialize()

StatusCode ItemListSvc::initialize ( )

override

Gaudi Service Implementation.

Definition at line 32 of file ItemListSvc.cxx.

{
  ATH_MSG_DEBUG("ItemListSvc initialize");
  return StatusCode::SUCCESS;
}

operator=()

ItemListSvc& ItemListSvc::operator= ( const ItemListSvc &  )

private

removeStreamItem()

StatusCode ItemListSvc::removeStreamItem ( const std::string &  stream, const std::string &  itemname  )

overridevirtual

Definition at line 97 of file ItemListSvc.cxx.

{
  lock_t lock (m_mutex);
  std::map<std::string, std::set<std::string> >::iterator it = m_streamItems.find(stream);
  if (it == m_streamItems.end()) {
    ATH_MSG_INFO("Tried to remove non-existing item " << itemname << " for " << stream);
  }
  else {
    // remove stream for item
    int n = it->second.erase(itemname);
    if (n<1) ATH_MSG_WARNING("Could not find stream " << stream << " for " << itemname);
  }
  return StatusCode::SUCCESS;
}

Member Data Documentation

m_mutex

std::mutex ItemListSvc::m_mutex

mutableprivate

Definition at line 94 of file ItemListSvc.h.

m_streamItems

std::map<std::string, std::set<std::string> > ItemListSvc::m_streamItems

private

Definition at line 92 of file ItemListSvc.h.

m_verboseThresh

float ItemListSvc::m_verboseThresh

private

Definition at line 93 of file ItemListSvc.h.

---

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

• ItemListSvc.h
• ItemListSvc.cxx