XrdSource.h

Go to the documentation of this file.

#ifndef Utilities_XrdAdaptor_XrdSource_h
#define Utilities_XrdAdaptor_XrdSource_h

#include "XrdCl/XrdClXRootDResponses.hh"
#include "FWCore/Utilities/interface/get_underlying_safe.h"

#include <memory>
#include <vector>

#include "QualityMetric.h"

namespace XrdCl {
  class File;
}

namespace XrdAdaptor {

  class RequestList;
  class ClientRequest;
  class XrdSiteStatistics;
  class XrdStatisticsService;

  class Source : public std::enable_shared_from_this<Source> {
  public:
    Source(const Source &) = delete;
    Source &operator=(const Source &) = delete;

    Source(timespec now, std::unique_ptr<XrdCl::File> fileHandle, const std::string &exclude);

    ~Source();

    void handle(std::shared_ptr<ClientRequest>);

    void handle(RequestList &);

    std::shared_ptr<XrdCl::File> getFileHandle();

    const std::string &ID() const { return m_id; }
    const std::string &Site() const { return m_site; }
    const std::string &PrettyID() const { return m_prettyid; }
    const std::string &ExcludeID() const { return m_exclude; }

    unsigned getQuality() { return m_qm->get(); }

    struct timespec getLastDowngrade() const {
      return m_lastDowngrade;
    }
    void setLastDowngrade(struct timespec now) { m_lastDowngrade = now; }

    static bool getDomain(const std::string &host, std::string &domain);
    static bool getXrootdSite(XrdCl::File &file, std::string &site);
    static bool getXrootdSiteFromURL(std::string url, std::string &site);

    // Given a file and (possibly) a host list, determine the exclude string.
    static void determineHostExcludeString(XrdCl::File &file, const XrdCl::HostList *hostList, std::string &exclude);

    // Given a connected File object, determine whether we believe this to be a
    // dCache pool (dCache is a separate implementation and sometimes benefits from
    // implementation-specific behaviors.
    static bool isDCachePool(XrdCl::File &file, const XrdCl::HostList *hostList = nullptr);
    static bool isDCachePool(const std::string &url);

    // Given an Xrootd server ID, determine the hostname to the best of our ability.
    static bool getHostname(const std::string &id, std::string &hostname);

  private:
    void requestCallback(/* TODO: type? */);

    void setXrootdSite();

    std::shared_ptr<XrdCl::File const> fh() const { return get_underlying_safe(m_fh); }
    std::shared_ptr<XrdCl::File> &fh() { return get_underlying_safe(m_fh); }
    std::shared_ptr<XrdSiteStatistics const> stats() const { return get_underlying_safe(m_stats); }
    std::shared_ptr<XrdSiteStatistics> &stats() { return get_underlying_safe(m_stats); }

    struct timespec m_lastDowngrade;
    std::string m_id;
    std::string m_prettyid;
    std::string m_site;
    std::string m_exclude;
    edm::propagate_const<std::shared_ptr<XrdCl::File>> m_fh;

    edm::propagate_const<std::unique_ptr<QualityMetricSource>> m_qm;
    edm::propagate_const<std::shared_ptr<XrdSiteStatistics>> m_stats;

#ifdef XRD_FAKE_SLOW
    bool m_slow;
#endif
  };

}  // namespace XrdAdaptor

#endif