69 .rhia_dtm = (
void *)1,
70 .rhia_mdstore = (
void *)1,
void m0_rpc_machine_fini(struct m0_rpc_machine *machine)
M0_INTERNAL int m0_reqh_service_start(struct m0_reqh_service *service)
M0_INTERNAL void m0_reqh_services_terminate(struct m0_reqh *reqh)
void m0_net_domain_fini(struct m0_net_domain *dom)
static const char * ep_addr
#define M0_REQH_INIT(reqh,...)
static struct m0_net_domain g_net_dom
M0_INTERNAL int m0_ut_rpc_machine_start(struct m0_rpc_machine *mach, struct m0_net_xprt *xprt, const char *ep_addr)
static struct m0_addb2_mach * mach
M0_INTERNAL void m0_reqh_fini(struct m0_reqh *reqh)
M0_INTERNAL void m0_reqh_shutdown_wait(struct m0_reqh *reqh)
M0_INTERNAL int m0_rpc_net_buffer_pool_setup(struct m0_net_domain *ndom, struct m0_net_buffer_pool *app_pool, uint32_t bufs_nr, uint32_t tm_nr)
M0_INTERNAL uint32_t m0_rpc_bufs_nr(uint32_t len, uint32_t tms_nr)
M0_INTERNAL int m0_rpc_machine_init(struct m0_rpc_machine *machine, struct m0_net_domain *net_dom, const char *ep_addr, struct m0_reqh *reqh, struct m0_net_buffer_pool *receive_pool, uint32_t colour, m0_bcount_t msg_size, uint32_t queue_len)
static struct m0_reqh g_reqh
M0_INTERNAL int m0_reqh_service_allocate(struct m0_reqh_service **out, const struct m0_reqh_service_type *stype, struct m0_reqh_context *rctx)
M0_INTERNAL void m0_reqh_service_init(struct m0_reqh_service *service, struct m0_reqh *reqh, const struct m0_fid *fid)
M0_INTERNAL void m0_reqh_start(struct m0_reqh *reqh)
M0_INTERNAL int m0_ut_rpc_service_start(struct m0_reqh_service **service, const struct m0_reqh_service_type *type)
int m0_net_domain_init(struct m0_net_domain *dom, const struct m0_net_xprt *xprt)
static struct m0_net_buffer_pool g_buf_pool
M0_INTERNAL void m0_ut_rpc_machine_stop(struct m0_rpc_machine *mach)
static struct m0_addb2_net * net
static struct m0_net_buffer_pool * buf_pool
struct m0_net_xprt * xprt
void m0_rpc_net_buffer_pool_cleanup(struct m0_net_buffer_pool *app_pool)
static struct m0_reqh_service * service[REQH_IN_UT_MAX]
struct m0_fid g_process_fid