25 #ifndef __MOTR_CAS_CLIENT_H__ 26 #define __MOTR_CAS_CLIENT_H__ 405 const struct m0_fid *start_fid,
M0_INTERNAL void m0_cas_req_fini(struct m0_cas_req *req)
struct m0_be_tx_remid ccr_remid
struct m0_rpc_session * ccr_sess
struct m0_cas_hint crr_hint
int const char const void size_t int flags
struct m0_cas_rep ccr_reply
M0_INTERNAL int m0_cas_index_list(struct m0_cas_req *req, const struct m0_fid *start_fid, uint32_t indices_nr, uint32_t flags)
static struct io_request req
static struct m0_sm_group * grp
M0_INTERNAL bool m0_cas_req_is_locked(const struct m0_cas_req *req)
M0_INTERNAL void m0_cas_get_rep(const struct m0_cas_req *req, uint64_t idx, struct m0_cas_get_reply *rep)
const struct m0_bufvec * ccr_keys
M0_INTERNAL void m0_cas_index_create_rep(const struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep)
struct m0_fop_type * ccr_ftype
struct m0_fop ccr_asmbl_fop
struct m0_fop_getxattr_rep * rep
M0_INTERNAL int m0_cas_get(struct m0_cas_req *req, struct m0_cas_id *index, const struct m0_bufvec *keys)
M0_INTERNAL void m0_cas_req_unlock(struct m0_cas_req *req)
M0_INTERNAL void m0_cas_req_lock(struct m0_cas_req *req)
uint64_t ccr_sent_recs_nr
M0_INTERNAL int m0_cas_req_generic_rc(const struct m0_cas_req *req)
M0_INTERNAL void m0_cas_req_init(struct m0_cas_req *req, struct m0_rpc_session *sess, struct m0_sm_group *grp)
M0_INTERNAL void m0_cas_put_rep(struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep)
M0_INTERNAL int m0_cas_next(struct m0_cas_req *req, struct m0_cas_id *index, struct m0_bufvec *start_keys, uint32_t *recs_nr, uint32_t flags)
M0_INTERNAL int m0_cas_versioned_get(struct m0_cas_req *req, struct m0_cas_id *index, const struct m0_bufvec *keys)
M0_INTERNAL void m0_cas_next_rep(const struct m0_cas_req *req, uint32_t idx, struct m0_cas_next_reply *rep)
struct m0_rpc_item * ccr_reply_item
M0_INTERNAL int m0_cas_sm_conf_init(void)
M0_INTERNAL int m0_cas_del(struct m0_cas_req *req, struct m0_cas_id *index, struct m0_bufvec *keys, struct m0_dtx *dtx, uint32_t flags)
M0_INTERNAL int m0_cas_index_create(struct m0_cas_req *req, const struct m0_cas_id *cids, uint64_t cids_nr, struct m0_dtx *dtx)
M0_INTERNAL void m0_cas_index_list_rep(struct m0_cas_req *req, uint32_t idx, struct m0_cas_ilist_reply *rep)
struct m0_sm_ast ccr_failure_ast
M0_INTERNAL int m0_cas_index_delete(struct m0_cas_req *req, const struct m0_cas_id *cids, uint64_t cids_nr, struct m0_dtx *dtx, uint32_t flags)
struct m0_cas_op * ccr_req_op
M0_INTERNAL void m0_cas_sm_conf_fini(void)
M0_INTERNAL void m0_cas_index_delete_rep(const struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep)
M0_INTERNAL void m0_cas_req_fini_lock(struct m0_cas_req *req)
M0_INTERNAL void m0_cas_del_rep(struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep)
M0_INTERNAL uint64_t m0_cas_req_nr(const struct m0_cas_req *req)
M0_INTERNAL int m0_cas_index_lookup(struct m0_cas_req *req, const struct m0_cas_id *cids, uint64_t cids_nr)
M0_INTERNAL int m0_cas_put(struct m0_cas_req *req, struct m0_cas_id *index, const struct m0_bufvec *keys, const struct m0_bufvec *values, struct m0_dtx *dtx, uint32_t flags)
struct m0_sm_ast ccr_replied_ast
M0_INTERNAL int m0_cas_req_wait(struct m0_cas_req *req, uint64_t states, m0_time_t to)
struct m0_cas_hint clr_hint
M0_INTERNAL void m0_cas_rep_mlock(const struct m0_cas_req *req, uint64_t idx)
struct m0_cas_recv ccr_rec_orig
M0_INTERNAL void m0_cas_index_lookup_rep(const struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep)
static struct m0_sm_state_descr states[C_NR]
uint64_t * ccr_asmbl_ikeys
uint64_t ccr_max_replies_nr
struct m0_cas_hint cnp_hint