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 67 of file XrdStatistics.h.

Constructor & Destructor Documentation

XrdSiteStatistics() [1/2]

XrdSiteStatistics::XrdSiteStatistics

(

std::string const &

site

)

Definition at line 106 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) {}

XrdSiteStatistics() [2/2]

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

delete

Member Function Documentation

finishRead()

void XrdSiteStatistics::finishRead

(

XrdReadStatistics const &

readStats

)

Definition at line 147 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();
  }
}

getTotalBytes()

uint64_t XrdAdaptor::XrdSiteStatistics::getTotalBytes ( ) const

inline

Definition at line 86 of file XrdStatistics.h.

References m_readSize, and m_readvSize.

{ return m_readvSize + m_readSize; }

getTotalReadTime()

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

inline

Definition at line 87 of file XrdStatistics.h.

References m_readNS, and m_readvNS.

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

operator=()

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

delete

recomputeProperties()

void XrdSiteStatistics::recomputeProperties

(

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

props

)

Definition at line 134 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);
}

site()

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

inline

Definition at line 75 of file XrdStatistics.h.

References m_site.

{ return m_site; }

startRead()

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

static

Definition at line 116 of file XrdStatistics.cc.

References class-composition::parent, and 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

XrdReadStatistics

friend class XrdReadStatistics

friend

Definition at line 68 of file XrdStatistics.h.

Referenced by startRead().

Member Data Documentation

m_chunkCount

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

private

Definition at line 95 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

m_readCount

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

private

Definition at line 98 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

m_readNS

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

private

Definition at line 100 of file XrdStatistics.h.

Referenced by finishRead(), getTotalReadTime(), and recomputeProperties().

m_readSize

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

private

Definition at line 99 of file XrdStatistics.h.

Referenced by finishRead(), getTotalBytes(), and recomputeProperties().

m_readvCount

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

private

Definition at line 94 of file XrdStatistics.h.

Referenced by finishRead(), and recomputeProperties().

m_readvNS

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

private

Definition at line 97 of file XrdStatistics.h.

Referenced by finishRead(), getTotalReadTime(), and recomputeProperties().

m_readvSize

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

private

Definition at line 96 of file XrdStatistics.h.

Referenced by finishRead(), getTotalBytes(), and recomputeProperties().

m_site

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

private

Definition at line 92 of file XrdStatistics.h.

Referenced by site().