25 #ifndef __MOTR_CLIENT_H__ 26 #define __MOTR_CLIENT_H__ 840 #define M0_COMPOSITE_EXTENT_INF (0xffffffffffffffff) 1575 uint64_t wcount, uint64_t rcount,
1579 uint64_t wcount, uint64_t rcount,
1583 uint64_t wcount, uint64_t rcount,
1761 struct m0_obj *sub_obj,
int priority);
1780 bool write,
struct m0_idx *idx);
static struct m0_semaphore wait
enum m0_client_layout_type m0_obj_layout_type(struct m0_obj *obj)
void m0_entity_fini(struct m0_entity *entity)
struct m0_mutex en_pending_tx_lock
void m0_obj_lock_put(struct m0_rm_lock_req *req)
int const char const void size_t int flags
const struct m0_op_ops * op_cbs
const char * mc_process_fid
void m0_op_fini(struct m0_op *op)
static struct io_request req
int m0_obj_read_lock_get(struct m0_obj *obj, struct m0_rm_lock_req *req, struct m0_clink *clink)
void(* oop_executed)(struct m0_op *op)
struct m0_mutex op_pending_tx_lock
int m0_entity_sync(struct m0_entity *ent)
uint64_t m0_obj_unit_size_to_layout_id(int unit_size)
void m0_process_fid(const struct m0_client *m0c, struct m0_fid *proc_fid)
int m0_obj_write_lock_get_sync(struct m0_obj *obj, struct m0_rm_lock_req *req)
int32_t m0_rc(const struct m0_op *op)
void m0_client_fini(struct m0_client *m0c, bool fini_m0)
int m0_obj_lock_init(struct m0_obj *obj)
int m0_obj_write_lock_get(struct m0_obj *obj, struct m0_rm_lock_req *req, struct m0_clink *clink)
static struct m0_clovis * m0c
uint64_t m0_client_layout_id(const struct m0_client *instance)
enum m0_entity_opcode M0_XCA_ENUM
int m0_sync_op_add(struct m0_op *sop, struct m0_op *op)
void m0_idx_fini(struct m0_idx *idx)
struct m0_idx_attr in_attr
int m0_client_init(struct m0_client **m0c, struct m0_config *conf, bool init_m0)
const struct m0_uint128 M0_UBER_REALM
void m0_obj_lock_fini(struct m0_obj *obj)
void m0_composite_layer_idx_val_from_buf(struct m0_composite_layer_idx_val *val, void *vbuf)
void m0__dtx_init(struct m0__dtx *dtx, struct m0_realm *parent, const struct m0_uint128 *id)
const struct m0_uint128 M0_ID_APP
int32_t m0_op_wait(struct m0_op *op, uint64_t bits, m0_time_t to)
struct m0_tl en_pending_tx
int m0_idx_op(struct m0_idx *idx, enum m0_idx_opcode opcode, struct m0_bufvec *keys, struct m0_bufvec *vals, int32_t *rcs, uint32_t flags, struct m0_op **op)
int m0_obj_op(struct m0_obj *obj, enum m0_obj_opcode opcode, struct m0_indexvec *ext, struct m0_bufvec *data, struct m0_bufvec *attr, uint64_t mask, uint32_t flags, struct m0_op **op)
static uint32_t unit_size
struct m0_entity in_entity
enum m0_client_layout_type ml_type
int m0_obj_layout_id_to_unit_size(uint64_t layout_id)
struct m0_sm_ast op_parent_ast
int m0_obj_read_lock_get_sync(struct m0_obj *obj, struct m0_rm_lock_req *req)
struct m0_client_layout * m0_client_layout_alloc(enum m0_client_layout_type type)
static void attr(struct m0_addb2__context *ctx, const uint64_t *v, char *buf)
void(* oop_stable)(struct m0_op *op)
void m0_composite_layer_idx_key_from_buf(struct m0_composite_layer_idx_key *key, void *kbuf)
struct m0_entity re_entity
size_t m0_op_maxsize(void)
void m0_realm_open(struct m0_realm *realm, uint64_t wcount, uint64_t rcount, struct m0_op **op)
void m0_client_layout_free(struct m0_client_layout *layout)
int m0_composite_layer_idx(struct m0_uint128 layer_id, bool write, struct m0_idx *idx)
void m0_obj_fini(struct m0_obj *obj)
int m0_composite_layer_idx_key_to_buf(struct m0_composite_layer_idx_key *key, void **out_kbuf, m0_bcount_t *out_klen)
void m0_op_launch(struct m0_op **op, uint32_t nr)
struct m0_client_layout * ob_layout
int m0_sync_entity_add(struct m0_op *sop, struct m0_entity *ent)
void m0_composite_layer_del(struct m0_client_layout *layout, struct m0_uint128 subobj_id)
enum m0_realm_type re_type
struct m0_entity ml_entity
int m0_sync(struct m0_client *m0c, bool wait)
static struct m0_clink clink[RDWR_REQUEST_MAX]
int m0_sync_op_init(struct m0_op **sop)
void(* oop_failed)(struct m0_op *op)
void m0_op_cancel(struct m0_op **op, uint32_t nr)
static struct m0_pool pool
void * mc_idx_service_conf
struct m0_uint128 cek_layer_id
int m0_entity_create(struct m0_fid *pool, struct m0_entity *entity, struct m0_op **op)
struct m0_realm * en_realm
struct m0_sm_group en_sm_group
uint32_t mc_max_rpc_msg_size
struct m0_sm_group op_sm_group
const char * mc_local_addr
void m0_obj_idx_init(struct m0_idx *idx, const struct m0_obj *obj)
static struct m0_realm realm
struct m0_entity * op_entity
int m0_composite_layer_add(struct m0_client_layout *layout, struct m0_obj *sub_obj, int priority)
uint32_t mc_tm_recv_queue_min_len
struct m0_entity ob_entity
int m0_client_layout_op(struct m0_obj *obj, enum m0_entity_opcode opcode, struct m0_client_layout *layout, struct m0_op **op)
const struct m0_client_layout_ops * ml_ops
void m0_obj_init(struct m0_obj *obj, struct m0_realm *parent, const struct m0_uint128 *id, uint64_t layout_id)
static struct m0 instance
int m0_client_layout_capture(struct m0_client_layout *layout, struct m0_obj *obj, struct m0_client_layout **out)
int m0_entity_delete(struct m0_entity *entity, struct m0_op **op)
void m0_container_init(struct m0_container *con, struct m0_realm *parent, const struct m0_uint128 *id, struct m0_client *instance)
struct m0_client * re_instance
void m0_op_kick(struct m0_op *op)
void m0_op_free(struct m0_op *op)
struct m0_tl op_pending_tx
int m0_entity_open(struct m0_entity *entity, struct m0_op **op)
struct m0_cookie ob_cookie
void m0_realm_close(struct m0_realm *realm, uint64_t wcount, uint64_t rcount, struct m0_op **op)
void m0_realm_create(struct m0_realm *realm, uint64_t wcount, uint64_t rcount, struct m0_op **op)
struct m0_mutex op_priv_lock
int m0_composite_layer_idx_val_to_buf(struct m0_composite_layer_idx_val *val, void **out_vbuf, m0_bcount_t *out_vlen)
enum m0_entity_type en_type
void m0_idx_init(struct m0_idx *idx, struct m0_realm *parent, const struct m0_uint128 *id)
struct m0_obj_attr ob_attr
void m0_epoch_init(struct m0_epoch *epoch, struct m0_realm *parent, const struct m0_uint128 *id)
void m0_op_setup(struct m0_op *op, const struct m0_op_ops *cbs, m0_time_t linger)