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