|
M0_INTERNAL int | m0_rpc_conn_init (struct m0_rpc_conn *conn, struct m0_fid *svc_fid, struct m0_net_end_point *ep, struct m0_rpc_machine *machine, uint64_t max_rpcs_in_flight) |
|
M0_INTERNAL void | m0_rpc_conn_reset (struct m0_rpc_conn *conn) |
|
M0_INTERNAL int | m0_rpc_conn_establish (struct m0_rpc_conn *conn, m0_time_t abs_timeout) |
|
M0_INTERNAL int | m0_rpc_conn_establish_sync (struct m0_rpc_conn *conn, m0_time_t abs_timeout) |
|
M0_INTERNAL int | m0_rpc_conn_create (struct m0_rpc_conn *conn, struct m0_fid *svc_fid, struct m0_net_end_point *ep, struct m0_rpc_machine *rpc_machine, uint64_t max_rpcs_in_flight, m0_time_t abs_timeout) |
|
M0_INTERNAL int | m0_rpc_conn_terminate (struct m0_rpc_conn *conn, m0_time_t abs_timeout) |
|
M0_INTERNAL int | m0_rpc_conn_terminate_sync (struct m0_rpc_conn *conn, m0_time_t abs_timeout) |
|
M0_INTERNAL void | m0_rpc_conn_fini (struct m0_rpc_conn *conn) |
|
int | m0_rpc_conn_destroy (struct m0_rpc_conn *conn, m0_time_t abs_timeout) |
|
M0_INTERNAL int | m0_rpc_conn_timedwait (struct m0_rpc_conn *conn, uint64_t states, const m0_time_t timeout) |
|
M0_INTERNAL int | m0_rpc_conn_ha_subscribe (struct m0_rpc_conn *conn, struct m0_fid *svc_fid) |
|
M0_INTERNAL void | m0_rpc_conn_ha_unsubscribe (struct m0_rpc_conn *conn) |
|
M0_INTERNAL int | m0_rpc_machine_conn_list_dump (struct m0_rpc_machine *machine, int dir) |
|
M0_INTERNAL const char * | m0_rpc_conn_addr (const struct m0_rpc_conn *conn) |
|
M0_INTERNAL bool | m0_rpc_conn_is_known_dead (const struct m0_rpc_conn *conn) |
|
M0_INTERNAL struct m0_conf_obj * | m0_rpc_conn2svc (const struct m0_rpc_conn *conn) |
|
M0_INTERNAL void | m0_rpc_conn_ha_cfg_set (struct m0_rpc_conn *conn, const struct m0_rpc_conn_ha_cfg *cfg) |
|
M0_INTERNAL const char * | m0_rpc_conn_state_to_str (enum m0_rpc_conn_state state) |
|
M0_INTERNAL void | m0_rpc_conn_sessions_cancel (struct m0_rpc_conn *conn) |
|