23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_SNSCM 110 #undef M0_TRACE_SUBSYSTEM
M0_INTERNAL void m0_sns_cm_svc_stop(struct m0_reqh_service *service)
int(* rso_start)(struct m0_reqh_service *service)
static const struct m0_reqh_service_ops rebalance_svc_ops
M0_INTERNAL void m0_sns_cm_rebalance_trigger_fop_init(void)
M0_INTERNAL int m0_sns_cm_svc_start(struct m0_reqh_service *service)
M0_INTERNAL void m0_sns_cm_rebalance_sw_onwire_fop_fini(void)
const struct m0_cm_ops sns_rebalance_ops
const struct m0_fom_type_ops rebalance_cp_fom_type_ops
M0_INTERNAL void m0_sns_cm_rebalance_sw_onwire_fop_init(void)
M0_INTERNAL int m0_sns_cm_svc_allocate(struct m0_reqh_service **service, const struct m0_reqh_service_type *stype, const struct m0_reqh_service_ops *svc_ops, const struct m0_cm_ops *cm_ops)
M0_INTERNAL void m0_sns_cm_svc_fini(struct m0_reqh_service *service)
static const struct socktype stype[]
M0_INTERNAL void m0_sns_cm_rebalance_cpx_init(void)
M0_INTERNAL void m0_sns_cm_rebalance_cpx_fini(void)
int m0_reqh_service_async_start_simple(struct m0_reqh_service_start_async_ctx *asc)
static int rebalance_svc_allocate(struct m0_reqh_service **service, const struct m0_reqh_service_type *stype)
M0_INTERNAL void m0_sns_cm_rebalance_trigger_fop_fini(void)
static const struct m0_reqh_service_type_ops rebalance_svc_type_ops
int(* rsto_service_allocate)(struct m0_reqh_service **service, const struct m0_reqh_service_type *stype)
static int rebalance_svc_start(struct m0_reqh_service *service)
M0_CM_TYPE_DECLARE(sns_rebalance, M0_CM_REBALANCE_OPCODE, &rebalance_svc_type_ops, "M0_CST_SNS_REB", M0_CST_SNS_REB)
M0_EXTERN struct m0_cm_type sns_rebalance_cmt
M0_INTERNAL void m0_cm_cp_init(struct m0_cm_type *cmtype, const struct m0_fom_type_ops *ft_ops)
static void rebalance_svc_stop(struct m0_reqh_service *service)
static struct m0_reqh_service * service[REQH_IN_UT_MAX]