outputHandlerGpfs.h

Go to the documentation of this file.

#ifndef __outputHandlerGpfs_h__
#define __outputHandlerGpfs_h__
#include "outputHandlerPosixFile.h"
#include "gpfsCommon.h"
#include "Options.h"
 
namespace outputHandler {
 
    class Gpfs: public posixFile {
        static factoryTemplate<Gpfs> factory;
      public:
        class writerGpfs: public writerPosixFile, virtual public gpfsIoCommon {
            static options::single<bool> usePreallocate;
            void doSpecialFdHandling(size_t sourceSize);
            void setAclData();
          public:
            writerGpfs(const std::string& aPath,
                       bool mightAppend,
                       size_t sourceSize,
                       size_t readBlockSize,
                       copyRequest::stateType &state,
                       bool noWrite,
                       std::unique_ptr<ioHandle::attrDataType> attrData,
                       std::unique_ptr<acl::list> aAclData);
            writerGpfs(std::string& aPath,
                       size_t sourceSize,
                       bool noWrite,
                       std::unique_ptr<ioHandle::attrDataType> aAttrData,
                       std::unique_ptr<acl::list> aAclData,
                       base& handler);
            ~writerGpfs() noexcept(false) override;
            void writeBlock(const block& b) override;
            void writeBlockP(const block& b) override;
        };
        Gpfs() = default;
        ~Gpfs() override = default;
        std::unique_ptr<writer> newWriter(const std::string& path,
                                          bool mightAppend,
                                          size_t sourceSize,
                                          size_t readBlockSize,
                                          copyRequest::stateType &state,
                                          bool noWrite,
                                          std::unique_ptr<ioHandle::attrDataType>,
                                          std::unique_ptr<acl::list> aclData) override;
        std::unique_ptr<writer> newTmpWriter(std::string& path,
                                             size_t /*sourceSize*/,
                                             bool noWrite,
                                             std::unique_ptr<ioHandle::attrDataType> attrData,
                                             std::unique_ptr<acl::list> aclData) override;
        base::renameRetvalType rename(const std::string& fromPath,
                                      const std::unique_ptr<const genericStat>& readInitialStat,
                                      const std::string& toPath,
                                      copyRequest::stateType& state) override;
    };
}; // end namespace outputHandler
 
 
#endif