cachepc-linux

Fork of AMDESE/linux with modifications for CachePC side-channel attack
git clone https://git.sinitax.com/sinitax/cachepc-linux
Log | Files | Refs | README | LICENSE | sfeed.txt

net_ns.c (3901B)

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