#include <algorithm>
#include <cassert>
#include <iostream>
#include <memory>
#include <netdb.h>
#include "XrdCl/XrdClFile.hh"
#include "XrdCl/XrdClDefaultEnv.hh"
#include "XrdCl/XrdClFileSystem.hh"
#include "FWCore/Utilities/interface/CPUTimer.h"
#include "FWCore/Utilities/interface/EDMException.h"
#include "FWCore/Utilities/interface/Likely.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/Utilities/interface/thread_safety_macros.h"
#include "Utilities/StorageFactory/interface/StatisticsSenderService.h"
#include "XrdStatistics.h"
#include "Utilities/XrdAdaptor/src/XrdRequestManager.h"
#include "Utilities/XrdAdaptor/src/XrdHostHandler.hh"
Go to the source code of this file.
Classes | |
class | SendMonitoringInfoHandler |
Macros | |
#define | GET_CLOCK_MONOTONIC(ts) clock_gettime(CLOCK_MONOTONIC, &ts); |
Functions | |
static void | consumeChunkBack (size_t front, std::vector< IOPosBuffer > &input, std::vector< IOPosBuffer > &output, IOSize chunksize) |
static void | consumeChunkFront (size_t &front, std::vector< IOPosBuffer > &input, std::vector< IOPosBuffer > &output, IOSize chunksize) |
static void | SendMonitoringInfo (XrdCl::File &file) |
long long | timeDiffMS (const timespec &a, const timespec &b) |
static IOSize | validateList (const std::vector< IOPosBuffer > req) |
Variables | |
static constexpr int | XRD_ADAPTOR_CHUNK_THRESHOLD = 1000 |
static constexpr int | XRD_ADAPTOR_LONG_OPEN_DELAY = 2 * 60 |
static constexpr int | XRD_ADAPTOR_OPEN_PROBE_PERCENT = 10 |
static constexpr int | XRD_ADAPTOR_SHORT_OPEN_DELAY = 5 |
static constexpr int | XRD_ADAPTOR_SOURCE_QUALITY_FUDGE = 100 |
static constexpr int | XRD_CL_MAX_CHUNK = 512 * 1024 |
#define GET_CLOCK_MONOTONIC | ( | ts | ) | clock_gettime(CLOCK_MONOTONIC, &ts); |
Definition at line 56 of file XrdRequestManager.cc.
Referenced by XrdAdaptor::RequestManager::handle(), XrdAdaptor::RequestManager::OpenHandler::HandleResponseWithHosts(), XrdAdaptor::RequestManager::initialize(), and XrdAdaptor::RequestManager::requestFailure().
|
static |
Definition at line 863 of file XrdRequestManager.cc.
References edm::storage::IOPosBuffer::data(), edm::storage::IOPosBuffer::offset(), edm::storage::IOPosBuffer::set_data(), edm::storage::IOPosBuffer::set_offset(), edm::storage::IOPosBuffer::set_size(), edm::storage::IOPosBuffer::size(), XRD_ADAPTOR_CHUNK_THRESHOLD, and XRD_CL_MAX_CHUNK.
Referenced by XrdAdaptor::RequestManager::splitClientRequest().
|
static |
Definition at line 824 of file XrdRequestManager.cc.
References edm::storage::IOPosBuffer::data(), edm::storage::IOPosBuffer::offset(), edm::storage::IOPosBuffer::set_data(), edm::storage::IOPosBuffer::set_offset(), edm::storage::IOPosBuffer::set_size(), edm::storage::IOPosBuffer::size(), XRD_ADAPTOR_CHUNK_THRESHOLD, and XRD_CL_MAX_CHUNK.
Referenced by XrdAdaptor::RequestManager::splitClientRequest().
|
static |
Definition at line 98 of file XrdRequestManager.cc.
References edm::storage::StatisticsSenderService::getJobID(), XrdAdaptor::Source::isDCachePool(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by XrdAdaptor::RequestManager::OpenHandler::HandleResponseWithHosts(), and XrdAdaptor::RequestManager::initialize().
long long timeDiffMS | ( | const timespec & | a, |
const timespec & | b | ||
) |
Definition at line 62 of file XrdRequestManager.cc.
References change_name::diff.
Referenced by XrdAdaptor::RequestManager::checkSources(), and XrdAdaptor::RequestManager::checkSourcesImpl().
|
static |
Definition at line 902 of file XrdRequestManager.cc.
References cms::cuda::assert(), dqmMemoryStats::total, and XRD_CL_MAX_CHUNK.
Referenced by XrdAdaptor::RequestManager::splitClientRequest().
|
static |
Definition at line 40 of file XrdRequestManager.cc.
Referenced by consumeChunkBack(), consumeChunkFront(), and XrdAdaptor::RequestManager::splitClientRequest().
|
static |
Definition at line 36 of file XrdRequestManager.cc.
Referenced by XrdAdaptor::RequestManager::checkSourcesImpl(), and XrdAdaptor::RequestManager::handleOpen().
|
static |
Definition at line 35 of file XrdRequestManager.cc.
Referenced by XrdAdaptor::RequestManager::checkSourcesImpl().
|
static |
Definition at line 27 of file XrdRequestManager.cc.
Referenced by XrdAdaptor::RequestManager::checkSourcesImpl(), XrdAdaptor::RequestManager::handleOpen(), and XrdAdaptor::RequestManager::initialize().
|
static |
Definition at line 37 of file XrdRequestManager.cc.
Referenced by XrdAdaptor::RequestManager::checkSourcesImpl().
|
static |
Definition at line 25 of file XrdRequestManager.cc.
Referenced by consumeChunkBack(), consumeChunkFront(), XrdAdaptor::RequestManager::splitClientRequest(), and validateList().