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 405 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().