29 #include "rpc/ut/fops_xc.h" 56 m0_xc_rpc_ut_fops_init();
74 m0_xc_rpc_ut_fops_fini();
static const struct m0_fom_type_ops arrow_fom_type_ops
static struct m0_addb2_mach * m
struct m0_semaphore arrow_hit
#define M0_FOP_TYPE_INIT(ft,...)
static const struct m0_fom_ops arrow_fom_ops
int(* fto_create)(struct m0_fop *fop, struct m0_fom **out, struct m0_reqh *reqh)
void m0_fop_type_fini(struct m0_fop_type *fopt)
static struct m0_xcode_type ** xt[]
const struct m0_sm_conf m0_generic_conf
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)
struct m0_fop_type m0_rpc_arrow_fopt
M0_INTERNAL void m0_rpc_test_fops_fini(void)
void m0_fom_fini(struct m0_fom *fom)
M0_INTERNAL int m0_semaphore_init(struct m0_semaphore *semaphore, unsigned value)
static int arrow_fom_create(struct m0_fop *fop, struct m0_fom **m, struct m0_reqh *reqh)
struct m0_semaphore arrow_destroyed
struct m0_reqh_service_type m0_rpc_service_type
static size_t arrow_fom_home_locality(const struct m0_fom *fom)
#define M0_ALLOC_PTR(ptr)
M0_INTERNAL void m0_semaphore_fini(struct m0_semaphore *semaphore)
static struct m0_fop * fop
static int arrow_fom_tick(struct m0_fom *fom)
void(* fo_fini)(struct m0_fom *fom)
static void arrow_fom_fini(struct m0_fom *fom)
void m0_fom_phase_set(struct m0_fom *fom, int phase)
M0_INTERNAL void m0_semaphore_up(struct m0_semaphore *semaphore)
M0_INTERNAL void m0_rpc_test_fops_init(void)