Lines Matching refs:rxnet

52 	struct rxrpc_net *rxnet = conn->params.local->rxnet;  in rxrpc_get_client_connection_id()  local
68 conn->proto.epoch = rxnet->epoch; in rxrpc_get_client_connection_id()
157 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_alloc_client_connection() local
187 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
188 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
189 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
190 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
201 atomic_inc(&rxnet->nr_client_conns); in rxrpc_alloc_client_connection()
221 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
227 rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn()
232 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
246 limit = max_t(unsigned long, atomic_read(&rxnet->nr_conns) * 4, 1024); in rxrpc_may_reuse_conn()
567 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_unidle_conn() local
572 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
577 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
703 struct rxrpc_net *rxnet = cp->local->rxnet; in rxrpc_connect_call() local
708 rxrpc_discard_expired_client_conns(&rxnet->client_conn_reaper); in rxrpc_connect_call()
774 static void rxrpc_set_client_reap_timer(struct rxrpc_net *rxnet) in rxrpc_set_client_reap_timer() argument
776 if (!rxnet->kill_all_client_conns) { in rxrpc_set_client_reap_timer()
780 if (rxnet->live) in rxrpc_set_client_reap_timer()
781 timer_reduce(&rxnet->client_conn_reap_timer, reap_at); in rxrpc_set_client_reap_timer()
792 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_disconnect_client_call() local
883 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
884 list_move_tail(&conn->cache_link, &rxnet->idle_client_conns); in rxrpc_disconnect_client_call()
885 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
887 rxrpc_set_client_reap_timer(rxnet); in rxrpc_disconnect_client_call()
953 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
958 atomic_dec(&rxnet->nr_client_conns); in rxrpc_kill_client_conn()
991 struct rxrpc_net *rxnet = in rxrpc_discard_expired_client_conns() local
998 if (list_empty(&rxnet->idle_client_conns)) { in rxrpc_discard_expired_client_conns()
1004 if (!spin_trylock(&rxnet->client_conn_discard_lock)) { in rxrpc_discard_expired_client_conns()
1012 nr_conns = atomic_read(&rxnet->nr_client_conns); in rxrpc_discard_expired_client_conns()
1015 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1017 if (list_empty(&rxnet->idle_client_conns)) in rxrpc_discard_expired_client_conns()
1020 conn = list_entry(rxnet->idle_client_conns.next, in rxrpc_discard_expired_client_conns()
1023 if (!rxnet->kill_all_client_conns) { in rxrpc_discard_expired_client_conns()
1045 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1062 if (!rxnet->kill_all_client_conns) in rxrpc_discard_expired_client_conns()
1063 timer_reduce(&rxnet->client_conn_reap_timer, conn_expires_at); in rxrpc_discard_expired_client_conns()
1066 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1067 spin_unlock(&rxnet->client_conn_discard_lock); in rxrpc_discard_expired_client_conns()
1075 void rxrpc_destroy_all_client_connections(struct rxrpc_net *rxnet) in rxrpc_destroy_all_client_connections() argument
1079 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1080 rxnet->kill_all_client_conns = true; in rxrpc_destroy_all_client_connections()
1081 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1083 del_timer_sync(&rxnet->client_conn_reap_timer); in rxrpc_destroy_all_client_connections()
1085 if (!rxrpc_queue_work(&rxnet->client_conn_reaper)) in rxrpc_destroy_all_client_connections()
1097 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_clean_up_local_conns() local
1102 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()
1104 list_for_each_entry_safe(conn, tmp, &rxnet->idle_client_conns, in rxrpc_clean_up_local_conns()
1112 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()