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
72 		conn->rxnet = rxnet;  in rxrpc_alloc_connection()
214 			rxrpc_set_service_reap_timer(conn->rxnet,  in rxrpc_disconnect_call()
279 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet,  in rxrpc_set_service_reap_timer()  argument
282 	if (rxnet->live)  in rxrpc_set_service_reap_timer()
283 		timer_reduce(&rxnet->service_conn_reap_timer, reap_at);  in rxrpc_set_service_reap_timer()
293 	struct rxrpc_net *rxnet = conn->rxnet;  in rxrpc_rcu_free_connection()  local
301 	if (atomic_dec_and_test(&rxnet->nr_conns))  in rxrpc_rcu_free_connection()
302 		wake_up_var(&rxnet->nr_conns);  in rxrpc_rcu_free_connection()
312 	struct rxrpc_net *rxnet = conn->rxnet;  in rxrpc_clean_up_connection()  local
324 	write_lock(&rxnet->conn_lock);  in rxrpc_clean_up_connection()
326 	write_unlock(&rxnet->conn_lock);  in rxrpc_clean_up_connection()
384 	struct rxrpc_net *rxnet =  in rxrpc_service_connection_reaper()  local
396 	write_lock(&rxnet->conn_lock);  in rxrpc_service_connection_reaper()
397 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {  in rxrpc_service_connection_reaper()
404 		if (rxnet->live && !conn->local->dead) {  in rxrpc_service_connection_reaper()
436 	write_unlock(&rxnet->conn_lock);  in rxrpc_service_connection_reaper()
441 		rxrpc_set_service_reap_timer(rxnet, earliest);  in rxrpc_service_connection_reaper()
460 void rxrpc_destroy_all_connections(struct rxrpc_net *rxnet)  in rxrpc_destroy_all_connections()  argument
467 	atomic_dec(&rxnet->nr_conns);  in rxrpc_destroy_all_connections()
469 	del_timer_sync(&rxnet->service_conn_reap_timer);  in rxrpc_destroy_all_connections()
470 	rxrpc_queue_work(&rxnet->service_conn_reaper);  in rxrpc_destroy_all_connections()
473 	write_lock(&rxnet->conn_lock);  in rxrpc_destroy_all_connections()
474 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {  in rxrpc_destroy_all_connections()
479 	write_unlock(&rxnet->conn_lock);  in rxrpc_destroy_all_connections()
482 	ASSERT(list_empty(&rxnet->conn_proc_list));  in rxrpc_destroy_all_connections()
487 	wait_var_event(&rxnet->nr_conns, !atomic_read(&rxnet->nr_conns));  in rxrpc_destroy_all_connections()