XrdSource.cc File Reference

#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
static void	validateList (const XrdCl::ChunkList &cl)

Variables
std::atomic< int >	g_delayCount {0}

Macro Definition Documentation

#define _GLIBCXX_USE_NANOSLEEP

Definition at line 3 of file XrdSource.cc.

#define MAX_REQUEST   256 * 1024

Definition at line 21 of file XrdSource.cc.

#define XRD_CL_MAX_CHUNK   512 * 1024

Definition at line 22 of file XrdSource.cc.

Referenced by validateList().

Function Documentation

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

static

Definition at line 365 of file XrdSource.cc.

References 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::atomic<int> g_delayCount {0}

Definition at line 30 of file XrdSource.cc.

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