StorageAccount Class Reference

#include <StorageAccount.h>

Classes
struct	Counter
class	Stamp
class	StorageClassToken

Public Types
enum	Operation {   Operation::check, Operation::close, Operation::construct, Operation::destruct,   Operation::flush, Operation::open, Operation::position, Operation::prefetch,   Operation::read, Operation::readActual, Operation::readAsync, Operation::readPrefetchToCache,   Operation::readViaCache, Operation::readv, Operation::resize, Operation::seek,   Operation::stagein, Operation::stat, Operation::write, Operation::writeActual,   Operation::writeViaCache, Operation::writev }
typedef tbb::concurrent_unordered_map< int, Counter >	OperationStats
typedef tbb::concurrent_unordered_map< int, OperationStats >	StorageStats

Static Public Member Functions
static Counter &	counter (StorageClassToken token, Operation operation)
static void	fillSummary (std::map< std::string, std::string > &summary)
static const std::string &	nameForToken (StorageClassToken)
static char const *	operationName (Operation operation)
static const StorageStats &	summary (void)
static std::string	summaryText (bool banner=false)
static StorageClassToken	tokenForStorageClassName (std::string const &iName)

Static Private Attributes
static StorageStats	m_stats

Detailed Description

Definition at line 12 of file StorageAccount.h.

Member Typedef Documentation

OperationStats

typedef tbb::concurrent_unordered_map<int, Counter> StorageAccount::OperationStats

Definition at line 118 of file StorageAccount.h.

StorageStats

typedef tbb::concurrent_unordered_map<int, OperationStats> StorageAccount::StorageStats

Definition at line 119 of file StorageAccount.h.

Member Enumeration Documentation

Operation

enum StorageAccount::Operation

strong

Enumerator
check
close
construct
destruct
flush
open
position
prefetch
read
readActual
readAsync
readPrefetchToCache
readViaCache
readv
resize
seek
stagein
stat
write
writeActual
writeViaCache
writev

Definition at line 14 of file StorageAccount.h.

                       {
    check,
    close,
    construct,
    destruct,
    flush,
    open,
    position,
    prefetch,
    read,
    readActual,
    readAsync,
    readPrefetchToCache,
    readViaCache,
    readv,
    resize,
    seek,
    stagein,
    stat,
    write,
    writeActual,
    writeViaCache,
    writev
  };

Member Function Documentation

counter()

StorageAccount::Counter & StorageAccount::counter ( StorageClassToken  token, Operation  operation  )

static

Definition at line 97 of file StorageAccount.cc.

                                                                                           {
  auto& opstats = m_stats[token.value()];
 
  return opstats[static_cast<int>(operation)];
}

References m_stats, and unpackBuffers-CaloStage2::token.

Referenced by StorageFactory::check(), StorageAccountProxy::close(), StorageAccountProxy::flush(), StorageFactory::open(), StorageAccountProxy::resize(), StorageFactory::stagein(), StorageAccountProxy::StorageAccountProxy(), storageCounter(), and StorageAccountProxy::~StorageAccountProxy().

fillSummary()

void StorageAccount::fillSummary ( std::map< std::string, std::string > &  summary )

static

Definition at line 76 of file StorageAccount.cc.

                                                                      {
  int const oneM = 1000 * 1000;
  int const oneMeg = 1024 * 1024;
  for (auto i = s_nameToToken.begin(); i != s_nameToToken.end(); ++i) {
    auto const& opStats = m_stats[i->second];
    for (auto j = opStats.begin(); j != opStats.end(); ++j) {
      std::ostringstream os;
      os << "Timing-" << i->first << "-" << kOperationNames[j->first] << "-";
      summary.insert(std::make_pair(os.str() + "numOperations", i2str(j->second.attempts)));
      summary.insert(std::make_pair(os.str() + "numSuccessfulOperations", i2str(j->second.successes)));
      summary.insert(
          std::make_pair(os.str() + "totalMegabytes", d2str(static_cast<double>(j->second.amount) / oneMeg)));
      summary.insert(std::make_pair(os.str() + "totalMsecs", d2str(static_cast<double>(j->second.timeTotal) / oneM)));
      summary.insert(std::make_pair(os.str() + "minMsecs", d2str(static_cast<double>(j->second.timeMin) / oneM)));
      summary.insert(std::make_pair(os.str() + "maxMsecs", d2str(static_cast<double>(j->second.timeMax) / oneM)));
    }
  }
}

