DTKeyedConfigCache Class Reference

#include <DTKeyedConfigCache.h>

Public Member Functions
	DTKeyedConfigCache ()
	DTKeyedConfigCache (const DTKeyedConfigCache &x)=delete
int	get (const cond::persistency::KeyList &keyList, int cfgId, const DTKeyedConfig *&obj)
void	getData (const cond::persistency::KeyList &keyList, int cfgId, std::vector< std::string > &list)
const DTKeyedConfigCache &	operator= (const DTKeyedConfigCache &x)=delete
void	purge ()
virtual	~DTKeyedConfigCache ()

Static Public Attributes
static const int	maxBrickNumber = 5000
static const int	maxByteNumber = 10000000
static const int	maxStringNumber = 100000

Private Types
typedef std::pair< int, const DTKeyedConfig * >	counted_brick

Private Attributes
std::map< int, counted_brick >	brickMap
int	cachedBrickNumber
int	cachedByteNumber
int	cachedStringNumber

Detailed Description

Description: Class to hold configuration identifier for chambers

This class was originally defined in CondCore/DTPlugins/interface/DTConfigPluginHandler.h It was moved, renamed, and modified to not be a singleton for thread safety, but otherwise little was changed.

Author

Paolo Ronchese INFN Padova

Definition at line 29 of file DTKeyedConfigCache.h.

Member Typedef Documentation

typedef std::pair<int, const DTKeyedConfig*> DTKeyedConfigCache::counted_brick

private

Definition at line 47 of file DTKeyedConfigCache.h.

Constructor & Destructor Documentation

DTKeyedConfigCache::DTKeyedConfigCache

(

)

Definition at line 35 of file DTKeyedConfigCache.cc.

: cachedBrickNumber(0), cachedStringNumber(0), cachedByteNumber(0) {}

DTKeyedConfigCache::DTKeyedConfigCache ( const DTKeyedConfigCache &  x )

delete

DTKeyedConfigCache::~DTKeyedConfigCache ( )

virtual

Definition at line 40 of file DTKeyedConfigCache.cc.

References purge().

{ purge(); }

Member Function Documentation

int DTKeyedConfigCache::get	(	const cond::persistency::KeyList &	keyList,
		int	cfgId,
		const DTKeyedConfig *&	obj
	)

Definition at line 42 of file DTKeyedConfigCache.cc.

References brickMap, cachedBrickNumber, cachedByteNumber, cachedStringNumber, DTKeyedConfig::dataBegin(), DTKeyedConfig::dataEnd(), alignCSCRings::e, mps_splice::entry, cppFunctionSkipper::exception, DTKeyedConfig::getId(), cond::persistency::KeyList::getUsingKey(), maxBrickNumber, maxByteNumber, maxStringNumber, and findQualityFiles::size.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), submitPVValidationJobs.BetterConfigParser::__updateDict(), util.rrapi.RRApi::columns(), rrapi.RRApi::columns(), rrapi.RRApi::count(), util.rrapi.RRApi::count(), rrapi.RRApi::data(), util.rrapi.RRApi::data(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), submitPVValidationJobs.BetterConfigParser::getResultingSection(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), rrapi.RRApi::reports(), util.rrapi.RRApi::reports(), rrapi.RRApi::tables(), util.rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

                                                                                                       {
  bool cacheFound = false;
  int cacheAge = 999999999;
  std::map<int, counted_brick>::iterator cache_iter = brickMap.begin();
  std::map<int, counted_brick>::iterator cache_icfg = brickMap.find(cfgId);
  std::map<int, counted_brick>::iterator cache_iend = brickMap.end();
  if (cache_icfg != cache_iend) {
    std::pair<const int, counted_brick>& entry = *cache_icfg;
    counted_brick& cBrick = entry.second;
    cacheAge = cBrick.first;
    obj = cBrick.second;
    cacheFound = true;
  }

  std::map<int, const DTKeyedConfig*> ageMap;
  if (cacheFound) {
    if (!cacheAge)
      return 0;
    while (cache_iter != cache_iend) {
      std::pair<const int, counted_brick>& entry = *cache_iter++;
      counted_brick& cBrick = entry.second;
      int& brickAge = cBrick.first;
      if (brickAge < cacheAge)
        brickAge++;
      if (entry.first == cfgId)
        brickAge = 0;
    }
    return 0;
  } else {
    while (cache_iter != cache_iend) {
      std::pair<const int, counted_brick>& entry = *cache_iter++;
      counted_brick& cBrick = entry.second;
      ageMap.insert(std::pair<int, const DTKeyedConfig*>(++cBrick.first, entry.second.second));
    }
  }

  std::shared_ptr<DTKeyedConfig> kBrick;
  bool brickFound = false;
  try {
    kBrick = keyList.getUsingKey<DTKeyedConfig>(cfgId);
    if (kBrick.get())
      brickFound = (kBrick->getId() == cfgId);
  } catch (std::exception const& e) {
  }
  if (brickFound) {
    counted_brick cBrick(0, obj = new DTKeyedConfig(*kBrick));
    brickMap.insert(std::pair<int, counted_brick>(cfgId, cBrick));
    DTKeyedConfig::data_iterator d_iter = kBrick->dataBegin();
    DTKeyedConfig::data_iterator d_iend = kBrick->dataEnd();
    cachedBrickNumber++;
    cachedStringNumber += (d_iend - d_iter);
    while (d_iter != d_iend)
      cachedByteNumber += (*d_iter++).size();
  }
  std::map<int, const DTKeyedConfig*>::reverse_iterator iter = ageMap.rbegin();
  while ((cachedBrickNumber > maxBrickNumber) || (cachedStringNumber > maxStringNumber) ||
         (cachedByteNumber > maxByteNumber)) {
    const DTKeyedConfig* oldestBrick = iter->second;
    int oldestId = oldestBrick->getId();
    cachedBrickNumber--;
    DTKeyedConfig::data_iterator d_iter = oldestBrick->dataBegin();
    DTKeyedConfig::data_iterator d_iend = oldestBrick->dataEnd();
    cachedStringNumber -= (d_iend - d_iter);
    while (d_iter != d_iend)
      cachedByteNumber -= (*d_iter++).size();
    brickMap.erase(oldestId);
    delete iter->second;
    iter++;
  }

  return 999;
}

