26 #ifndef __MOTR_RPC_LINK_H__ 27 #define __MOTR_RPC_LINK_H__ 87 uint64_t max_rpcs_in_flight);
M0_INTERNAL const char * m0_rpc_link_end_point(const struct m0_rpc_link *rlink)
M0_INTERNAL int m0_rpc_link_init(struct m0_rpc_link *rlink, struct m0_rpc_machine *mach, struct m0_fid *svc_fid, const char *ep, uint64_t max_rpcs_in_flight)
struct m0_rpc_conn rlk_conn
static struct m0_addb2_mach * mach
M0_INTERNAL void m0_rpc_link_fini(struct m0_rpc_link *rlink)
M0_INTERNAL void m0_rpc_link_module_fini(void)
M0_INTERNAL bool m0_rpc_link_is_connected(const struct m0_rpc_link *rlink)
M0_INTERNAL void m0_rpc_link_reset(struct m0_rpc_link *rlink)
struct m0_mutex rlk_wait_mutex
M0_INTERNAL int m0_rpc_link_disconnect_sync(struct m0_rpc_link *rlink, m0_time_t abs_timeout)
M0_INTERNAL int m0_rpc_link_connect_sync(struct m0_rpc_link *rlink, m0_time_t abs_timeout)
M0_INTERNAL void m0_rpc_link_connect_async(struct m0_rpc_link *rlink, m0_time_t abs_timeout, struct m0_clink *wait_clink)
struct m0_fom_callback rlk_fomcb
M0_INTERNAL int m0_rpc_link_module_init(void)
struct m0_rpc_session rlk_sess
M0_INTERNAL void m0_rpc_link_disconnect_async(struct m0_rpc_link *rlink, m0_time_t abs_timeout, struct m0_clink *wait_clink)