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
73 conn->rxnet = rxnet; in rxrpc_alloc_connection()
210 rxrpc_set_service_reap_timer(conn->rxnet, in rxrpc_disconnect_call()
275 static void rxrpc_set_service_reap_timer(struct rxrpc_net *rxnet, in rxrpc_set_service_reap_timer() argument
278 if (rxnet->live) in rxrpc_set_service_reap_timer()
279 timer_reduce(&rxnet->service_conn_reap_timer, reap_at); in rxrpc_set_service_reap_timer()
289 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_rcu_free_connection() local
297 if (atomic_dec_and_test(&rxnet->nr_conns)) in rxrpc_rcu_free_connection()
298 wake_up_var(&rxnet->nr_conns); in rxrpc_rcu_free_connection()
308 struct rxrpc_net *rxnet = conn->rxnet; in rxrpc_clean_up_connection() local
320 write_lock(&rxnet->conn_lock); in rxrpc_clean_up_connection()
322 write_unlock(&rxnet->conn_lock); in rxrpc_clean_up_connection()
383 struct rxrpc_net *rxnet = in rxrpc_service_connection_reaper() local
395 write_lock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
396 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_service_connection_reaper()
403 if (rxnet->live && !conn->local->dead) { in rxrpc_service_connection_reaper()
435 write_unlock(&rxnet->conn_lock); in rxrpc_service_connection_reaper()
440 rxrpc_set_service_reap_timer(rxnet, earliest); in rxrpc_service_connection_reaper()
459 void rxrpc_destroy_all_connections(struct rxrpc_net *rxnet) in rxrpc_destroy_all_connections() argument
466 atomic_dec(&rxnet->nr_conns); in rxrpc_destroy_all_connections()
468 del_timer_sync(&rxnet->service_conn_reap_timer); in rxrpc_destroy_all_connections()
469 rxrpc_queue_work(&rxnet->service_conn_reaper); in rxrpc_destroy_all_connections()
472 write_lock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
473 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_destroy_all_connections()
478 write_unlock(&rxnet->conn_lock); in rxrpc_destroy_all_connections()
481 ASSERT(list_empty(&rxnet->conn_proc_list)); in rxrpc_destroy_all_connections()
486 wait_var_event(&rxnet->nr_conns, !atomic_read(&rxnet->nr_conns)); in rxrpc_destroy_all_connections()