|
M0_INTERNAL int | m0_dix_cm_cp_sw_check (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_send_wait (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_repair_cp_send (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_rebalance_cp_send (struct m0_cm_cp *cp) |
|
M0_INTERNAL struct m0_dix_cm_cp * | cp2dixcp (const struct m0_cm_cp *cp) |
|
static struct m0_dix_cm * | cp2dixcm (struct m0_cm_cp *cp) |
|
M0_INTERNAL bool | m0_dix_cm_cp_invariant (const struct m0_cm_cp *cp) |
|
M0_INTERNAL uint64_t | m0_dix_cm_cp_home_loc_helper (const struct m0_cm_cp *cp) |
|
M0_INTERNAL struct m0_cm_cp * | m0_dix_cm_cp_alloc (struct m0_cm *cm) |
|
static void | dix_cm_cp_dtx_fini (struct m0_cm_cp *cp) |
|
static int | dix_cm_cp_dtx_failure (struct m0_cm_cp *cp) |
|
static int | dix_cm_cp_incoming_kv (struct m0_rpc_at_buf *ab_key, struct m0_rpc_at_buf *ab_val, struct m0_buf *key, struct m0_buf *val) |
|
static void | dixcpx_to_dixcp (const struct m0_dix_cpx *dix_cpx, struct m0_dix_cm_cp *dix_cp) |
|
static void | dix_cm_cp_reply_send (struct m0_cm_cp *cp, struct m0_fop_type *ft, int rc) |
|
static int | dix_cm_fom_tx_wait (struct m0_fom *fom) |
|
M0_INTERNAL int | m0_dix_cm_cp_init (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_fail (struct m0_cm_cp *cp, struct m0_fop_type *ft) |
|
static int | dix_cm_repair_cp_fail (struct m0_cm_cp *cp) |
|
static int | dix_cm_rebalance_cp_fail (struct m0_cm_cp *cp) |
|
M0_INTERNAL void | m0_dix_cm_cp_complete (struct m0_cm_cp *cp) |
|
M0_INTERNAL void | m0_dix_cm_cp_free (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_fini (struct m0_cm_cp *cp) |
|
M0_INTERNAL void | m0_dix_cm_cp_tgt_info_fill (struct m0_dix_cm_cp *dix_cp, const struct m0_fid *cctg_fid) |
|
M0_INTERNAL void | m0_dix_cm_cp_setup (struct m0_dix_cm_cp *dix_cp, const struct m0_fid *cctg_fid, uint64_t failed_unit_index) |
|
M0_INTERNAL int | m0_dix_cm_cp_dup (struct m0_cm_cp *src, struct m0_cm_cp **dest) |
|
M0_INTERNAL int | m0_dix_cm_cp_read (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_xform (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_write_pre (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_tx_open (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_write (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_tx_done (struct m0_cm_cp *cp) |
|
M0_INTERNAL int | m0_dix_cm_cp_io_wait (struct m0_cm_cp *cp, struct m0_fop_type *ft) |
|
static int | dix_cm_repair_cp_io_wait (struct m0_cm_cp *cp) |
|
static int | dix_cm_rebalance_cp_io_wait (struct m0_cm_cp *cp) |
|