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>

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;
  }

};
DEFINE_EDM_PLUGIN (StorageMakerFactory, LStoreStorageMaker, "lstore");