daos_fs.h

Go to the documentation of this file.

/*
 * (C) Copyright 2018-2022 Intel Corporation.
 *
 * SPDX-License-Identifier: BSD-2-Clause-Patent
 */
#ifndef __DAOS_FS_H__
#define __DAOS_FS_H__
 
#if defined(__cplusplus)
extern "C" {
#endif
 
#include <dirent.h>
#include <sys/stat.h>
 
#define DFS_MAX_NAME        NAME_MAX
#define DFS_MAX_PATH        PATH_MAX
#define DFS_MAX_FSIZE       (~0ULL)
 
#define DFS_MAX_XATTR_NAME  255
#define DFS_MAX_XATTR_LEN   65536
 
typedef struct dfs_obj dfs_obj_t;
typedef struct dfs dfs_t;
 
/*
 * Consistency modes of the DFS container. A container created with balanced
 * mode, can only be accessed with balanced mode with dfs_mount. A container
 * created with relaxed mode, can be accessed with either mode in the future.
 *
 * Reserve bit 3 in the access flags for dfs_mount() - bits 1 and 2 are used
 * for read / write access (O_RDONLY, O_RDRW).
 */
#define DFS_BALANCED    4 
#define DFS_RELAXED 0 
#define DFS_RDONLY  O_RDONLY
#define DFS_RDWR    O_RDWR
 
typedef struct {
    uint64_t        da_id;
    daos_size_t     da_chunk_size;
    daos_oclass_id_t    da_oclass_id;
    daos_prop_t     *da_props;
    /*
     * Consistency mode for the DFS container: DFS_RELAXED, DFS_BALANCED.
     * If set to 0 or more generally not set to balanced explicitly, relaxed
     * mode will be used. In the future, Balanced mode will be the default.
     */
    uint32_t        da_mode;
} dfs_attr_t;
 
typedef struct {
    daos_size_t     iod_nr;
    daos_range_t           *iod_rgs;
} dfs_iod_t;
 
typedef struct {
    daos_oclass_id_t    doi_oclass_id;
    daos_size_t     doi_chunk_size;
} dfs_obj_info_t;
 
int
dfs_cont_create(daos_handle_t poh, uuid_t *uuid, dfs_attr_t *attr, daos_handle_t *coh, dfs_t **dfs);
 
int
dfs_cont_create_with_label(daos_handle_t poh, const char *label, dfs_attr_t *attr,
               uuid_t *uuid, daos_handle_t *coh, dfs_t **dfs);
 
int
dfs_mount(daos_handle_t poh, daos_handle_t coh, int flags, dfs_t **dfs);
 
int
dfs_umount(dfs_t *dfs);
 
int
dfs_query(dfs_t *dfs, dfs_attr_t *attr);
 
int
dfs_local2global(dfs_t *dfs, d_iov_t *glob);
 
int
dfs_global2local(daos_handle_t poh, daos_handle_t coh, int flags, d_iov_t glob,
         dfs_t **dfs);
 
int
dfs_set_prefix(dfs_t *dfs, const char *prefix);
 
int
dfs_obj2id(dfs_obj_t *obj, daos_obj_id_t *oid);
 
int
dfs_lookup(dfs_t *dfs, const char *path, int flags, dfs_obj_t **obj,
       mode_t *mode, struct stat *stbuf);
 
int
dfs_lookup_rel(dfs_t *dfs, dfs_obj_t *parent, const char *name, int flags,
           dfs_obj_t **obj, mode_t *mode, struct stat *stbuf);
 
int
dfs_open(dfs_t *dfs, dfs_obj_t *parent, const char *name, mode_t mode,
     int flags, daos_oclass_id_t cid, daos_size_t chunk_size,
     const char *value, dfs_obj_t **obj);
 
int
dfs_dup(dfs_t *dfs, dfs_obj_t *obj, int flags, dfs_obj_t **new_obj);
 
int
dfs_obj_local2global(dfs_t *dfs, dfs_obj_t *obj, d_iov_t *glob);
 
int
dfs_obj_global2local(dfs_t *dfs, int flags, d_iov_t glob, dfs_obj_t **obj);
 
int
dfs_release(dfs_obj_t *obj);
 
int
dfs_read(dfs_t *dfs, dfs_obj_t *obj, d_sg_list_t *sgl, daos_off_t off,
     daos_size_t *read_size, daos_event_t *ev);
 
int
dfs_readx(dfs_t *dfs, dfs_obj_t *obj, dfs_iod_t *iod, d_sg_list_t *sgl,
      daos_size_t *read_size, daos_event_t *ev);
 
int
dfs_write(dfs_t *dfs, dfs_obj_t *obj, d_sg_list_t *sgl, daos_off_t off,
      daos_event_t *ev);
 
int
dfs_writex(dfs_t *dfs, dfs_obj_t *obj, dfs_iod_t *iod, d_sg_list_t *sgl,
       daos_event_t *ev);
 
int
dfs_get_size(dfs_t *dfs, dfs_obj_t *obj, daos_size_t *size);
 
int
dfs_punch(dfs_t *dfs, dfs_obj_t *obj, daos_off_t offset, daos_size_t len);
 
int
dfs_readdir(dfs_t *dfs, dfs_obj_t *obj, daos_anchor_t *anchor,
        uint32_t *nr, struct dirent *dirs);
 
typedef int (*dfs_filler_cb_t)(dfs_t *dfs, dfs_obj_t *obj, const char name[],
                   void *arg);
 
int
dfs_iterate(dfs_t *dfs, dfs_obj_t *obj, daos_anchor_t *anchor,
        uint32_t *nr, size_t size, dfs_filler_cb_t op, void *arg);
 
int
dfs_obj_anchor_split(dfs_obj_t *obj, uint32_t *nr, daos_anchor_t *anchors);
 
int
dfs_obj_anchor_set(dfs_obj_t *obj, uint32_t index, daos_anchor_t *anchor);
 
int
dfs_mkdir(dfs_t *dfs, dfs_obj_t *parent, const char *name, mode_t mode,
      daos_oclass_id_t cid);
 
int
dfs_remove(dfs_t *dfs, dfs_obj_t *parent, const char *name, bool force,
       daos_obj_id_t *oid);
 
int
dfs_move(dfs_t *dfs, dfs_obj_t *parent, const char *name, dfs_obj_t *new_parent,
     const char *new_name, daos_obj_id_t *oid);
 
int
dfs_exchange(dfs_t *dfs, dfs_obj_t *parent1, const char *name1, dfs_obj_t *parent2,
         const char *name2);
 
int
dfs_get_mode(dfs_obj_t *obj, mode_t *mode);
 
int
dfs_obj_get_info(dfs_t *dfs, dfs_obj_t *obj, dfs_obj_info_t *info);
 
int
dfs_obj_set_oclass(dfs_t *dfs, dfs_obj_t *obj, int flags, daos_oclass_id_t cid);
 
int
dfs_obj_set_chunk_size(dfs_t *dfs, dfs_obj_t *obj, int flags,
               daos_size_t csize);
 
int
dfs_get_file_oh(dfs_obj_t *obj, daos_handle_t *oh);
 
int
dfs_get_chunk_size(dfs_obj_t *obj, daos_size_t *chunk_size);
 
int
dfs_get_symlink_value(dfs_obj_t *obj, char *buf, daos_size_t *size);
 
int
dfs_update_parent(dfs_obj_t *obj, dfs_obj_t *src_obj, const char *name);
 
int
dfs_stat(dfs_t *dfs, dfs_obj_t *parent, const char *name,
     struct stat *stbuf);
 
int
dfs_ostat(dfs_t *dfs, dfs_obj_t *obj, struct stat *stbuf);
 
#define DFS_SET_ATTR_MODE   (1 << 0)
#define DFS_SET_ATTR_ATIME  (1 << 1)
#define DFS_SET_ATTR_MTIME  (1 << 2)
#define DFS_SET_ATTR_SIZE   (1 << 3)
 
int
dfs_osetattr(dfs_t *dfs, dfs_obj_t *obj, struct stat *stbuf, int flags);
 
int
dfs_access(dfs_t *dfs, dfs_obj_t *parent, const char *name, int mask);
 
int
dfs_chmod(dfs_t *dfs, dfs_obj_t *parent, const char *name, mode_t mode);
 
int
dfs_sync(dfs_t *dfs);
 
int
dfs_setxattr(dfs_t *dfs, dfs_obj_t *obj, const char *name,
         const void *value, daos_size_t size, int flags);
 
int
dfs_getxattr(dfs_t *dfs, dfs_obj_t *obj, const char *name, void *value,
         daos_size_t *size);
 
int
dfs_removexattr(dfs_t *dfs, dfs_obj_t *obj, const char *name);
 
int
dfs_listxattr(dfs_t *dfs, dfs_obj_t *obj, char *list, daos_size_t *size);
 
int
dfs_cont_create2(daos_handle_t poh, uuid_t *cuuid, dfs_attr_t *attr, daos_handle_t *coh,
         dfs_t **dfs);
int
dfs_cont_create1(daos_handle_t poh, const uuid_t cuuid, dfs_attr_t *attr, daos_handle_t *coh,
         dfs_t **dfs);
 
#if defined(__cplusplus)
}
 
#define dfs_cont_create dfs_cont_create_cpp
static inline int
dfs_cont_create_cpp(daos_handle_t poh, uuid_t *cuuid, dfs_attr_t *attr, daos_handle_t *coh,
            dfs_t **dfs)
{
    return dfs_cont_create2(poh, cuuid, attr, coh, dfs);
}
 
static inline int
dfs_cont_create_cpp(daos_handle_t poh, const uuid_t cuuid, dfs_attr_t *attr, daos_handle_t *coh,
            dfs_t **dfs)
{
    return dfs_cont_create1(poh, cuuid, attr, coh, dfs);
};
#else
#define dfs_cont_create(poh, co, ...)                   \
    ({                              \
        int _ret;                       \
        uuid_t *_u;                     \
        if (d_is_uuid(co)) {                    \
            _u = (uuid_t *)((unsigned char *)(co));     \
            _ret = dfs_cont_create((poh), _u, __VA_ARGS__); \
        } else {                        \
            _u = (uuid_t *)(co);                \
            _ret = dfs_cont_create2((poh), _u, __VA_ARGS__); \
        }                           \
        _ret;                           \
    })
 
 
#endif /* __cplusplus */
#endif /* __DAOS_FS_H__ */