addConnections(cms::Exception &) | XrdAdaptor::RequestManager | |
broadcastRequest(const ClientRequest &, bool active) | XrdAdaptor::RequestManager | private |
checkSources(timespec &now, IOSize requestSize) | XrdAdaptor::RequestManager | private |
checkSourcesImpl(timespec &now, IOSize requestSize) | XrdAdaptor::RequestManager | private |
compareSources(const timespec &now, unsigned a, unsigned b) | XrdAdaptor::RequestManager | private |
getActiveFile() | XrdAdaptor::RequestManager | |
getActiveSourceNames(std::vector< std::string > &sources) | XrdAdaptor::RequestManager | |
getDisabledSourceNames(std::vector< std::string > &sources) | 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) | 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 |
m_activeSites | XrdAdaptor::RequestManager | private |
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_serverToAdvertise | XrdAdaptor::RequestManager | private |
m_source_mutex | XrdAdaptor::RequestManager | private |
m_timeout | XrdAdaptor::RequestManager | private |
pickSingleSource() | XrdAdaptor::RequestManager | private |
prepareOpaqueString() | XrdAdaptor::RequestManager | private |
queueUpdateCurrentServer(const std::string &) | XrdAdaptor::RequestManager | private |
requestFailure(std::shared_ptr< XrdAdaptor::ClientRequest > c_ptr, XrdCl::Status &c_status) | 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) | XrdAdaptor::RequestManager | private |
updateCurrentServer() | XrdAdaptor::RequestManager | inlineprivate |
updateSiteInfo(std::string orig_site="") | XrdAdaptor::RequestManager | private |
XRD_DEFAULT_TIMEOUT | XrdAdaptor::RequestManager | static |
~RequestManager()=default | XrdAdaptor::RequestManager | |