25 #ifndef __MOTR_RPC_RPCLIB_H__ 26 #define __MOTR_RPC_RPCLIB_H__ 185 uint64_t max_rpcs_in_flight,
206 uint64_t max_rpcs_in_flight,
int m0_rpc_client_stop(struct m0_rpc_client_ctx *cctx)
int m0_rpc_client_start(struct m0_rpc_client_ctx *cctx)
M0_INTERNAL int m0_rpc_client_find_connect(struct m0_rpc_conn *conn, struct m0_rpc_session *session, struct m0_rpc_machine *rpc_mach, const char *remote_addr, enum m0_conf_service_type stype, uint64_t max_rpcs_in_flight, m0_time_t abs_timeout)
struct m0_net_buffer_pool rcx_buffer_pool
static struct m0_rpc_client_ctx cctx
static const char * remote_addr
int m0_rpc_client_stop_stats(struct m0_rpc_client_ctx *cctx, void(*printout)(struct m0_rpc_machine *))
int m0_rpc_server_start(struct m0_rpc_server_ctx *sctx)
static struct m0_rm_incoming_ops ri_ops
int m0_rpc_post_sync(struct m0_fop *fop, struct m0_rpc_session *session, const struct m0_rpc_item_ops *ri_ops, m0_time_t deadline)
static const struct socktype stype[]
const char * rsx_log_file_name
M0_INTERNAL struct m0_rpc_machine * m0_rpc_server_ctx_get_rmachine(struct m0_rpc_server_ctx *sctx)
uint32_t rcx_max_rpc_msg_size
struct m0_rpc_conn rcx_connection
struct m0_net_xprt ** rsx_xprts
static struct m0_rpc_server_ctx sctx
uint32_t rcx_recv_queue_min_length
m0_time_t rcx_abs_timeout
struct m0_net_domain * rcx_net_dom
uint64_t rcx_max_rpcs_in_flight
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)
struct m0_rpc_session rcx_session
const char * rcx_remote_addr
static struct m0_fop * fop
const char * rcx_local_addr
struct m0_rpc_machine rcx_rpc_machine
void m0_rpc_server_stop(struct m0_rpc_server_ctx *sctx)
struct m0_motr rsx_motr_ctx
int m0_rpc_post_with_timeout_sync(struct m0_fop *fop, struct m0_rpc_session *session, const struct m0_rpc_item_ops *ri_ops, m0_time_t deadline, m0_time_t timeout)