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