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