25 #ifndef __MOTR_SNS_CM_CP_H__ 26 #define __MOTR_SNS_CM_CP_H__ 139 uint64_t stob_offset,
144 uint64_t stob_offset,
145 uint64_t data_seg_nr,
146 uint64_t failed_unit_index,
M0_INTERNAL void m0_sns_cm_cp_free(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_init(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_send(struct m0_cm_cp *cp, struct m0_fop_type *ft)
M0_INTERNAL void m0_sns_cm_cp_tgt_info_fill(struct m0_sns_cm_cp *scp, const struct m0_fid *cob_fid, uint64_t stob_offset, uint64_t ag_cp_idx)
M0_INTERNAL int m0_sns_cm_cp_send_wait(struct m0_cm_cp *cp)
struct m0_stob_id sc_stob_id
M0_INTERNAL struct m0_cob_domain * m0_sns_cm_cp2cdom(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_buf_acquire(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_recv_wait(struct m0_cm_cp *cp)
M0_INTERNAL void m0_sns_cm_cp_complete(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_write_pre(struct m0_cm_cp *cp)
const struct m0_cm_cp_ops m0_sns_cm_repair_cp_ops
M0_INTERNAL int m0_sns_cm_cp_recv_init(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_write(struct m0_cm_cp *cp)
struct m0_stob_io sc_stio
M0_INTERNAL int m0_sns_cm_cp_io_wait(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_phase_next(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_dup(struct m0_cm_cp *src, struct m0_cm_cp **dest)
const struct m0_cm_cp_ops m0_sns_cm_rebalance_cp_ops
static struct m0_fid cob_fid
M0_INTERNAL int m0_sns_cm_cp_setup(struct m0_sns_cm_cp *scp, const struct m0_fid *cob_fid, uint64_t stob_offset, uint64_t data_seg_nr, uint64_t failed_unit_index, uint64_t ag_cp_idx)
M0_INTERNAL bool m0_sns_cm_cp_invariant(const struct m0_cm_cp *cp)
const struct m0_cm_cp_ops m0_sns_cm_acc_cp_ops
M0_INTERNAL struct m0_cm * cpfom2cm(struct m0_fom *fom)
M0_INTERNAL struct m0_sns_cm_cp * cp2snscp(const struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_tx_open(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_read(struct m0_cm_cp *cp)
static struct m0_sns_cm_cp scp
M0_INTERNAL int m0_sns_cm_cp_fail(struct m0_cm_cp *cp)
M0_INTERNAL void m0_sns_cm_cp_buf_release(struct m0_cm_cp *cp)
static struct m0_fop_type * ft[]
M0_INTERNAL int m0_sns_cm_cp_tx_close(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_sw_check(struct m0_cm_cp *cp)
M0_INTERNAL uint64_t cp_home_loc_helper(const struct m0_cm_cp *cp)
struct m0_pdclust_src_addr src
struct m0_fol_frag sc_fol_frag
M0_INTERNAL int m0_sns_cm_cp_fini(struct m0_cm_cp *cp)
M0_INTERNAL int m0_sns_cm_cp_next_phase_get(int phase, struct m0_cm_cp *cp)