LStoreStorageMaker.cc

Go to the documentation of this file.

#include "Utilities/StorageFactory/interface/StorageMaker.h"
#include "Utilities/StorageFactory/interface/StorageMakerFactory.h"
#include "Utilities/StorageFactory/interface/StorageFactory.h"
#include "Utilities/LStoreAdaptor/interface/LStoreFile.h"
#include "FWCore/Utilities/interface/Exception.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include <unistd.h>
#include <iostream>

namespace edm::storage {
  class LStoreStorageMaker : public StorageMaker {
  public:
    std::unique_ptr<Storage> open(const std::string &proto,
                                  const std::string &path,
                                  int mode,
                                  const AuxSettings &) const override {
      std::string fullpath = proto + ":" + path;
      return std::make_unique<LStoreFile>(fullpath, mode);
    }

    /* I don't think this is necessary - Melo
  virtual void stagein (const std::string &proto, const std::string &path)
  {
    std::string fullpath(proto + ":" + path);
    XrdClientAdmin admin(fullpath.c_str());
    if (admin.Connect())
    {
      XrdOucString str(fullpath.c_str());
      XrdClientUrlSet url(str);
      admin.Prepare(url.GetFile().c_str(), kXR_stage | kXR_noerrs, 0);
    }
  }
*/

    bool check(const std::string &proto,
               const std::string &path,
               const AuxSettings &,
               IOOffset *size = nullptr) const override {
      std::string fullpath = proto + ":" + path;
      try {
        LStoreFile fileObj(fullpath);  // = LStoreFile (fullpath);
        *size = fileObj.position(0, Storage::END);
      } catch (cms::Exception &e) {
        return false;
      }
      return true;
    }
  };
}  // namespace edm::storage

using namespace edm::storage;
DEFINE_EDM_PLUGIN(StorageMakerFactory, LStoreStorageMaker, "lstore");