66 &
cl_ctx.rcx_rpc_machine, sep,
M0_INTERNAL int repair_rpc_ctx_init(struct rpc_ctx *ctx, const char *sep)
M0_INTERNAL int m0_rpc_post(struct m0_rpc_item *item)
m0_time_t ri_resend_interval
void m0_net_domain_fini(struct m0_net_domain *dom)
enum m0_rpc_item_priority ri_prio
const m0_time_t M0_TIME_NEVER
int m0_rpc_session_destroy(struct m0_rpc_session *session, m0_time_t abs_timeout)
static struct m0_net_domain cl_ndom
static struct m0_rpc_item * item
static struct m0_rm_incoming_ops ri_ops
static struct m0_fid process_fid
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 void repair_rpc_ctx_fini(struct rpc_ctx *ctx)
int m0_rpc_conn_destroy(struct m0_rpc_conn *conn, m0_time_t abs_timeout)
int m0_rpc_client_stop(struct m0_rpc_client_ctx *cctx)
struct m0_net_xprt * m0_net_xprt_default_get(void)
int m0_rpc_client_start(struct m0_rpc_client_ctx *cctx)
const char * srv_ep_addr[MAX_SERVERS]
int m0_net_domain_init(struct m0_net_domain *dom, const struct m0_net_xprt *xprt)
const struct m0_rpc_item_ops * ri_ops
m0_time_t m0_time_from_now(uint64_t secs, long ns)
struct m0_rpc_session * ri_session
M0_INTERNAL void repair_client_fini(void)
M0_INTERNAL int repair_rpc_post(struct m0_fop *fop, struct m0_rpc_session *session, const struct m0_rpc_item_ops *ri_ops, m0_time_t deadline)
static struct m0_fop * fop
struct m0_rpc_item f_item
M0_INTERNAL int repair_client_init(void)