DTKeyedConfigCache Class Reference

#include <DTKeyedConfigCache.h>

Public Member Functions
	DTKeyedConfigCache ()
int	get (const DTKeyedConfigListRcd &keyRecord, int cfgId, const DTKeyedConfig *&obj)
void	getData (const DTKeyedConfigListRcd &keyRecord, int cfgId, std::vector< std::string > &list)
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 Member Functions
	DTKeyedConfigCache (const DTKeyedConfigCache &x)
const DTKeyedConfigCache &	operator= (const DTKeyedConfigCache &x)

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 28 of file DTKeyedConfigCache.h.

Member Typedef Documentation

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

private

Definition at line 52 of file DTKeyedConfigCache.h.

Constructor & Destructor Documentation

DTKeyedConfigCache::DTKeyedConfigCache

(

)

Definition at line 38 of file DTKeyedConfigCache.cc.

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

DTKeyedConfigCache::~DTKeyedConfigCache ( )

virtual

Definition at line 48 of file DTKeyedConfigCache.cc.

References purge().

                                        {
  purge();
}

DTKeyedConfigCache::DTKeyedConfigCache ( const DTKeyedConfigCache &  x )

private

Member Function Documentation

int DTKeyedConfigCache::get	(	const DTKeyedConfigListRcd &	keyRecord,
		int	cfgId,
		const DTKeyedConfig *&	obj
	)

Definition at line 53 of file DTKeyedConfigCache.cc.

References brickMap, cachedBrickNumber, cachedByteNumber, cachedStringNumber, DTKeyedConfig::dataBegin(), DTKeyedConfig::dataEnd(), alignCSCRings::e, cppFunctionSkipper::exception, cond::persistency::KeyList::get(), edm::eventsetup::EventSetupRecord::get(), DTKeyedConfig::getId(), cond::persistency::KeyList::load(), maxBrickNumber, maxByteNumber, maxStringNumber, edm::ESHandle< class >::product(), and findQualityFiles::size.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), rrapi.RRApi::columns(), rrapi.RRApi::count(), rrapi.RRApi::data(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), rrapi.RRApi::report(), rrapi.RRApi::reports(), rrapi.RRApi::tables(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), 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 ) );
    }
  }

// get dummy brick list
  edm::ESHandle<cond::persistency::KeyList> klh;
  keyRecord.get( klh );
  cond::persistency::KeyList const &  kl= *klh.product();
  // This const_cast and usage of KeyList is a problem
  // that will need to be addressed in the future.
  // I'm not fixing now, because I want to finish what I am
  // fixing. One thing at a time. (This was already in the
  // the code I copied to make this file)
  cond::persistency::KeyList* keyList = const_cast<cond::persistency::KeyList*>( &kl );
  if ( keyList == 0 ) return 999;

  std::vector<unsigned long long> checkedKeys;
  boost::shared_ptr<DTKeyedConfig> kBrick;
  checkedKeys.push_back( cfgId );
  bool brickFound = false;
  try {
    keyList->load( checkedKeys );
    kBrick = keyList->get<DTKeyedConfig>( 0 );
    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 DTKeyedConfigListRcd &	keyRecord,
		int	cfgId,
		std::vector< std::string > &	list
	)

Definition at line 143 of file DTKeyedConfigCache.cc.

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

Referenced by FrontierCondition_GT_autoExpress_cfi.Tier0DasInterface::expressGlobalTag(), FrontierCondition_GT_autoExpress_cfi.Tier0DasInterface::firstConditionSafeRun(), FrontierCondition_GT_autoExpress_cfi.Tier0DasInterface::getData(), FrontierCondition_GT_autoExpress_cfi.Tier0DasInterface::lastPromptRun(), FrontierCondition_GT_autoExpress_cfi.Tier0DasInterface::promptGlobalTag(), and DTConfigDBProducer::readDTCCBConfig().

                                                                  {
  const DTKeyedConfig* obj = 0;
  get( keyRecord, cfgId, obj );
  if ( obj == 0 ) 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( keyRecord, *l_iter++, list );
  return;
}

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

private

void DTKeyedConfigCache::purge

(

)

Definition at line 159 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 53 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

int DTKeyedConfigCache::cachedBrickNumber

private

Definition at line 54 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

int DTKeyedConfigCache::cachedByteNumber

private

Definition at line 56 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

int DTKeyedConfigCache::cachedStringNumber

private

Definition at line 55 of file DTKeyedConfigCache.h.

Referenced by get(), and purge().

const int DTKeyedConfigCache::maxBrickNumber = 5000

static

Definition at line 43 of file DTKeyedConfigCache.h.

Referenced by get().

const int DTKeyedConfigCache::maxByteNumber = 10000000

static

Definition at line 45 of file DTKeyedConfigCache.h.

Referenced by get().

const int DTKeyedConfigCache::maxStringNumber = 100000

static

Definition at line 44 of file DTKeyedConfigCache.h.

Referenced by get().