25 #ifndef __MOTR_RPC_CONN_POOL_H__ 26 #define __MOTR_RPC_CONN_POOL_H__ 60 uint64_t max_rpcs_in_flight);
66 const char *remote_ep,
75 const char *remote_ep,
M0_INTERNAL void m0_rpc_conn_pool_fini(struct m0_rpc_conn_pool *pool)
struct m0_rpc_link cpi_rpc_link
M0_INTERNAL int m0_rpc_conn_pool_init(struct m0_rpc_conn_pool *pool, struct m0_rpc_machine *rpc_mach, m0_time_t conn_timeout, uint64_t max_rpcs_in_flight)
M0_INTERNAL void m0_rpc_conn_pool_put(struct m0_rpc_conn_pool *pool, struct m0_rpc_session *session)
M0_INTERNAL void m0_rpc_conn_pool_destroy(struct m0_rpc_conn_pool *pool, struct m0_rpc_session *session)
M0_INTERNAL struct m0_chan * m0_rpc_conn_pool_session_chan(struct m0_rpc_session *session)
M0_INTERNAL int m0_rpc_conn_pool_get_async(struct m0_rpc_conn_pool *pool, const char *remote_ep, struct m0_rpc_session **session)
struct m0_rpc_machine * cp_rpc_mach
M0_INTERNAL int m0_rpc_conn_pool_get_sync(struct m0_rpc_conn_pool *pool, const char *remote_ep, struct m0_rpc_session **session)
struct m0_rpc_conn_pool * cpi_pool
static struct m0_pool pool
struct m0_clink cpi_clink
struct m0_tlink cpi_linkage
struct m0_mutex cp_ch_mutex
M0_INTERNAL bool m0_rpc_conn_pool_session_established(struct m0_rpc_session *session)
uint64_t cp_max_rpcs_in_flight