30 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DIXCM 40 uint64_t proxy_id,
const char *
local_ep,
42 const struct m0_cm_sw *out_interval);
95 #undef M0_TRACE_SUBSYSTEM
M0_INTERNAL struct m0_dix_cm * cm2dix(struct m0_cm *cm)
static struct m0_cm_cp * dix_repair_cm_cp_alloc(struct m0_cm *cm)
M0_EXTERN const struct m0_cm_cp_ops m0_dix_cm_repair_cp_ops
void fop_release(struct m0_ref *ref)
M0_INTERNAL int m0_dix_cm_data_next(struct m0_cm *cm, struct m0_cm_cp *cp)
static void dix_repair_cm_stop(struct m0_cm *cm)
M0_INTERNAL void m0_dix_cm_fini(struct m0_cm *cm)
const struct m0_cm_ops dix_repair_ops
M0_INTERNAL int m0_dix_cm_setup(struct m0_cm *cm)
static int dix_repair_cm_prepare(struct m0_cm *cm)
M0_INTERNAL int m0_dix_cm_ag_alloc(struct m0_cm *cm, const struct m0_cm_ag_id *id, bool has_incoming, struct m0_cm_aggr_group **out)
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)
const struct m0_cm_cp_ops * c_ops
M0_INTERNAL struct m0_cm_cp * m0_dix_cm_cp_alloc(struct m0_cm *cm)
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)
static const char * local_ep(const struct m0_cm *cm)
int(* cmo_setup)(struct m0_cm *cm)
static struct m0_fop * fop
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_stop(struct m0_cm *cm)
M0_INTERNAL int m0_dix_repair_sw_onwire_fop_setup(struct m0_cm *cm, struct m0_fop *fop, void(*fop_release)(struct m0_ref *), uint64_t proxy_id, const char *local_ep, const struct m0_cm_sw *sw, const struct m0_cm_sw *out_interval)