Motr
M0
|
#include "lib/time.h"
#include "lib/chan.h"
#include "fid/fid.h"
#include "fop/fop.h"
#include "cas/cas.h"
Go to the source code of this file.
Data Structures | |
struct | m0_cas_req |
struct | m0_cas_rec_reply |
struct | m0_cas_ilist_reply |
struct | m0_cas_get_reply |
struct | m0_cas_next_reply |
Macros | |
#define | __MOTR_CAS_CLIENT_H__ |
Enumerations | |
enum | m0_cas_req_state { CASREQ_INVALID, CASREQ_INIT, CASREQ_SENT, CASREQ_FRAGM_SENT, CASREQ_ASSEMBLY, CASREQ_FINAL, CASREQ_FAILURE, CASREQ_NR } |
Functions | |
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_req_fini (struct m0_cas_req *req) |
M0_INTERNAL void | m0_cas_req_fini_lock (struct m0_cas_req *req) |
M0_INTERNAL void | m0_cas_req_lock (struct m0_cas_req *req) |
M0_INTERNAL void | m0_cas_req_unlock (struct m0_cas_req *req) |
M0_INTERNAL bool | m0_cas_req_is_locked (const struct m0_cas_req *req) |
M0_INTERNAL int | m0_cas_req_generic_rc (const struct m0_cas_req *req) |
M0_INTERNAL uint64_t | m0_cas_req_nr (const struct m0_cas_req *req) |
M0_INTERNAL int | m0_cas_req_wait (struct m0_cas_req *req, uint64_t states, m0_time_t to) |
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_create_rep (const struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep) |
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) |
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 int | m0_cas_index_lookup (struct m0_cas_req *req, const struct m0_cas_id *cids, uint64_t cids_nr) |
M0_INTERNAL void | m0_cas_index_lookup_rep (const struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep) |
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) |
M0_INTERNAL void | m0_cas_index_list_rep (struct m0_cas_req *req, uint32_t idx, struct m0_cas_ilist_reply *rep) |
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) |
M0_INTERNAL void | m0_cas_put_rep (struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep) |
M0_INTERNAL void | m0_cas_rep_mlock (const struct m0_cas_req *req, uint64_t idx) |
M0_INTERNAL int | m0_cas_get (struct m0_cas_req *req, struct m0_cas_id *index, const struct m0_bufvec *keys) |
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_get_rep (const struct m0_cas_req *req, uint64_t idx, struct m0_cas_get_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 void | m0_cas_next_rep (const struct m0_cas_req *req, uint32_t idx, struct m0_cas_next_reply *rep) |
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 void | m0_cas_del_rep (struct m0_cas_req *req, uint64_t idx, struct m0_cas_rec_reply *rep) |
M0_INTERNAL int | m0_cas_sm_conf_init (void) |
M0_INTERNAL void | m0_cas_sm_conf_fini (void) |