Commit | Line | Data |
---|---|---|
2874c5fd | 1 | // SPDX-License-Identifier: GPL-2.0-or-later |
9a36a6bc | 2 | /* Socket buffer accounting |
17926a79 DH |
3 | * |
4 | * Copyright (C) 2007 Red Hat, Inc. All Rights Reserved. | |
5 | * Written by David Howells (dhowells@redhat.com) | |
17926a79 DH |
6 | */ |
7 | ||
9b6d5398 JP |
8 | #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt |
9 | ||
17926a79 DH |
10 | #include <linux/module.h> |
11 | #include <linux/net.h> | |
12 | #include <linux/skbuff.h> | |
13 | #include <net/sock.h> | |
14 | #include <net/af_rxrpc.h> | |
15 | #include "ar-internal.h" | |
16 | ||
27f699cc | 17 | #define select_skb_count(skb) (&rxrpc_n_rx_skbs) |
71f3ca40 | 18 | |
df844fd4 | 19 | /* |
71f3ca40 | 20 | * Note the allocation or reception of a socket buffer. |
df844fd4 | 21 | */ |
9a36a6bc | 22 | void rxrpc_new_skb(struct sk_buff *skb, enum rxrpc_skb_trace why) |
df844fd4 | 23 | { |
987db9f7 | 24 | int n = atomic_inc_return(select_skb_count(skb)); |
9a36a6bc | 25 | trace_rxrpc_skb(skb, refcount_read(&skb->users), n, why); |
df844fd4 DH |
26 | } |
27 | ||
28 | /* | |
29 | * Note the re-emergence of a socket buffer from a queue or buffer. | |
30 | */ | |
9a36a6bc | 31 | void rxrpc_see_skb(struct sk_buff *skb, enum rxrpc_skb_trace why) |
df844fd4 | 32 | { |
df844fd4 | 33 | if (skb) { |
987db9f7 | 34 | int n = atomic_read(select_skb_count(skb)); |
9a36a6bc | 35 | trace_rxrpc_skb(skb, refcount_read(&skb->users), n, why); |
df844fd4 DH |
36 | } |
37 | } | |
38 | ||
39 | /* | |
40 | * Note the addition of a ref on a socket buffer. | |
41 | */ | |
9a36a6bc | 42 | void rxrpc_get_skb(struct sk_buff *skb, enum rxrpc_skb_trace why) |
df844fd4 | 43 | { |
987db9f7 | 44 | int n = atomic_inc_return(select_skb_count(skb)); |
9a36a6bc | 45 | trace_rxrpc_skb(skb, refcount_read(&skb->users), n, why); |
df844fd4 DH |
46 | skb_get(skb); |
47 | } | |
48 | ||
d0d5c0cd DH |
49 | /* |
50 | * Note the dropping of a ref on a socket buffer by the core. | |
51 | */ | |
9a36a6bc | 52 | void rxrpc_eaten_skb(struct sk_buff *skb, enum rxrpc_skb_trace why) |
d0d5c0cd | 53 | { |
d0d5c0cd | 54 | int n = atomic_inc_return(&rxrpc_n_rx_skbs); |
9a36a6bc | 55 | trace_rxrpc_skb(skb, 0, n, why); |
d0d5c0cd DH |
56 | } |
57 | ||
df844fd4 DH |
58 | /* |
59 | * Note the destruction of a socket buffer. | |
60 | */ | |
9a36a6bc | 61 | void rxrpc_free_skb(struct sk_buff *skb, enum rxrpc_skb_trace why) |
df844fd4 | 62 | { |
df844fd4 | 63 | if (skb) { |
9a36a6bc DH |
64 | int n = atomic_dec_return(select_skb_count(skb)); |
65 | trace_rxrpc_skb(skb, refcount_read(&skb->users), n, why); | |
16d5677e | 66 | consume_skb(skb); |
df844fd4 DH |
67 | } |
68 | } | |
69 | ||
70 | /* | |
71 | * Clear a queue of socket buffers. | |
72 | */ | |
73 | void rxrpc_purge_queue(struct sk_buff_head *list) | |
74 | { | |
df844fd4 | 75 | struct sk_buff *skb; |
9a36a6bc | 76 | |
df844fd4 | 77 | while ((skb = skb_dequeue((list))) != NULL) { |
987db9f7 | 78 | int n = atomic_dec_return(select_skb_count(skb)); |
9a36a6bc DH |
79 | trace_rxrpc_skb(skb, refcount_read(&skb->users), n, |
80 | rxrpc_skb_put_purge); | |
16d5677e | 81 | consume_skb(skb); |
df844fd4 DH |
82 | } |
83 | } |