edm::storage::StatisticsSenderService::FileStatistics Class Reference

Public Member Functions
	FileStatistics ()
void	fillUDP (std::ostringstream &os)

Private Attributes
ssize_t	m_read_single_bytes
ssize_t	m_read_single_operations
ssize_t	m_read_single_square
ssize_t	m_read_vector_bytes
ssize_t	m_read_vector_count_square
ssize_t	m_read_vector_count_sum
ssize_t	m_read_vector_operations
ssize_t	m_read_vector_square
time_t	m_start_time

Detailed Description

Definition at line 26 of file StatisticsSenderService.h.

Constructor & Destructor Documentation

StatisticsSenderService::FileStatistics::FileStatistics

(

)

Definition at line 36 of file StatisticsSenderService.cc.

                                                      :
  m_read_single_operations(0),
  m_read_single_bytes(0),
  m_read_single_square(0),
  m_read_vector_operations(0),
  m_read_vector_bytes(0),
  m_read_vector_square(0),
  m_read_vector_count_sum(0),
  m_read_vector_count_square(0),
  m_start_time(time(NULL))
{}

Member Function Documentation

void StatisticsSenderService::FileStatistics::fillUDP

(

std::ostringstream &

os

)

Definition at line 49 of file StatisticsSenderService.cc.

References i, j, NULL, StorageAccount::read, StorageAccount::readv, mathSSE::sqrt(), StorageAccount::summary(), cond::rpcobgas::time, StorageAccount::tokenForStorageClassName(), and UPDATE_AND_OUTPUT_STATISTIC.

Referenced by edm::storage::StatisticsSenderService::fillUDP().

                                                                   {
  const StorageAccount::StorageStats &stats = StorageAccount::summary();
  ssize_t read_single_operations = 0;
  ssize_t read_single_bytes = 0;
  ssize_t read_single_square = 0;
  ssize_t read_vector_operations = 0;
  ssize_t read_vector_bytes = 0;
  ssize_t read_vector_square = 0;
  ssize_t read_vector_count_sum = 0;
  ssize_t read_vector_count_square = 0;
  auto token = StorageAccount::tokenForStorageClassName("tstoragefile");
  for (StorageAccount::StorageStats::const_iterator i = stats.begin (); i != stats.end(); ++i) {
    if (i->first == token.value()) {
      continue;
    }
    for (StorageAccount::OperationStats::const_iterator j = i->second.begin(); j != i->second.end(); ++j) {
      if (j->first == static_cast<int>(StorageAccount::Operation::readv)) {
        read_vector_operations += j->second.attempts;
        read_vector_bytes += j->second.amount;
        read_vector_count_square += j->second.vector_square;
        read_vector_square += j->second.amount_square;
        read_vector_count_sum += j->second.vector_count;
      } else if (j->first == static_cast<int>(StorageAccount::Operation::read)) {
        read_single_operations += j->second.attempts;
        read_single_bytes += j->second.amount;
        read_single_square += j->second.amount_square;
      }
    }
  }
  int64_t single_op_count = read_single_operations - m_read_single_operations;
  if (single_op_count > 0) {
    double single_sum = read_single_bytes-m_read_single_bytes;
    double single_average = single_sum/static_cast<double>(single_op_count);
    os << "\"read_single_sigma\":" << sqrt((static_cast<double>(read_single_square-m_read_single_square) - single_average*single_average*single_op_count)/static_cast<double>(single_op_count)) << ", ";
    os << "\"read_single_average\":" << single_average << ", ";
  }
  m_read_single_square = read_single_square;
  int64_t vector_op_count = read_vector_operations - m_read_vector_operations;
  if (vector_op_count > 0) {
    double vector_average = static_cast<double>(read_vector_bytes-m_read_vector_bytes)/static_cast<double>(vector_op_count);
    os << "\"read_vector_average\":" << vector_average << ", ";
    os << "\"read_vector_sigma\":" << sqrt((static_cast<double>(read_vector_square-m_read_vector_square) - vector_average*vector_average*vector_op_count)/static_cast<double>(vector_op_count)) << ", ";
    double vector_count_average = static_cast<double>(read_vector_count_sum-m_read_vector_count_sum)/static_cast<double>(vector_op_count);
    os << "\"read_vector_count_average\":" << vector_count_average << ", ";
    os << "\"read_vector_count_sigma\":" << sqrt((static_cast<double>(read_vector_count_square-m_read_vector_count_square) - vector_count_average*vector_count_average*vector_op_count)/static_cast<double>(vector_op_count)) << ", ";
  }
  m_read_vector_square = read_vector_square;
  m_read_vector_count_square = read_vector_count_square;
  m_read_vector_count_sum = read_vector_count_sum;

  os << "\"read_bytes\":" << (read_vector_bytes + read_single_bytes - m_read_vector_bytes - m_read_single_bytes) << ", ";
  os << "\"read_bytes_at_close\":" << (read_vector_bytes + read_single_bytes - m_read_vector_bytes - m_read_single_bytes) << ", ";

  // See top of file for macros; not complex, just avoiding copy/paste
  UPDATE_AND_OUTPUT_STATISTIC(read_single_operations)
  UPDATE_AND_OUTPUT_STATISTIC(read_single_bytes)
  UPDATE_AND_OUTPUT_STATISTIC(read_vector_operations)
  UPDATE_AND_OUTPUT_STATISTIC(read_vector_bytes)

  os << "\"start_time\":" << m_start_time << ", ";
  m_start_time = time(NULL);
  // NOTE: last entry doesn't have the trailing comma.
  os << "\"end_time\":" << m_start_time;
}

Member Data Documentation

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_single_bytes

private

Definition at line 32 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_single_operations

private

Definition at line 31 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_single_square

private

Definition at line 33 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_vector_bytes

private

Definition at line 35 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_vector_count_square

private

Definition at line 38 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_vector_count_sum

private

Definition at line 37 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_vector_operations

private

Definition at line 34 of file StatisticsSenderService.h.

ssize_t edm::storage::StatisticsSenderService::FileStatistics::m_read_vector_square

private

Definition at line 36 of file StatisticsSenderService.h.

time_t edm::storage::StatisticsSenderService::FileStatistics::m_start_time

private

Definition at line 39 of file StatisticsSenderService.h.