void DTKeyedConfigCache::getData	(	const cond::persistency::KeyList &	keyList,
		int	cfgId,
		std::vector< std::string > &	list
	)

Definition at line 115 of file DTKeyedConfigCache.cc.

References DTKeyedConfig::dataBegin(), DTKeyedConfig::dataEnd(), DTKeyedConfig::linkBegin(), DTKeyedConfig::linkEnd(), and getGTfromDQMFile::obj.

Referenced by DTConfigDBProducer::readDTCCBConfig().

                                                                                                             {
  const DTKeyedConfig* obj = nullptr;
  get(keyList, cfgId, obj);
  if (obj == nullptr)
    return;
  DTKeyedConfig::data_iterator d_iter = obj->dataBegin();
  DTKeyedConfig::data_iterator d_iend = obj->dataEnd();
  while (d_iter != d_iend)
    list.push_back(*d_iter++);
  DTKeyedConfig::link_iterator l_iter = obj->linkBegin();
  DTKeyedConfig::link_iterator l_iend = obj->linkEnd();
  while (l_iter != l_iend)
    getData(keyList, *l_iter++, list);
  return;
}

const DTKeyedConfigCache& DTKeyedConfigCache::operator= ( const DTKeyedConfigCache &  x )

delete

void DTKeyedConfigCache::purge

(

)

Definition at line 131 of file DTKeyedConfigCache.cc.

References brickMap, cachedBrickNumber, cachedByteNumber, and cachedStringNumber.

Referenced by ~DTKeyedConfigCache().

                               {
  std::map<int, counted_brick>::const_iterator iter = brickMap.begin();
  std::map<int, counted_brick>::const_iterator iend = brickMap.end();
  while (iter != iend) {
    delete iter->second.second;
    iter++;
  }
  brickMap.clear();
  cachedBrickNumber = 0;
  cachedStringNumber = 0;
  cachedByteNumber = 0;
  return;
}

Member Data Documentation

std::map<int, counted_brick> DTKeyedConfigCache::brickMap

private

Definition at line 48 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

int DTKeyedConfigCache::cachedBrickNumber

private

Definition at line 49 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

int DTKeyedConfigCache::cachedByteNumber

private

Definition at line 51 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

int DTKeyedConfigCache::cachedStringNumber

private

Definition at line 50 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

const int DTKeyedConfigCache::maxBrickNumber = 5000

static

Definition at line 42 of file DTKeyedConfigCache.h.

Referenced by get().

const int DTKeyedConfigCache::maxByteNumber = 10000000

static

Definition at line 44 of file DTKeyedConfigCache.h.

Referenced by get().

const int DTKeyedConfigCache::maxStringNumber = 100000

static

Definition at line 43 of file DTKeyedConfigCache.h.

Referenced by get().