25 #ifndef __MOTR_CM_CP_H__ 26 #define __MOTR_CM_CP_H__
M0_INTERNAL void m0_cm_cp_buf_release(struct m0_cm_cp *cp)
bool(* co_invariant)(const struct m0_cm_cp *cp)
M0_INTERNAL void m0_cm_cp_only_fini(struct m0_cm_cp *cp)
M0_INTERNAL void m0_cm_cp_fom_fini(struct m0_fom *fom)
struct m0_chan c_reply_wait
static struct m0_addb2_mach * m
struct m0_bitmap c_xform_cp_indices
struct m0_mutex c_reply_wait_mutex
M0_INTERNAL int m0_cm_cp_fom_create(struct m0_fop *fop, struct m0_fop *r_fop, struct m0_fom **m, struct m0_reqh *reqh)
M0_INTERNAL void m0_cm_cp_fom_init(struct m0_cm *cm, struct m0_cm_cp *cp, struct m0_fop *fop, struct m0_fop *r_fop)
M0_INTERNAL int m0_cm_cp_bufvec_split(struct m0_cm_cp *cp)
M0_INTERNAL void m0_cm_cp_only_init(struct m0_cm *cm, struct m0_cm_cp *cp)
M0_INTERNAL int m0_cm_cp_dup(struct m0_cm_cp *src, struct m0_cm_cp **dest)
M0_INTERNAL void m0_cm_cp_data_copy(struct m0_cm_cp *src, struct m0_cm_cp *dst)
enum m0_cm_cp_io_op c_io_op
struct m0_tlink c_cm_proxy_linkage
struct m0_rpc_bulk c_bulk
M0_INTERNAL void m0_cm_cp_buf_move(struct m0_cm_cp *src, struct m0_cm_cp *dest)
M0_TL_DESCR_DECLARE(cp_data_buf, M0_EXTERN)
M0_INTERNAL void m0_cm_cp_fini(struct m0_cm_cp *cp)
const struct m0_cm_cp_ops * c_ops
M0_INTERNAL void m0_cm_cp_buf_add(struct m0_cm_cp *cp, struct m0_net_buffer *nb)
int(* co_action[])(struct m0_cm_cp *cp)
M0_TL_DECLARE(cp_data_buf, M0_INTERNAL, struct m0_net_buffer)
struct m0_cm_aggr_group * c_ag
M0_INTERNAL int m0_cm_cp_bufvec_merge(struct m0_cm_cp *cp)
M0_INTERNAL int m0_cm_cp_enqueue(struct m0_cm *cm, struct m0_cm_cp *cp)
struct m0_cm_proxy * c_cm_proxy
void(* co_complete)(struct m0_cm_cp *cp)
static struct m0_fop * fop
int(* co_phase_next)(struct m0_cm_cp *cp)
void(* co_free)(struct m0_cm_cp *cp)
uint64_t(* co_home_loc_helper)(const struct m0_cm_cp *cp)
M0_INTERNAL void m0_cm_cp_init(struct m0_cm_type *cmtype, const struct m0_fom_type_ops *ft_ops)
enum m0_cm_cp_priority c_prio
M0_INTERNAL uint64_t m0_cm_cp_nr(struct m0_cm_cp *cp)
M0_INTERNAL bool m0_cm_cp_invariant(const struct m0_cm_cp *cp)
struct m0_pdclust_src_addr src