addConnections(cms::Exception &) const | XrdAdaptor::RequestManager | |
broadcastRequest(const ClientRequest &, bool active) | XrdAdaptor::RequestManager | private |
checkSources(timespec &now, IOSize requestSize, std::vector< std::shared_ptr< Source >> &activeSources, std::vector< std::shared_ptr< Source >> &inactiveSources) | XrdAdaptor::RequestManager | private |
checkSourcesImpl(timespec &now, IOSize requestSize, std::vector< std::shared_ptr< Source >> &activeSources, std::vector< std::shared_ptr< Source >> &inactiveSources) | XrdAdaptor::RequestManager | private |
compareSources(const timespec &now, unsigned a, unsigned b, std::vector< std::shared_ptr< Source >> &activeSources, std::vector< std::shared_ptr< Source >> &inactiveSources) const | XrdAdaptor::RequestManager | private |
getActiveFile() const | XrdAdaptor::RequestManager | |
getActiveSourceNames(std::vector< std::string > &sources) const | XrdAdaptor::RequestManager | |
getDisabledSourceNames(std::vector< std::string > &sources) const | XrdAdaptor::RequestManager | |
getFilename() const | XrdAdaptor::RequestManager | inline |
getInstance(const std::string &filename, XrdCl::OpenFlags::Flags flags, XrdCl::Access::Mode perms) | XrdAdaptor::RequestManager | inlinestatic |
getPrettyActiveSourceNames(std::vector< std::string > &sources) const | XrdAdaptor::RequestManager | |
handle(void *into, IOSize size, IOOffset off) | XrdAdaptor::RequestManager | inline |
handle(std::shared_ptr< std::vector< IOPosBuffer >> iolist) | XrdAdaptor::RequestManager | |
handle(std::shared_ptr< XrdAdaptor::ClientRequest > c_ptr) | XrdAdaptor::RequestManager | |
handleOpen(XrdCl::XRootDStatus &status, std::shared_ptr< Source >) | XrdAdaptor::RequestManager | privatevirtual |
initialize(std::weak_ptr< RequestManager > selfref) | XrdAdaptor::RequestManager | private |
IOOffset typedef | XrdAdaptor::RequestManager | |
IOPosBuffer typedef | XrdAdaptor::RequestManager | |
IOSize typedef | XrdAdaptor::RequestManager | |
m_activeSources | XrdAdaptor::RequestManager | private |
m_disabledExcludeStrings | XrdAdaptor::RequestManager | private |
m_disabledSources | XrdAdaptor::RequestManager | private |
m_disabledSourceStrings | XrdAdaptor::RequestManager | private |
m_distribution | XrdAdaptor::RequestManager | private |
m_excluded_active_count | XrdAdaptor::RequestManager | private |
m_flags | XrdAdaptor::RequestManager | private |
m_generator | XrdAdaptor::RequestManager | private |
m_inactiveSources | XrdAdaptor::RequestManager | private |
m_lastSourceCheck | XrdAdaptor::RequestManager | private |
m_name | XrdAdaptor::RequestManager | private |
m_nextActiveSourceCheck | XrdAdaptor::RequestManager | private |
m_nextInitialSourceToggle | XrdAdaptor::RequestManager | private |
m_open_handler | XrdAdaptor::RequestManager | private |
m_perms | XrdAdaptor::RequestManager | private |
m_redirectLimitDelayScale | XrdAdaptor::RequestManager | private |
m_serverToAdvertise | XrdAdaptor::RequestManager | private |
m_source_mutex | XrdAdaptor::RequestManager | mutableprivate |
m_timeout | XrdAdaptor::RequestManager | private |
operator=(const RequestManager &)=delete | XrdAdaptor::RequestManager | |
pickSingleSource() | XrdAdaptor::RequestManager | private |
prepareOpaqueString() const | XrdAdaptor::RequestManager | private |
queueUpdateCurrentServer(const std::string &) | XrdAdaptor::RequestManager | private |
reportSiteChange(std::vector< std::shared_ptr< Source >> const &iOld, std::vector< std::shared_ptr< Source >> const &iNew, std::string orig_site=std::string{}) const | XrdAdaptor::RequestManager | private |
requestFailure(std::shared_ptr< XrdAdaptor::ClientRequest > c_ptr, XrdCl::Status &c_status) | XrdAdaptor::RequestManager | |
RequestManager(const RequestManager &)=delete | XrdAdaptor::RequestManager | |
RequestManager(const std::string &filename, XrdCl::OpenFlags::Flags flags, XrdCl::Access::Mode perms) | XrdAdaptor::RequestManager | private |
searchMode | XrdAdaptor::RequestManager | private |
splitClientRequest(const std::vector< IOPosBuffer > &iolist, std::vector< IOPosBuffer > &req1, std::vector< IOPosBuffer > &req2, std::vector< std::shared_ptr< Source >> const &activeSources) const | XrdAdaptor::RequestManager | private |
updateCurrentServer() | XrdAdaptor::RequestManager | inlineprivate |
XRD_DEFAULT_TIMEOUT | XrdAdaptor::RequestManager | static |
~RequestManager()=default | XrdAdaptor::RequestManager | virtual |