net/rxrpc/net_ns.c

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