XrdAdaptor::XrdSiteStatistics Class Reference

#include <XrdStatistics.h>

Public Member Functions
void	finishRead (XrdReadStatistics const &)
uint64_t	getTotalBytes () const
std::chrono::nanoseconds	getTotalReadTime ()
XrdSiteStatistics &	operator= (const XrdSiteStatistics &)=delete
void	recomputeProperties (std::map< std::string, std::string > &props)
std::string const &	site () const
	XrdSiteStatistics (std::string const &site)
	XrdSiteStatistics (const XrdSiteStatistics &)=delete

Static Public Member Functions
static std::shared_ptr< XrdReadStatistics >	startRead (std::shared_ptr< XrdSiteStatistics > parent, std::shared_ptr< ClientRequest > req)

Private Attributes
std::atomic< unsigned >	m_chunkCount
std::atomic< unsigned >	m_readCount
std::atomic< uint64_t >	m_readNS
std::atomic< uint64_t >	m_readSize
std::atomic< unsigned >	m_readvCount
std::atomic< uint64_t >	m_readvNS
std::atomic< uint64_t >	m_readvSize
const std::string	m_site = "Unknown"

Friends
class	XrdReadStatistics

Detailed Description

Definition at line 71 of file XrdStatistics.h.

Constructor & Destructor Documentation

XrdSiteStatistics::XrdSiteStatistics

(

std::string const &

site

)

Definition at line 100 of file XrdStatistics.cc.

    : m_site(site),
      m_readvCount(0),
      m_chunkCount(0),
      m_readvSize(0),
      m_readvNS(0.0),
      m_readCount(0),
      m_readSize(0),
      m_readNS(0) {}

XrdAdaptor::XrdSiteStatistics::XrdSiteStatistics ( const XrdSiteStatistics &  )

delete

Member Function Documentation

void XrdSiteStatistics::finishRead

(

XrdReadStatistics const &

readStats

)

Definition at line 141 of file XrdStatistics.cc.

References XrdAdaptor::XrdReadStatistics::elapsedNS(), m_chunkCount, m_readCount, m_readNS, m_readSize, m_readvCount, m_readvNS, m_readvSize, XrdAdaptor::XrdReadStatistics::readCount(), and XrdAdaptor::XrdReadStatistics::size().

                                                                     {
  if (readStats.readCount() > 1) {
    m_readvCount++;
    m_chunkCount += readStats.readCount();
    m_readvSize += readStats.size();
    m_readvNS += readStats.elapsedNS();
  } else {
    m_readCount++;
    m_readSize += readStats.size();
    m_readNS += readStats.elapsedNS();
  }
}

uint64_t XrdAdaptor::XrdSiteStatistics::getTotalBytes ( ) const

inline

Definition at line 90 of file XrdStatistics.h.

{ return m_readvSize + m_readSize; }

std::chrono::nanoseconds XrdAdaptor::XrdSiteStatistics::getTotalReadTime ( )

inline

Definition at line 91 of file XrdStatistics.h.

                                            {
      return std::chrono::nanoseconds(m_readvNS) + std::chrono::nanoseconds(m_readNS);
    }

XrdSiteStatistics& XrdAdaptor::XrdSiteStatistics::operator= ( const XrdSiteStatistics &  )

delete

void XrdSiteStatistics::recomputeProperties

(

std::map< std::string, std::string > &

props

)

Definition at line 128 of file XrdStatistics.cc.

References d2str(), i2str(), m_chunkCount, m_readCount, m_readNS, m_readSize, m_readvCount, m_readvNS, and m_readvSize.

                                                                               {
  props.clear();

  props["readv-numOperations"] = i2str(m_readvCount);
  props["readv-numChunks"] = i2str(m_chunkCount);
  props["readv-totalMegabytes"] = d2str(static_cast<float>(m_readvSize) / (1024.0 * 1024.0));
  props["readv-totalMsecs"] = d2str(m_readvNS / 1e6);

  props["read-numOperations"] = i2str(m_readCount);
  props["read-totalMegabytes"] = d2str(static_cast<float>(m_readSize) / (1024.0 * 1024.0));
  props["read-totalMsecs"] = d2str(static_cast<float>(m_readNS) / 1e6);
}

std::string const& XrdAdaptor::XrdSiteStatistics::site ( ) const

inline

Definition at line 79 of file XrdStatistics.h.

References class-composition::parent.

{ return m_site; }

std::shared_ptr< XrdReadStatistics > XrdSiteStatistics::startRead ( std::shared_ptr< XrdSiteStatistics >  parent, std::shared_ptr< ClientRequest >  req  )

static

Definition at line 110 of file XrdStatistics.cc.

References XrdReadStatistics.

Referenced by XrdAdaptor::Source::handle().

                                                                                                  {
  std::shared_ptr<XrdReadStatistics> readStats(new XrdReadStatistics(parent, req->getSize(), req->getCount()));
  return readStats;
}

Friends And Related Function Documentation

friend class XrdReadStatistics

friend

Definition at line 72 of file XrdStatistics.h.

Referenced by startRead().

Member Data Documentation

std::atomic<unsigned> XrdAdaptor::XrdSiteStatistics::m_chunkCount

private

Definition at line 99 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

std::atomic<unsigned> XrdAdaptor::XrdSiteStatistics::m_readCount

private

Definition at line 102 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

std::atomic<uint64_t> XrdAdaptor::XrdSiteStatistics::m_readNS

private

Definition at line 104 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

std::atomic<uint64_t> XrdAdaptor::XrdSiteStatistics::m_readSize

private

Definition at line 103 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

std::atomic<unsigned> XrdAdaptor::XrdSiteStatistics::m_readvCount

private

Definition at line 98 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

std::atomic<uint64_t> XrdAdaptor::XrdSiteStatistics::m_readvNS

private

Definition at line 101 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

std::atomic<uint64_t> XrdAdaptor::XrdSiteStatistics::m_readvSize

private

Definition at line 100 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

const std::string XrdAdaptor::XrdSiteStatistics::m_site = "Unknown"

private

Definition at line 96 of file XrdStatistics.h.