References d2str(), mps_fire::i, i2str(), dqmiolumiharvest::j, m_stats, and summary().

Referenced by TFileAdaptor::statsXML().

nameForToken()

const std::string & StorageAccount::nameForToken ( StorageClassToken  iToken )

static

Definition at line 50 of file StorageAccount.cc.

                                                                      {
  for (auto it = s_nameToToken.begin(), itEnd = s_nameToToken.end(); it != itEnd; ++it) {
    if (it->second == iToken.value()) {
      return it->first;
    }
  }
  assert(false);
}

References cms::cuda::assert(), and StorageAccount::StorageClassToken::value().

operationName()

char const * StorageAccount::operationName ( Operation  operation )

inlinestatic

Definition at line 34 of file StorageAccount.cc.

                                                                    {
  return kOperationNames[static_cast<int>(operation)];
}

summary()

const StorageAccount::StorageStats & StorageAccount::summary ( void  )

static

Definition at line 95 of file StorageAccount.cc.

{ return m_stats; }

References m_stats.

Referenced by fillSummary(), edm::storage::StatisticsSenderService::FileStatistics::fillUDP(), and edm::service::CondorStatusService::updateImpl().

summaryText()

std::string StorageAccount::summaryText ( bool  banner = false )

static

Definition at line 59 of file StorageAccount.cc.

                                                   {
  bool first = true;
  std::ostringstream os;
  if (banner)
    os << "stats: class/operation/attempts/successes/amount/time-total/time-min/time-max\n";
  for (auto i = s_nameToToken.begin(); i != s_nameToToken.end(); ++i) {
    auto const& opStats = m_stats[i->second];
    for (auto j = opStats.begin(); j != opStats.end(); ++j, first = false)
      os << (first ? "" : "; ") << (i->first) << '/' << kOperationNames[j->first] << '=' << j->second.attempts << '/'
         << j->second.successes << '/' << (static_cast<double>(j->second.amount) / 1024 / 1024) << "MB/"
         << (static_cast<double>(j->second.timeTotal) / 1000 / 1000) << "ms/"
         << (static_cast<double>(j->second.timeMin) / 1000 / 1000) << "ms/"
         << (static_cast<double>(j->second.timeMax) / 1000 / 1000) << "ms";
  }
  return os.str();
}

References dqmdumpme::first, mps_fire::i, dqmiolumiharvest::j, and m_stats.

Referenced by TFileAdaptor::stats().

tokenForStorageClassName()

StorageAccount::StorageClassToken StorageAccount::tokenForStorageClassName ( std::string const &  iName )

static

Definition at line 38 of file StorageAccount.cc.

                                                                                               {
  auto itFound = s_nameToToken.find(iName);
  if (itFound != s_nameToToken.end()) {
    return StorageClassToken(itFound->second);
  }
  int value = s_nextTokenValue++;
 
  s_nameToToken.insert(std::make_pair(iName, value));
 
  return StorageClassToken(value);
}

Referenced by StorageFactory::check(), edm::storage::StatisticsSenderService::FileStatistics::fillUDP(), StorageFactory::open(), StorageFactory::stagein(), storageCounter(), and edm::service::CondorStatusService::updateImpl().

Member Data Documentation

m_stats

StorageAccount::StorageStats StorageAccount::m_stats

staticprivate

Definition at line 131 of file StorageAccount.h.

Referenced by counter(), fillSummary(), summary(), and summaryText().