1 | // SPDX-License-Identifier: GPL-2.0-or-later |
2 | /* rxrpc network namespace handling. |
3 | * |
4 | * Copyright (C) 2017 Red Hat, Inc. All Rights Reserved. |
5 | * Written by David Howells (dhowells@redhat.com) |
6 | */ |
7 | |
8 | #include <linux/proc_fs.h> |
9 | #include "ar-internal.h" |
10 | |
11 | unsigned int rxrpc_net_id; |
12 | |
13 | static void rxrpc_service_conn_reap_timeout(struct timer_list *timer) |
14 | { |
15 | struct rxrpc_net *rxnet = |
16 | container_of(timer, struct rxrpc_net, service_conn_reap_timer); |
17 | |
18 | if (rxnet->live) |
19 | rxrpc_queue_work(&rxnet->service_conn_reaper); |
20 | } |
21 | |
22 | static void rxrpc_peer_keepalive_timeout(struct timer_list *timer) |
23 | { |
24 | struct rxrpc_net *rxnet = |
25 | container_of(timer, struct rxrpc_net, peer_keepalive_timer); |
26 | |
27 | if (rxnet->live) |
28 | rxrpc_queue_work(&rxnet->peer_keepalive_work); |
29 | } |
30 | |
31 | /* |
32 | * Initialise a per-network namespace record. |
33 | */ |
34 | static __net_init int rxrpc_init_net(struct net *net) |
35 | { |
36 | struct rxrpc_net *rxnet = rxrpc_net(net); |
37 | int ret, i; |
38 | |
39 | rxnet->live = true; |
40 | get_random_bytes(buf: &rxnet->epoch, len: sizeof(rxnet->epoch)); |
41 | rxnet->epoch |= RXRPC_RANDOM_EPOCH; |
42 | |
43 | INIT_LIST_HEAD(list: &rxnet->calls); |
44 | spin_lock_init(&rxnet->call_lock); |
45 | atomic_set(v: &rxnet->nr_calls, i: 1); |
46 | |
47 | atomic_set(v: &rxnet->nr_conns, i: 1); |
48 | INIT_LIST_HEAD(list: &rxnet->bundle_proc_list); |
49 | INIT_LIST_HEAD(list: &rxnet->conn_proc_list); |
50 | INIT_LIST_HEAD(list: &rxnet->service_conns); |
51 | rwlock_init(&rxnet->conn_lock); |
52 | INIT_WORK(&rxnet->service_conn_reaper, |
53 | rxrpc_service_connection_reaper); |
54 | timer_setup(&rxnet->service_conn_reap_timer, |
55 | rxrpc_service_conn_reap_timeout, 0); |
56 | |
57 | atomic_set(v: &rxnet->nr_client_conns, i: 0); |
58 | |
59 | INIT_HLIST_HEAD(&rxnet->local_endpoints); |
60 | mutex_init(&rxnet->local_mutex); |
61 | |
62 | hash_init(rxnet->peer_hash); |
63 | spin_lock_init(&rxnet->peer_hash_lock); |
64 | for (i = 0; i < ARRAY_SIZE(rxnet->peer_keepalive); i++) |
65 | INIT_LIST_HEAD(list: &rxnet->peer_keepalive[i]); |
66 | INIT_LIST_HEAD(list: &rxnet->peer_keepalive_new); |
67 | timer_setup(&rxnet->peer_keepalive_timer, |
68 | rxrpc_peer_keepalive_timeout, 0); |
69 | INIT_WORK(&rxnet->peer_keepalive_work, rxrpc_peer_keepalive_worker); |
70 | rxnet->peer_keepalive_base = ktime_get_seconds(); |
71 | |
72 | ret = -ENOMEM; |
73 | rxnet->proc_net = proc_net_mkdir(net, name: "rxrpc" , parent: net->proc_net); |
74 | if (!rxnet->proc_net) |
75 | goto err_proc; |
76 | |
77 | proc_create_net("calls" , 0444, rxnet->proc_net, &rxrpc_call_seq_ops, |
78 | sizeof(struct seq_net_private)); |
79 | proc_create_net("conns" , 0444, rxnet->proc_net, |
80 | &rxrpc_connection_seq_ops, |
81 | sizeof(struct seq_net_private)); |
82 | proc_create_net("bundles" , 0444, rxnet->proc_net, |
83 | &rxrpc_bundle_seq_ops, |
84 | sizeof(struct seq_net_private)); |
85 | proc_create_net("peers" , 0444, rxnet->proc_net, |
86 | &rxrpc_peer_seq_ops, |
87 | sizeof(struct seq_net_private)); |
88 | proc_create_net("locals" , 0444, rxnet->proc_net, |
89 | &rxrpc_local_seq_ops, |
90 | sizeof(struct seq_net_private)); |
91 | proc_create_net_single_write(name: "stats" , S_IFREG | 0644, parent: rxnet->proc_net, |
92 | show: rxrpc_stats_show, write: rxrpc_stats_clear, NULL); |
93 | return 0; |
94 | |
95 | err_proc: |
96 | rxnet->live = false; |
97 | return ret; |
98 | } |
99 | |
100 | /* |
101 | * Clean up a per-network namespace record. |
102 | */ |
103 | static __net_exit void rxrpc_exit_net(struct net *net) |
104 | { |
105 | struct rxrpc_net *rxnet = rxrpc_net(net); |
106 | |
107 | rxnet->live = false; |
108 | del_timer_sync(timer: &rxnet->peer_keepalive_timer); |
109 | cancel_work_sync(work: &rxnet->peer_keepalive_work); |
110 | /* Remove the timer again as the worker may have restarted it. */ |
111 | del_timer_sync(timer: &rxnet->peer_keepalive_timer); |
112 | rxrpc_destroy_all_calls(rxnet); |
113 | rxrpc_destroy_all_connections(rxnet); |
114 | rxrpc_destroy_all_peers(rxnet); |
115 | rxrpc_destroy_all_locals(rxnet); |
116 | proc_remove(rxnet->proc_net); |
117 | } |
118 | |
119 | struct pernet_operations rxrpc_net_ops = { |
120 | .init = rxrpc_init_net, |
121 | .exit = rxrpc_exit_net, |
122 | .id = &rxrpc_net_id, |
123 | .size = sizeof(struct rxrpc_net), |
124 | }; |
125 | |