FWStorage/DCacheAdaptor/plugins/DCacheStorageMaker.cc - master - githubmirror/cmssw

FWStorage/DCacheAdaptor/plugins/DCacheStorageMaker.cc
92 строки3 KB
Chris Jones
Moved Utilities/DCacheAdaptor to FWStorage/DCacheAdaptor
10 дек 2025, 18:30
10 дек 2025, 18:30c3949be
#include "FWStorage/StorageFactory/interface/StorageMaker.h"
#include "FWStorage/StorageFactory/interface/StorageMakerFactory.h"
#include "FWStorage/StorageFactory/interface/StorageFactory.h"
#include "FWStorage/DCacheAdaptor/interface/DCacheFile.h"
#include "FWCore/Utilities/interface/Exception.h"
#include <unistd.h>
#include <dcap.h>

namespace edm::storage {
  class DCacheStorageMaker : public StorageMaker {
    /** Return appropriate path for use with dcap library.  If the path is in the
      URL form ([gsi]dcap://host:port/path), return the full URL as it is.  If
      the path is /pnfs form (dcap:/pnfs/path), return only the path part, unless
      the protocol is 'gsidcap', in which case return the whole thing.  */
    static std::string normalise(const std::string &proto, const std::string &path) {
      size_t p = path.find("/pnfs");
      if (p < 3)
        return (proto == "gsidcap") ? proto + ':' + path.substr(p) : path.substr(p);

      // remove multiple "/"
      p = path.find_first_not_of('/');

      // it's url, return the full thing
      return proto + "://" + path.substr(p);
    }

  public:
    /** Open a storage object for the given URL (protocol + path), using the
      @a mode bits.  No temporary files are downloaded.  */
    std::unique_ptr<Storage> open(const std::string &proto,
                                  const std::string &path,
                                  int mode,
                                  AuxSettings const &aux) const override {
      setTimeout(aux.timeout);
      const StorageFactory *f = StorageFactory::get();
      StorageFactory::ReadHint readHint = f->readHint();
      StorageFactory::CacheHint cacheHint = f->cacheHint();

      if (readHint != StorageFactory::READ_HINT_UNBUFFERED || cacheHint == StorageFactory::CACHE_HINT_STORAGE)
        mode &= ~IOFlags::OpenUnbuffered;
      else
        mode |= IOFlags::OpenUnbuffered;

      return std::make_unique<DCacheFile>(normalise(proto, path), mode);
    }

    void stagein(const std::string &proto, const std::string &path, const AuxSettings &aux) const override {
      setTimeout(aux.timeout);
      std::string npath = normalise(proto, path);
      if (dc_stage(npath.c_str(), 0, nullptr) != 0) {
        cms::Exception ex("FileStageInError");
        ex << "Cannot stage in file '" << npath << "', error was: " << dc_strerror(dc_errno)
           << " (dc_errno=" << dc_errno << ")";
        ex.addContext("Calling DCacheStorageMaker::stagein()");
        throw ex;
      }
    }

    bool check(const std::string &proto,
               const std::string &path,
               const AuxSettings &aux,
               IOOffset *size = nullptr) const override {
      setTimeout(aux.timeout);
      std::string testpath(normalise(proto, path));
      if (dc_access(testpath.c_str(), R_OK) != 0)
        return false;

      if (size) {
        struct stat64 buf;
        if (dc_stat64(testpath.c_str(), &buf) != 0)
          return false;

        *size = buf.st_size;
      }

      return true;
    }

    UseLocalFile usesLocalFile() const override { return UseLocalFile::kNo; }

  private:
    void setTimeout(unsigned int timeout) const {
      if (timeout != 0)
        dc_setOpenTimeout(timeout);
    }
  };
}  // namespace edm::storage

using namespace edm::storage;
DEFINE_EDM_PLUGIN(StorageMakerFactory, DCacheStorageMaker, "dcache");
DEFINE_EDM_PLUGIN(StorageMakerFactory, DCacheStorageMaker, "dcap");
DEFINE_EDM_PLUGIN(StorageMakerFactory, DCacheStorageMaker, "gsidcap");