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
197 atomic_inc(&rxnet->nr_conns); in rxrpc_alloc_client_connection()
198 write_lock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
199 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
200 write_unlock(&rxnet->conn_lock); in rxrpc_alloc_client_connection()
211 atomic_inc(&rxnet->nr_client_conns); in rxrpc_alloc_client_connection()
231 struct rxrpc_net *rxnet; in rxrpc_may_reuse_conn() local
237 rxnet = conn->params.local->rxnet; in rxrpc_may_reuse_conn()
242 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
256 limit = max_t(unsigned long, atomic_read(&rxnet->nr_conns) * 4, 1024); in rxrpc_may_reuse_conn()
579 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_unidle_conn() local
584 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
589 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_unidle_conn()
715 struct rxrpc_net *rxnet = cp->local->rxnet; in rxrpc_connect_call() local
720 rxrpc_discard_expired_client_conns(&rxnet->client_conn_reaper); in rxrpc_connect_call()
787 static void rxrpc_set_client_reap_timer(struct rxrpc_net *rxnet) in rxrpc_set_client_reap_timer() argument
789 if (!rxnet->kill_all_client_conns) { in rxrpc_set_client_reap_timer()
793 if (rxnet->live) in rxrpc_set_client_reap_timer()
794 timer_reduce(&rxnet->client_conn_reap_timer, reap_at); in rxrpc_set_client_reap_timer()
805 struct rxrpc_net *rxnet = bundle->params.local->rxnet; in rxrpc_disconnect_client_call() local
896 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
897 list_move_tail(&conn->cache_link, &rxnet->idle_client_conns); in rxrpc_disconnect_client_call()
898 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_disconnect_client_call()
900 rxrpc_set_client_reap_timer(rxnet); in rxrpc_disconnect_client_call()
968 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_kill_client_conn() local
973 atomic_dec(&rxnet->nr_client_conns); in rxrpc_kill_client_conn()
1005 struct rxrpc_net *rxnet = in rxrpc_discard_expired_client_conns() local
1012 if (list_empty(&rxnet->idle_client_conns)) { in rxrpc_discard_expired_client_conns()
1018 if (!spin_trylock(&rxnet->client_conn_discard_lock)) { in rxrpc_discard_expired_client_conns()
1026 nr_conns = atomic_read(&rxnet->nr_client_conns); in rxrpc_discard_expired_client_conns()
1029 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1031 if (list_empty(&rxnet->idle_client_conns)) in rxrpc_discard_expired_client_conns()
1034 conn = list_entry(rxnet->idle_client_conns.next, in rxrpc_discard_expired_client_conns()
1037 if (!rxnet->kill_all_client_conns) { in rxrpc_discard_expired_client_conns()
1059 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1076 if (!rxnet->kill_all_client_conns) in rxrpc_discard_expired_client_conns()
1077 timer_reduce(&rxnet->client_conn_reap_timer, conn_expires_at); in rxrpc_discard_expired_client_conns()
1080 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_discard_expired_client_conns()
1081 spin_unlock(&rxnet->client_conn_discard_lock); in rxrpc_discard_expired_client_conns()
1089 void rxrpc_destroy_all_client_connections(struct rxrpc_net *rxnet) in rxrpc_destroy_all_client_connections() argument
1093 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1094 rxnet->kill_all_client_conns = true; in rxrpc_destroy_all_client_connections()
1095 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_destroy_all_client_connections()
1097 del_timer_sync(&rxnet->client_conn_reap_timer); in rxrpc_destroy_all_client_connections()
1099 if (!rxrpc_queue_work(&rxnet->client_conn_reaper)) in rxrpc_destroy_all_client_connections()
1111 struct rxrpc_net *rxnet = local->rxnet; in rxrpc_clean_up_local_conns() local
1116 spin_lock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()
1118 list_for_each_entry_safe(conn, tmp, &rxnet->idle_client_conns, in rxrpc_clean_up_local_conns()
1126 spin_unlock(&rxnet->client_conn_cache_lock); in rxrpc_clean_up_local_conns()