AtomicId.cc

Go to the documentation of this file.

#include <algorithm>
#include <cstddef>
#include <cstdlib>
#include <cstring>
#include <mutex>
#include <set>
 
#include "FWCore/Utilities/interface/thread_safety_macros.h"
#include "PhysicsTools/MVAComputer/interface/AtomicId.h"
 
namespace {  // anonymous
  struct StringLess {
    bool operator()(const char *id1, const char *id2) const { return std::strcmp(id1, id2) < 0; }
  };
 
  class IdCache {
  public:
    ~IdCache();
 
    inline const char *findOrInsert(const char *string) throw();
 
  private:
    typedef std::multiset<const char *, StringLess> IdSet;
 
    IdSet idSet;
    std::allocator<char> stringAllocator;
    std::mutex mutex;
  };
}  // anonymous namespace
 
IdCache::~IdCache() {
  for (std::multiset<const char *, StringLess>::iterator iter = idSet.begin(); iter != idSet.end(); iter++)
    stringAllocator.deallocate(const_cast<char *>(*iter), std::strlen(*iter) + 1);
}
 
const char *IdCache::findOrInsert(const char *string) throw() {
  std::lock_guard<std::mutex> scoped_lock(mutex);
 
  IdSet::iterator pos = idSet.lower_bound(string);
  if (pos != idSet.end() && std::strcmp(*pos, string) == 0)
    return *pos;
 
  std::size_t size = std::strlen(string) + 1;
  char *unique = stringAllocator.allocate(size);
  std::memcpy(unique, string, size);
 
  idSet.insert(pos, unique);
 
  return unique;
}
 
namespace PhysicsTools {
 
  static IdCache &getAtomicIdCache() {
    CMS_THREAD_SAFE static IdCache atomicIdCache;
    return atomicIdCache;
  }
 
  const char *AtomicId::lookup(const char *string) throw() {
    if (string)
      return getAtomicIdCache().findOrInsert(string);
 
    return nullptr;
  }
 
}  // namespace PhysicsTools