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()
161 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()
219 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
225 rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn()
230 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
244 limit = max_t(unsigned long, atomic_read(&rxnet->nr_conns) * 4, 1024); in rxrpc_may_reuse_conn()
565 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_unidle_conn() local
570 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
575 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
701 struct rxrpc_net *rxnet = cp->local->rxnet; in rxrpc_connect_call() local
706 rxrpc_discard_expired_client_conns(&rxnet->client_conn_reaper); in rxrpc_connect_call()
772 static void rxrpc_set_client_reap_timer(struct rxrpc_net *rxnet) in rxrpc_set_client_reap_timer() argument
774 if (!rxnet->kill_all_client_conns) { in rxrpc_set_client_reap_timer()
778 if (rxnet->live) in rxrpc_set_client_reap_timer()
779 timer_reduce(&rxnet->client_conn_reap_timer, reap_at); in rxrpc_set_client_reap_timer()
790 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_disconnect_client_call() local
881 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
882 list_move_tail(&conn->cache_link, &rxnet->idle_client_conns); in rxrpc_disconnect_client_call()
883 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
885 rxrpc_set_client_reap_timer(rxnet); in rxrpc_disconnect_client_call()
951 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
956 atomic_dec(&rxnet->nr_client_conns); in rxrpc_kill_client_conn()
989 struct rxrpc_net *rxnet = in rxrpc_discard_expired_client_conns() local
996 if (list_empty(&rxnet->idle_client_conns)) { in rxrpc_discard_expired_client_conns()
1002 if (!spin_trylock(&rxnet->client_conn_discard_lock)) { in rxrpc_discard_expired_client_conns()
1010 nr_conns = atomic_read(&rxnet->nr_client_conns); in rxrpc_discard_expired_client_conns()
1013 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1015 if (list_empty(&rxnet->idle_client_conns)) in rxrpc_discard_expired_client_conns()
1018 conn = list_entry(rxnet->idle_client_conns.next, in rxrpc_discard_expired_client_conns()
1021 if (!rxnet->kill_all_client_conns) { in rxrpc_discard_expired_client_conns()
1043 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1060 if (!rxnet->kill_all_client_conns) in rxrpc_discard_expired_client_conns()
1061 timer_reduce(&rxnet->client_conn_reap_timer, conn_expires_at); in rxrpc_discard_expired_client_conns()
1064 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1065 spin_unlock(&rxnet->client_conn_discard_lock); in rxrpc_discard_expired_client_conns()
1073 void rxrpc_destroy_all_client_connections(struct rxrpc_net *rxnet) in rxrpc_destroy_all_client_connections() argument
1077 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1078 rxnet->kill_all_client_conns = true; in rxrpc_destroy_all_client_connections()
1079 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1081 del_timer_sync(&rxnet->client_conn_reap_timer); in rxrpc_destroy_all_client_connections()
1083 if (!rxrpc_queue_work(&rxnet->client_conn_reaper)) in rxrpc_destroy_all_client_connections()
1095 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_clean_up_local_conns() local
1100 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()
1102 list_for_each_entry_safe(conn, tmp, &rxnet->idle_client_conns, in rxrpc_clean_up_local_conns()
1110 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()