30 #include "rpc/ub/fops_xc.h" 116 m0_xc_rpc_ub_fops_init();
119 .
name =
"RPC UB request",
127 .
name =
"RPC UB response",
137 m0_xc_rpc_ub_fops_fini();
static const struct m0_fom_type_ops ub_req_fom_type_ops
static struct m0_addb2_mach * m
static size_t ub_req_fom_home_locality(const struct m0_fom *fom)
#define M0_UB_ASSERT(cond)
#define M0_FOP_TYPE_INIT(ft,...)
M0_INTERNAL void m0_rpc_ub_fops_init(void)
static struct io_request req
struct m0_fop_type m0_rpc_ub_resp_fopt
int(* fto_create)(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
struct m0_reqh_service_type ds1_service_type
void * m0_fop_data(const struct m0_fop *fop)
void m0_fop_type_fini(struct m0_fop_type *fopt)
static struct m0_xcode_type ** xt[]
const struct m0_sm_conf m0_generic_conf
static int ub_req_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
struct m0_fom_type ft_fom_type
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)
static void ub_req_fom_fini(struct m0_fom *fom)
int m0_fom_tick_generic(struct m0_fom *fom)
void m0_fom_fini(struct m0_fom *fom)
void m0_fom_phase_move(struct m0_fom *fom, int32_t rc, int phase)
static const struct m0_fom_ops ub_req_fom_ops
M0_INTERNAL int m0_buf_copy(struct m0_buf *dest, const struct m0_buf *src)
struct m0_fop * m0_fop_reply_alloc(struct m0_fop *req, struct m0_fop_type *rept)
static int ub_req_fom_tick(struct m0_fom *fom)
#define M0_ALLOC_PTR(ptr)
struct m0_fop_type m0_rpc_ub_req_fopt
static struct m0_fop * fop
void(* fo_fini)(struct m0_fom *fom)
M0_INTERNAL void m0_rpc_ub_fops_fini(void)