StorageAccount Class Reference

#include <StorageAccount.h>

Classes
struct	Counter
class	Stamp

Public Types
typedef std::map< std::string, Counter >	OperationStats
typedef std::map< std::string, boost::shared_ptr < OperationStats > >	StorageStats

Static Public Member Functions
static Counter &	counter (const std::string &storageClass, const std::string &operation)
static void	fillSummary (std::map< std::string, std::string > &summary)
static const StorageStats &	summary (void)
static std::string	summaryText (bool banner=false)
static std::string	summaryXML (void)

Detailed Description

Definition at line 9 of file StorageAccount.h.

Member Typedef Documentation

typedef std::map<std::string, Counter> StorageAccount::OperationStats

Definition at line 30 of file StorageAccount.h.

typedef std::map<std::string, boost::shared_ptr<OperationStats> > StorageAccount::StorageStats

Definition at line 31 of file StorageAccount.h.

Member Function Documentation

StorageAccount::Counter & StorageAccount::counter ( const std::string &  storageClass, const std::string &  operation  )

static

Definition at line 96 of file StorageAccount.cc.

References CommonMethods::lock(), pos, s_mutex, s_stats, and vdt::x.

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

                                                                                  {
  boost::mutex::scoped_lock lock (s_mutex);
  boost::shared_ptr<OperationStats> &opstats = s_stats [storageClass];
  if (!opstats) opstats.reset(new OperationStats);

  OperationStats::iterator pos = opstats->find (operation);
  if (pos == opstats->end ()) {
    Counter x = { 0, 0, 0, 0, 0 };
    pos = opstats->insert (OperationStats::value_type (operation, x)).first;
  }

  return pos->second;
}

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

static

Definition at line 74 of file StorageAccount.cc.

References d2str(), i, i2str(), j, and s_stats.

Referenced by TFileAdaptor::statsXML().

                                                                 {
  int const oneM = 1000 * 1000;
  int const oneMeg = 1024 * 1024;
  for (StorageStats::iterator i = s_stats.begin (); i != s_stats.end(); ++i) {
    for (OperationStats::iterator j = i->second->begin(); j != i->second->end(); ++j) {
      std::ostringstream os;
      os << "Timing-" << i->first << "-" << 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(j->second.amount / oneMeg)));
      summary.insert(std::make_pair(os.str() + "totalMsecs", d2str(j->second.timeTotal / oneM)));
      summary.insert(std::make_pair(os.str() + "minMsecs", d2str(j->second.timeMin / oneM)));
      summary.insert(std::make_pair(os.str() + "maxMsecs", d2str(j->second.timeMax / oneM)));
    }
  }
}

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

static

Definition at line 92 of file StorageAccount.cc.

References s_stats.

{ return s_stats; }

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

static

Definition at line 35 of file StorageAccount.cc.

References first, i, j, and s_stats.

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 (StorageStats::iterator i = s_stats.begin (); i != s_stats.end(); ++i)
    for (OperationStats::iterator j = i->second->begin (); j != i->second->end (); ++j, first = false)
      os << (first ? "" : "; ")
         << i->first << '/'
         << j->first << '='
         << j->second.attempts << '/'
         << j->second.successes << '/'
         << (j->second.amount / 1024 / 1024) << "MB/"
         << (j->second.timeTotal / 1000 / 1000) << "ms/"
         << (j->second.timeMin / 1000 / 1000) << "ms/"
         << (j->second.timeMax / 1000 / 1000) << "ms";
 
  return os.str ();
}

std::string StorageAccount::summaryXML ( void  )

static

Definition at line 56 of file StorageAccount.cc.

References i, j, and s_stats.

                                {
  std::ostringstream os;
  os << "<storage-timing-summary>\n";
  for (StorageStats::iterator i = s_stats.begin (); i != s_stats.end(); ++i)
    for (OperationStats::iterator j = i->second->begin (); j != i->second->end (); ++j)
      os << " <counter-value subsystem='" << i->first
         << "' counter-name='" << j->first
         << "' num-operations='" << j->second.attempts
         << "' num-successful-operations='" << j->second.successes
         << "' total-megabytes='" << (j->second.amount / 1024 / 1024)
         << "' total-msecs='" << (j->second.timeTotal / 1000 / 1000)
         << "' min-msecs='" << (j->second.timeMin / 1000 / 1000)
         << "' max-msecs='" << (j->second.timeMax / 1000 / 1000) << "'/>\n";
  os << "</storage-timing-summary>";
  return os.str ();
}