XrdSource.cc File Reference

#include <memory>
#include <thread>
#include <chrono>
#include <atomic>
#include <iostream>
#include <cassert>
#include <netdb.h>
#include "XrdCl/XrdClFile.hh"
#include "FWCore/Utilities/interface/EDMException.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "XrdSource.h"
#include "XrdRequest.h"
#include "QualityMetric.h"
#include "XrdStatistics.h"

Go to the source code of this file.

Classes
class	DelayedClose
class	QueryAttrHandler
struct	QueryAttrHandler::QueryAttrState

Macros
#define	_GLIBCXX_USE_NANOSLEEP
#define	MAX_REQUEST   256 * 1024
#define	XRD_CL_MAX_CHUNK   512 * 1024

Functions
	assert (m_qm.get())
	assert (m_fh.get())
	if (getDomain(m_id, domain_id))
	if (statsService)
	m_exclude (exclude)
	m_fh (std::move(fh))
	m_id ("(unknown)")
	setXrootdSite ()
static void	validateList (const XrdCl::ChunkList &cl)

Variables
std::string	domain_id
	else
std::atomic< int >	g_delayCount {0}
	m_prettyid = m_id + " (unknown site)"
XrdSiteStatisticsInformation *	statsService = XrdSiteStatisticsInformation::getInstance()

Macro Definition Documentation

#define _GLIBCXX_USE_NANOSLEEP

Definition at line 3 of file XrdSource.cc.

#define MAX_REQUEST   256 * 1024

Definition at line 23 of file XrdSource.cc.

#define XRD_CL_MAX_CHUNK   512 * 1024

Definition at line 24 of file XrdSource.cc.

Referenced by validateList().

Function Documentation

assert

(

m_qm.

get()

)

assert

(

m_fh.

get()

)

if

(

getDomain(m_id, domain_id)

)

Definition at line 207 of file XrdSource.cc.

References domain_id.

                                  {
    m_site = domain_id;
  } else {

if

(

statsService

)

Definition at line 216 of file XrdSource.cc.

References XrdAdaptor::XrdSiteStatisticsInformation::getStatisticsForSite().

                    {
    m_stats = statsService->getStatisticsForSite(m_site);
  }

m_exclude

(

exclude

)

m_fh

(

std::

movefh

)

Referenced by DelayedClose::DelayedClose().

m_id

(

"(unknown)"

)

Referenced by DelayedClose::HandleResponseWithHosts(), and edmNew::DetSet< T >::set().

setXrootdSite

(

)

static void validateList ( const XrdCl::ChunkList &  cl )

static

Definition at line 371 of file XrdSource.cc.

References cms::cuda::assert(), and XRD_CL_MAX_CHUNK.

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

                                                   {
  off_t last_offset = -1;
  for (const auto &ci : cl) {
    assert(static_cast<off_t>(ci.offset) > last_offset);
    last_offset = ci.offset;
    assert(ci.length <= XRD_CL_MAX_CHUNK);
    assert(ci.offset < 0x1ffffffffff);
    assert(ci.offset > 0);
  }
  assert(cl.size() <= 1024);
}

Variable Documentation

std::string domain_id

Definition at line 206 of file XrdSource.cc.

Referenced by if().

else

Initial value:

{
    m_site = "Unknown (" + m_id + ")"

Definition at line 209 of file XrdSource.cc.

std::atomic<int> g_delayCount {0}

Definition at line 32 of file XrdSource.cc.

m_prettyid = m_id + " (unknown site)"

Definition at line 205 of file XrdSource.cc.

XrdSiteStatisticsInformation* statsService = XrdSiteStatisticsInformation::getInstance()

Definition at line 215 of file XrdSource.cc.

Referenced by TStorageFactoryFile::Initialize(), and XrdAdaptor::RequestManager::updateCurrentServer().