Lines Matching refs:rxnet
23 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet,
55 struct rxrpc_connection *rxrpc_alloc_connection(struct rxrpc_net *rxnet, in rxrpc_alloc_connection() argument
74 conn->rxnet = rxnet; in rxrpc_alloc_connection()
212 rxrpc_set_service_reap_timer(conn->rxnet, in rxrpc_disconnect_call()
277 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, in rxrpc_set_service_reap_timer() argument
280 if (rxnet->live) in rxrpc_set_service_reap_timer()
281 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); in rxrpc_set_service_reap_timer()
291 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_rcu_free_connection() local
299 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_rcu_free_connection()
300 wake_up_var(&rxnet->nr_conns); in rxrpc_rcu_free_connection()
310 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_clean_up_connection() local
322 write_lock(&rxnet->conn_lock); in rxrpc_clean_up_connection()
324 write_unlock(&rxnet->conn_lock); in rxrpc_clean_up_connection()
390 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
402 write_lock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
403 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_service_connection_reaper()
410 if (rxnet->live && !conn->local->dead) { in rxrpc_service_connection_reaper()
442 write_unlock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
447 rxrpc_set_service_reap_timer(rxnet, earliest); in rxrpc_service_connection_reaper()
466 void rxrpc_destroy_all_connections(struct rxrpc_net *rxnet) in rxrpc_destroy_all_connections() argument
473 atomic_dec(&rxnet->nr_conns); in rxrpc_destroy_all_connections()
475 timer_delete_sync(&rxnet->service_conn_reap_timer); in rxrpc_destroy_all_connections()
476 rxrpc_queue_work(&rxnet->service_conn_reaper); in rxrpc_destroy_all_connections()
479 write_lock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
480 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_destroy_all_connections()
485 write_unlock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
488 ASSERT(list_empty(&rxnet->conn_proc_list)); in rxrpc_destroy_all_connections()
493 wait_var_event(&rxnet->nr_conns, !atomic_read(&rxnet->nr_conns)); in rxrpc_destroy_all_connections()