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

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

Definition at line 120 of file StorageAccount.h.

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

Definition at line 121 of file StorageAccount.h.

Member Enumeration Documentation

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 15 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

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

static

Definition at line 126 of file StorageAccount.cc.

References StorageAccount::StorageClassToken::value().

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

                                                                     {
  auto &opstats = m_stats [token.value()];

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

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

static

Definition at line 103 of file StorageAccount.cc.

References d2str(), mps_fire::i, and i2str().

Referenced by TFileAdaptor::statsXML().

                                                                 {
  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)));
    }
  }
}

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

static

Definition at line 70 of file StorageAccount.cc.

References AlCaHLTBitMon_QueryRunRegistry::string, and StorageAccount::StorageClassToken::value().

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

char const * StorageAccount::operationName ( Operation  operation )

inlinestatic

Definition at line 53 of file StorageAccount.cc.

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

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

static

Definition at line 122 of file StorageAccount.cc.

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

{ return m_stats; }

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

static

Definition at line 81 of file StorageAccount.cc.

References plotBeamSpotDB::first, and mps_fire::i.

Referenced by TFileAdaptor::stats().

                                          {
  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 ();
}

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

static

Definition at line 57 of file StorageAccount.cc.

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

                                                                                                 {
  auto itFound = s_nameToToken.find(iName);
  if( itFound != s_nameToToken.end()) {
    return StorageClassToken(itFound->second);
  }
  int value = s_nextTokenValue++;
  
  auto ret = s_nameToToken.insert(std::make_pair(iName, value));
  
  //don't use value since another thread may have beaten us to here
  return StorageClassToken(ret.second);
}

Member Data Documentation

StorageAccount::StorageStats StorageAccount::m_stats

staticprivate

Definition at line 134 of file StorageAccount.h.