23 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_CM 33 #include "cm/repreb/sw_onwire_fop_xc.h" 68 "sns cm sw update fop",
75 "sns cm sw update rep fop",
76 m0_cm_sw_onwire_rep_xc,
90 uint64_t proxy_id,
const char *
local_ep,
99 #undef M0_TRACE_SUBSYSTEM
M0_INTERNAL void m0_cm_repreb_sw_onwire_fop_init(struct m0_fop_type *ft, const struct m0_fom_type_ops *fomt_ops, enum M0_RPC_OPCODES op, const char *name, const struct m0_xcode_type *xt, uint64_t rpc_flags, struct m0_cm_type *cmt)
static struct m0_addb2_mach * m
void fop_release(struct m0_ref *ref)
int(* fto_create)(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
struct m0_cm_type sns_rebalance_cmt
struct m0_fop_type sns_rebalance_sw_onwire_rep_fopt
return M0_ERR(-EOPNOTSUPP)
M0_INTERNAL void m0_sns_cm_rebalance_sw_onwire_fop_fini(void)
M0_INTERNAL void m0_cm_repreb_sw_onwire_fop_fini(struct m0_fop_type *ft)
struct m0_fop * m0_fop_reply_alloc(struct m0_fop *req, struct m0_fop_type *rept)
M0_INTERNAL int m0_cm_repreb_sw_onwire_fop_setup(struct m0_cm *cm, struct m0_fop_type *ft, 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)
const struct m0_fom_type_ops sns_rebalance_sw_fom_type_ops
static const char * local_ep(const struct m0_cm *cm)
static struct m0_fop * fop
static int sns_rebalance_sw_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
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)
M0_INTERNAL void m0_sns_cm_rebalance_sw_onwire_fop_init(void)
M0_INTERNAL int m0_sns_cm_rebalance_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)
struct m0_fop_type sns_rebalance_sw_onwire_fopt