inputHandlerDaosFs.h

Go to the documentation of this file.

#ifndef __inputHandlerDaosFs_h__
#define __inputHandlerDaosFs_h__
#include "inputHandler.h"
#include "daosFsCommon.h"
#include <Options.h>
#include <deque>
#include <dirent.h>
#include <string>
#include <sys/stat.h>
#include <sys/types.h>
 
 
namespace inputHandler {
 
    class daosFs: public base, virtual public daosFsCommon {
        static factoryTemplate<daosFs> factory;
    public:
 
        class readerDaosFs: public reader, virtual public daosFsIoCommon {
          public:
            readerDaosFs(const std::string& aPath,
                            copyRequest::stateType &state,
                         const genericStat& inititalStat,
                         daosFsCommon& aHandler);
            ~readerDaosFs() override;
            bool parallelizable() const override;
            bool readBlock(block &b) override;
            void readBlockP(block& b, size_t bytesToRead, off_t offset) override;
            void checkUnchangedness() override;
        };
        daosFs();
        ~daosFs() override = default;
        std::unique_ptr<reader> newReader(const std::string& aPath,
                                          copyRequest::stateType &state,
                                          const genericStat& inititalStat) override;
        bool readLinkTarget(const std::string& path,
                            std::vector<char>& target) override;
 
 
        class DaosFsDirectory: public Directory {
            daosFs& handler;
            dfs_obj_t *dir;
            daos_anchor_t anchor;
          public:
            DaosFsDirectory(daosFs& aHandler, const std::string& path);
            ~DaosFsDirectory() noexcept(false) override;
            std::unique_ptr<Entry> getNextEntry(bool ignoreMissing) override;
        };
        std::unique_ptr<Directory> getDirectory(const std::string& path) override;
 
    };
 
} // end namespace inputHandler
#endif