Lines Matching refs:rxnet

54 	struct rxrpc_net *rxnet = conn->params.local->rxnet;  in rxrpc_get_client_connection_id()  local
70 conn->proto.epoch = rxnet->epoch; in rxrpc_get_client_connection_id()
167 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_alloc_client_connection() local
193 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
194 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
195 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
196 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
207 atomic_inc(&rxnet->nr_client_conns); in rxrpc_alloc_client_connection()
225 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
231 rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn()
236 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
250 limit = max_t(unsigned long, atomic_read(&rxnet->nr_conns) * 4, 1024); in rxrpc_may_reuse_conn()
573 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_unidle_conn() local
578 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
583 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
709 struct rxrpc_net *rxnet = cp->local->rxnet; in rxrpc_connect_call() local
714 rxrpc_discard_expired_client_conns(&rxnet->client_conn_reaper); in rxrpc_connect_call()
781 static void rxrpc_set_client_reap_timer(struct rxrpc_net *rxnet) in rxrpc_set_client_reap_timer() argument
783 if (!rxnet->kill_all_client_conns) { in rxrpc_set_client_reap_timer()
787 if (rxnet->live) in rxrpc_set_client_reap_timer()
788 timer_reduce(&rxnet->client_conn_reap_timer, reap_at); in rxrpc_set_client_reap_timer()
799 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_disconnect_client_call() local
890 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
891 list_move_tail(&conn->cache_link, &rxnet->idle_client_conns); in rxrpc_disconnect_client_call()
892 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
894 rxrpc_set_client_reap_timer(rxnet); in rxrpc_disconnect_client_call()
962 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
967 atomic_dec(&rxnet->nr_client_conns); in rxrpc_kill_client_conn()
999 struct rxrpc_net *rxnet = in rxrpc_discard_expired_client_conns() local
1006 if (list_empty(&rxnet->idle_client_conns)) { in rxrpc_discard_expired_client_conns()
1012 if (!spin_trylock(&rxnet->client_conn_discard_lock)) { in rxrpc_discard_expired_client_conns()
1020 nr_conns = atomic_read(&rxnet->nr_client_conns); in rxrpc_discard_expired_client_conns()
1023 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1025 if (list_empty(&rxnet->idle_client_conns)) in rxrpc_discard_expired_client_conns()
1028 conn = list_entry(rxnet->idle_client_conns.next, in rxrpc_discard_expired_client_conns()
1031 if (!rxnet->kill_all_client_conns) { in rxrpc_discard_expired_client_conns()
1053 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1070 if (!rxnet->kill_all_client_conns) in rxrpc_discard_expired_client_conns()
1071 timer_reduce(&rxnet->client_conn_reap_timer, conn_expires_at); in rxrpc_discard_expired_client_conns()
1074 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1075 spin_unlock(&rxnet->client_conn_discard_lock); in rxrpc_discard_expired_client_conns()
1083 void rxrpc_destroy_all_client_connections(struct rxrpc_net *rxnet) in rxrpc_destroy_all_client_connections() argument
1087 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1088 rxnet->kill_all_client_conns = true; in rxrpc_destroy_all_client_connections()
1089 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1091 del_timer_sync(&rxnet->client_conn_reap_timer); in rxrpc_destroy_all_client_connections()
1093 if (!rxrpc_queue_work(&rxnet->client_conn_reaper)) in rxrpc_destroy_all_client_connections()
1105 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_clean_up_local_conns() local
1110 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()
1112 list_for_each_entry_safe(conn, tmp, &rxnet->idle_client_conns, in rxrpc_clean_up_local_conns()
1120 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()