1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
/* Copyright (c) 2014, 2016-2017 The Linux Foundation. All rights reserved.
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License version 2 and
* only version 2 as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
*
* RMNET Data statistics
*
*/
#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/export.h>
#include <linux/skbuff.h>
#include <linux/spinlock.h>
#include <linux/netdevice.h>
#include "rmnet_private.h"
#include "rmnet_stats.h"
#include "rmnet_config.h"
#include "rmnet_map.h"
enum rmnet_deagg_e {
RMNET_STATS_AGG_BUFF,
RMNET_STATS_AGG_PKT,
RMNET_STATS_AGG_MAX
};
static DEFINE_SPINLOCK(rmnet_skb_free_lock);
unsigned long int skb_free[RMNET_STATS_SKBFREE_MAX];
module_param_array(skb_free, ulong, 0, 0444);
MODULE_PARM_DESC(skb_free, "SKBs dropped or freed");
static DEFINE_SPINLOCK(rmnet_queue_xmit_lock);
unsigned long int queue_xmit[RMNET_STATS_QUEUE_XMIT_MAX * 2];
module_param_array(queue_xmit, ulong, 0, 0444);
MODULE_PARM_DESC(queue_xmit, "SKBs queued for transmit");
static DEFINE_SPINLOCK(rmnet_deagg_count);
unsigned long int deagg_count[RMNET_STATS_AGG_MAX];
module_param_array(deagg_count, ulong, 0, 0444);
MODULE_PARM_DESC(deagg_count, "SKBs De-aggregated");
void rmnet_kfree_skb(struct sk_buff *skb, unsigned int reason)
{
unsigned long flags;
if (reason >= RMNET_STATS_SKBFREE_MAX)
reason = RMNET_STATS_SKBFREE_UNKNOWN;
spin_lock_irqsave(&rmnet_skb_free_lock, flags);
skb_free[reason]++;
spin_unlock_irqrestore(&rmnet_skb_free_lock, flags);
if (skb)
kfree_skb(skb);
}
void rmnet_stats_queue_xmit(int rc, unsigned int reason)
{
unsigned long flags;
if (rc != 0)
reason += RMNET_STATS_QUEUE_XMIT_MAX;
if (reason >= RMNET_STATS_QUEUE_XMIT_MAX * 2)
reason = RMNET_STATS_SKBFREE_UNKNOWN;
spin_lock_irqsave(&rmnet_queue_xmit_lock, flags);
queue_xmit[reason]++;
spin_unlock_irqrestore(&rmnet_queue_xmit_lock, flags);
}
void rmnet_stats_deagg_pkts(int aggcount)
{
unsigned long flags;
spin_lock_irqsave(&rmnet_deagg_count, flags);
deagg_count[RMNET_STATS_AGG_BUFF]++;
deagg_count[RMNET_STATS_AGG_PKT] += aggcount;
spin_unlock_irqrestore(&rmnet_deagg_count, flags);
}
|
