daosFsCommon.h

Go to the documentation of this file.

#ifndef __daosFsCommon_h__
#define __daosFsCommon_h__
#include "ioHandle.h"
#include "pathHandler.h"
#include <daos.h>
#include <daos_fs.h>
#include <daos_obj.h>
#include <Options.h>
 
#include <forward_list>
class daosFsCommon: virtual public pathHandler {
  public:
    daos_handle_t poh;
    daos_handle_t coh;
    dfs_t*        dfs;
    int           flags;
    std::map<std::string, dfs_obj_t*> pathMap;
    dfs_obj_t* getDirObj(const std::string& path);
    
    class daosOptions {
    public:
        daosOptions(const std::string& optPrefix);
        options::single<std::string> containerName;
        options::single<std::string> poolName;
        options::single<std::string> sysName;
    };
protected:
    daosOptions& opt;
public:
    class attrDataType: public ioHandle::attrDataType {
        friend class daosFsIoCommon;
      protected:
      public:
        void fill(daosFsCommon& handler);
        ~attrDataType() override = default;
        void add(const std::string& name, const std::string& value);
        void set(ioHandle* handle) override;
    };
    daosFsCommon(daosOptions& aOpt, bool isWriter);
    ~daosFsCommon() override;
    bool pathExists(const std::string& path) override;
    std::unique_ptr<const genericStat> getStat(const std::string& path,
            bool followLink) override;
    std::string getXattr(const std::string& path,
                         const std::string& name) override;
};
 
class daosFsIoCommon: virtual public ioHandle {
  protected:
    const std::string& path;
    dfs_obj_t* obj;
    daosFsCommon& handler;
  public:
    class attrDataType: public ioHandle::attrDataType {
        friend class daosFsIoCommon;
      protected:
        void fill(daosFsIoCommon& handler);
      public:
        ~attrDataType() override = default;
        void add(const std::string& name, const std::string& value);
        void set(ioHandle* handle) override;
    };
    daosFsIoCommon(const std::string& aPath, daosFsCommon& aHandler);
    void setXattr(const std::string& name, const std::string& value) override;
    std::string getXattr(const std::string& name) override;
    void removeXattr(const std::string& name) override;
    std::unique_ptr<const genericStat> getStat() override;
    std::unique_ptr<ioHandle::attrDataType> getAttrData(const outputHandler::base* aOutputHandler) override;
};
 
#endif