daos_array.h

Go to the documentation of this file.

/*
 * (C) Copyright 2016-2021 Intel Corporation.
 *
 * SPDX-License-Identifier: BSD-2-Clause-Patent
 */
#ifndef __DAOS_ARRAY_H__
#define __DAOS_ARRAY_H__
 
#if defined(__cplusplus)
extern "C" {
#endif
 
typedef struct {
    daos_off_t      rg_idx;
    daos_size_t     rg_len;
} daos_range_t;
 
typedef struct {
    daos_size_t     arr_nr;
    daos_range_t           *arr_rgs;
    /*
     * On read only: return the number of records that are short fetched
     * from the largest dkey(s). This helps for checking for short reads. If
     * this values is not zero, then a short read is possible and should be
     * checked with daos_array_get_size() compared with the indexes being
     * read.
     */
    daos_size_t     arr_nr_short_read;
    daos_size_t     arr_nr_read;
} daos_array_iod_t;
 
static inline int
daos_array_generate_oid(daos_handle_t coh, daos_obj_id_t *oid, bool add_attr, daos_oclass_id_t cid,
            daos_oclass_hints_t hints, uint32_t args)
{
    enum daos_otype_t type;
 
    type = DAOS_OT_ARRAY_ATTR;
 
    if (add_attr)
        type = DAOS_OT_ARRAY;
 
    return daos_obj_generate_oid(coh, oid, type, cid, hints, args);
}
 
int
daos_array_create(daos_handle_t coh, daos_obj_id_t oid, daos_handle_t th,
          daos_size_t cell_size, daos_size_t chunk_size,
          daos_handle_t *oh, daos_event_t *ev);
 
int
daos_array_open(daos_handle_t coh, daos_obj_id_t oid, daos_handle_t th,
        unsigned int mode, daos_size_t *cell_size,
        daos_size_t *chunk_size, daos_handle_t *oh, daos_event_t *ev);
 
int
daos_array_open_with_attr(daos_handle_t coh, daos_obj_id_t oid,
              daos_handle_t th, unsigned int mode,
              daos_size_t cell_size, daos_size_t chunk_size,
              daos_handle_t *oh, daos_event_t *ev);
 
int
daos_array_local2global(daos_handle_t oh, d_iov_t *glob);
 
int
daos_array_global2local(daos_handle_t coh, d_iov_t glob, unsigned int mode,
            daos_handle_t *oh);
 
int
daos_array_close(daos_handle_t oh, daos_event_t *ev);
 
int
daos_array_read(daos_handle_t oh, daos_handle_t th, daos_array_iod_t *iod,
        d_sg_list_t *sgl, daos_event_t *ev);
 
int
daos_array_write(daos_handle_t oh, daos_handle_t th, daos_array_iod_t *iod,
         d_sg_list_t *sgl, daos_event_t *ev);
 
int
daos_array_get_size(daos_handle_t oh, daos_handle_t th, daos_size_t *size,
            daos_event_t *ev);
 
int
daos_array_set_size(daos_handle_t oh, daos_handle_t th, daos_size_t size,
            daos_event_t *ev);
 
int
daos_array_destroy(daos_handle_t oh, daos_handle_t th, daos_event_t *ev);
 
int
daos_array_punch(daos_handle_t oh, daos_handle_t th, daos_array_iod_t *iod,
         daos_event_t *ev);
 
int
daos_array_get_attr(daos_handle_t oh, daos_size_t *chunk_size,
            daos_size_t *cell_size);
 
#if defined(__cplusplus)
}
#endif
 
#endif /* __DAOS_ARRAY_H__ */