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