23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_CM 61 .
scf_name =
"Repair/re-balance sw update",
95 if (cm_proxy !=
NULL) {
106 rfop =
fom->fo_rep_fop;
162 #undef M0_TRACE_SUBSYSTEM
uint64_t cm_aggr_grps_in_nr
M0_INTERNAL void m0_cm_lock(struct m0_cm *cm)
#define ID_LOG(prefix, id)
struct m0_cm_sw swo_in_interval
#define M0_LOG(level,...)
void * m0_fop_data(const struct m0_fop *fop)
struct m0_cm_local_ep swo_cm_ep
uint64_t cm_aggr_grps_out_nr
struct m0_fom_type ft_fom_type
M0_INTERNAL void m0_cm_unlock(struct m0_cm *cm)
void m0_fom_init(struct m0_fom *fom, const struct m0_fom_type *fom_type, const struct m0_fom_ops *ops, struct m0_fop *fop, struct m0_fop *reply, struct m0_reqh *reqh)
struct m0_fop_type * f_type
return M0_ERR(-EOPNOTSUPP)
M0_INTERNAL uint64_t m0_rnd(uint64_t max, uint64_t *seed)
static int repreb_sw_fom_tick(struct m0_fom *fom)
void m0_fom_fini(struct m0_fom *fom)
struct m0_cm_sw swo_out_interval
static void repreb_sw_fom_fini(struct m0_fom *fom)
M0_INTERNAL int m0_cm_proxy_update(struct m0_cm_proxy *pxy, struct m0_cm_sw *in_interval, struct m0_cm_sw *out_interval, uint32_t px_status, m0_time_t px_epoch)
void m0_rpc_reply_post(struct m0_rpc_item *request, struct m0_rpc_item *reply)
static const struct m0_fom_ops repreb_sw_fom_ops
M0_INTERNAL struct m0_cm * m0_cmsvc2cm(struct m0_reqh_service *cmsvc)
#define M0_ALLOC_PTR(ptr)
static size_t repreb_sw_fom_home_locality(const struct m0_fom *fom)
static struct m0_sm_state_descr repreb_sw_fom_phases[]
M0_INTERNAL struct m0_cm_proxy * m0_cm_proxy_locate(struct m0_cm *cm, const char *addr)
static struct m0_fop * fop
void(* fo_fini)(struct m0_fom *fom)
const struct m0_sm_conf m0_cm_repreb_sw_onwire_conf
void m0_fom_phase_set(struct m0_fom *fom, int phase)
M0_INTERNAL int m0_cm_repreb_sw_onwire_fom_create(struct m0_fop *fop, struct m0_fop *r_fop, struct m0_fom **out, struct m0_reqh *reqh)
struct m0_rpc_item f_item
static struct m0_reqh_service * service[REQH_IN_UT_MAX]
#define M0_IMPOSSIBLE(fmt,...)