25 #ifndef __MOTR_DIX_CM_H__ 26 #define __MOTR_DIX_CM_H__ 98 #define M0_DIX_CM_TYPE_DECLARE(cmtype, id, ops, name, typecode) \ 99 M0_CM_TYPE_DECLARE(cmtype, id, ops, name, typecode); \ 100 M0_INTERNAL struct m0_dix_cm_type cmtype ## _dcmt = { \ 101 .dct_base = &cmtype ## _cmt, \ 259 M0_INTERNAL
enum dix_repair_state
M0_INTERNAL void m0_dix_cm_rebalance_trigger_fop_init(void)
M0_INTERNAL struct m0_dix_cm * cm2dix(struct m0_cm *cm)
M0_INTERNAL int m0_dix_cm_prepare(struct m0_cm *cm)
M0_EXTERN struct m0_cm_type dix_rebalance_cmt
M0_INTERNAL void m0_dix_rebalance_sw_onwire_fop_fini(void)
struct m0_cm_type * dct_base
struct m0_clink dcm_proxies_completed
M0_INTERNAL void m0_dix_repair_sw_onwire_fop_fini(void)
M0_INTERNAL void m0_dix_cm_repair_trigger_fop_init(void)
M0_EXTERN const struct m0_cm_cp_ops m0_dix_cm_repair_cp_ops
M0_INTERNAL void m0_dix_cm_svc_fini(struct m0_reqh_service *service)
M0_INTERNAL void m0_dix_cm_repair_trigger_fop_fini(void)
M0_INTERNAL int m0_dix_cm_data_next(struct m0_cm *cm, struct m0_cm_cp *cp)
M0_INTERNAL void m0_dix_cm_fini(struct m0_cm *cm)
M0_INTERNAL void m0_dix_rebalance_sw_onwire_fop_init(void)
M0_INTERNAL int m0_dix_cm_setup(struct m0_cm *cm)
M0_INTERNAL enum dix_repair_state m0_dix_cm_fid_repair_done(struct m0_fid *gfid, struct m0_reqh *reqh, enum m0_pool_nd_state device_state)
M0_EXTERN struct m0_dix_cm_type dix_rebalance_dcmt
M0_INTERNAL int m0_dix_cm_ag_next(struct m0_cm *cm, const struct m0_cm_ag_id *id_curr, struct m0_cm_ag_id *id_next)
M0_INTERNAL void m0_dix_cm_type_deregister(void)
M0_EXTERN struct m0_dix_cm_type dix_repair_dcmt
M0_EXTERN const struct m0_cm_cp_ops m0_dix_cm_rebalance_cp_ops
M0_INTERNAL int m0_dix_cm_start(struct m0_cm *cm)
M0_INTERNAL bool m0_dix_is_peer(struct m0_cm *cm, struct m0_reqh_service_ctx *ctx)
M0_EXTERN struct m0_cm_type dix_repair_cmt
M0_INTERNAL void m0_dix_repair_sw_onwire_fop_init(void)
struct m0_dix_cm_type * dcm_type
struct m0_fom_type dct_iter_fomt
M0_INTERNAL int m0_dix_cm_type_register(void)
M0_INTERNAL struct m0_reqh * m0_dix_cm2reqh(const struct m0_dix_cm *dcm)
M0_INTERNAL int m0_dix_get_space_for(struct m0_cm *cm, const struct m0_cm_ag_id *id, size_t *count)
M0_INTERNAL void m0_dix_cm_rebalance_trigger_fop_fini(void)
M0_INTERNAL void m0_dix_cm_stop(struct m0_cm *cm)
static struct m0_reqh_service * service[REQH_IN_UT_MAX]
struct m0_dix_cm_iter dcm_it