30 #define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_UT 44 const uint32_t tms_nr = 1;
45 const uint32_t bufs_nr =
47 const char *
ep =
"0@lo:12345:42:100";
54 &
ctx->hurc_buffer_pool,
59 .rhia_mdstore = (
void*)1,
64 &
ctx->hurc_net_domain,
ep,
66 &
ctx->hurc_buffer_pool,
90 &
ctx->hurc_rpc_machine,
108 #undef M0_TRACE_SUBSYSTEM
void m0_rpc_machine_fini(struct m0_rpc_machine *machine)
M0_INTERNAL void m0_reqh_services_terminate(struct m0_reqh *reqh)
void m0_net_domain_fini(struct m0_net_domain *dom)
#define M0_REQH_INIT(reqh,...)
const m0_time_t M0_TIME_NEVER
int m0_rpc_session_destroy(struct m0_rpc_session *session, m0_time_t abs_timeout)
M0_INTERNAL void m0_ha_ut_rpc_ctx_init(struct m0_ha_ut_rpc_ctx *ctx)
M0_INTERNAL void m0_reqh_fini(struct m0_reqh *reqh)
M0_INTERNAL const char * m0_rpc_machine_ep(const struct m0_rpc_machine *rmach)
M0_INTERNAL void m0_reqh_shutdown_wait(struct m0_reqh *reqh)
M0_INTERNAL int m0_rpc_client_connect(struct m0_rpc_conn *conn, struct m0_rpc_session *session, struct m0_rpc_machine *rpc_mach, const char *remote_addr, struct m0_fid *svc_fid, uint64_t max_rpcs_in_flight, m0_time_t abs_timeout)
#define M0_FID_TINIT(type, container, key)
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)
int m0_rpc_conn_destroy(struct m0_rpc_conn *conn, m0_time_t abs_timeout)
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)
struct m0_net_xprt * m0_net_xprt_default_get(void)
static struct m0_rpc_server_ctx sctx
M0_INTERNAL void m0_ha_ut_rpc_ctx_fini(struct m0_ha_ut_rpc_ctx *ctx)
M0_INTERNAL void m0_reqh_start(struct m0_reqh *reqh)
M0_INTERNAL void m0_ha_ut_rpc_session_ctx_fini(struct m0_ha_ut_rpc_session_ctx *sctx)
int m0_net_domain_init(struct m0_net_domain *dom, const struct m0_net_xprt *xprt)
M0_INTERNAL void m0_ha_ut_rpc_session_ctx_init(struct m0_ha_ut_rpc_session_ctx *sctx, struct m0_ha_ut_rpc_ctx *ctx)
void m0_rpc_net_buffer_pool_cleanup(struct m0_net_buffer_pool *app_pool)
static const char * process_fid