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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
|
/*
* m_sample.c ingress/egress packet sampling module
*
* This program is free software; you can distribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version
* 2 of the License, or (at your option) any later version.
*
* Authors: Yotam Gigi <yotamg@mellanox.com>
*
*/
#include <stdio.h>
#include "utils.h"
#include "tc_util.h"
#include "tc_common.h"
#include <linux/tc_act/tc_sample.h>
static void explain(void)
{
fprintf(stderr,
"Usage: sample SAMPLE_CONF\n"
"where:\n"
"\tSAMPLE_CONF := SAMPLE_PARAMS | SAMPLE_INDEX\n"
"\tSAMPLE_PARAMS := rate RATE group GROUP [trunc SIZE] [SAMPLE_INDEX]\n"
"\tSAMPLE_INDEX := index INDEX\n"
"\tRATE := The ratio of packets observed at the data source to the samples generated.\n"
"\tGROUP := the psample sampling group\n"
"\tSIZE := the truncation size\n"
"\tINDEX := integer index of the sample action\n");
}
static void usage(void)
{
explain();
exit(-1);
}
static int parse_sample(struct action_util *a, int *argc_p, char ***argv_p,
int tca_id, struct nlmsghdr *n)
{
struct tc_sample p = { 0 };
bool trunc_set = false;
bool group_set = false;
bool rate_set = false;
char **argv = *argv_p;
struct rtattr *tail;
int argc = *argc_p;
__u32 trunc;
__u32 group;
__u32 rate;
if (argc <= 1) {
fprintf(stderr, "sample bad argument count %d\n", argc);
usage();
return -1;
}
if (matches(*argv, "sample") == 0) {
NEXT_ARG();
} else {
fprintf(stderr, "sample bad argument %s\n", *argv);
return -1;
}
while (argc > 0) {
if (matches(*argv, "rate") == 0) {
NEXT_ARG();
if (get_u32(&rate, *argv, 10) != 0) {
fprintf(stderr, "Illegal rate %s\n", *argv);
usage();
return -1;
}
rate_set = true;
} else if (matches(*argv, "group") == 0) {
NEXT_ARG();
if (get_u32(&group, *argv, 10) != 0) {
fprintf(stderr, "Illegal group num %s\n",
*argv);
usage();
return -1;
}
group_set = true;
} else if (matches(*argv, "trunc") == 0) {
NEXT_ARG();
if (get_u32(&trunc, *argv, 10) != 0) {
fprintf(stderr, "Illegal truncation size %s\n",
*argv);
usage();
return -1;
}
trunc_set = true;
} else if (matches(*argv, "help") == 0) {
usage();
} else {
break;
}
NEXT_ARG_FWD();
}
parse_action_control_dflt(&argc, &argv, &p.action, false, TC_ACT_PIPE);
if (argc) {
if (matches(*argv, "index") == 0) {
NEXT_ARG();
if (get_u32(&p.index, *argv, 10)) {
fprintf(stderr, "sample: Illegal \"index\"\n");
return -1;
}
NEXT_ARG_FWD();
}
}
if (!p.index && !group_set) {
fprintf(stderr, "param \"group\" not set\n");
usage();
}
if (!p.index && !rate_set) {
fprintf(stderr, "param \"rate\" not set\n");
usage();
}
tail = addattr_nest(n, MAX_MSG, tca_id);
addattr_l(n, MAX_MSG, TCA_SAMPLE_PARMS, &p, sizeof(p));
if (rate_set)
addattr32(n, MAX_MSG, TCA_SAMPLE_RATE, rate);
if (group_set)
addattr32(n, MAX_MSG, TCA_SAMPLE_PSAMPLE_GROUP, group);
if (trunc_set)
addattr32(n, MAX_MSG, TCA_SAMPLE_TRUNC_SIZE, trunc);
addattr_nest_end(n, tail);
*argc_p = argc;
*argv_p = argv;
return 0;
}
static int print_sample(struct action_util *au, FILE *f, struct rtattr *arg)
{
struct rtattr *tb[TCA_SAMPLE_MAX + 1];
struct tc_sample *p;
print_string(PRINT_ANY, "kind", "%s ", "sample");
if (arg == NULL)
return 0;
parse_rtattr_nested(tb, TCA_SAMPLE_MAX, arg);
if (!tb[TCA_SAMPLE_PARMS] || !tb[TCA_SAMPLE_RATE] ||
!tb[TCA_SAMPLE_PSAMPLE_GROUP]) {
fprintf(stderr, "Missing sample parameters\n");
return -1;
}
p = RTA_DATA(tb[TCA_SAMPLE_PARMS]);
print_uint(PRINT_ANY, "rate", "rate 1/%u ",
rta_getattr_u32(tb[TCA_SAMPLE_RATE]));
print_uint(PRINT_ANY, "group", "group %u",
rta_getattr_u32(tb[TCA_SAMPLE_PSAMPLE_GROUP]));
if (tb[TCA_SAMPLE_TRUNC_SIZE])
print_uint(PRINT_ANY, "trunc_size", " trunc_size %u",
rta_getattr_u32(tb[TCA_SAMPLE_TRUNC_SIZE]));
print_action_control(f, " ", p->action, "");
print_nl();
print_uint(PRINT_ANY, "index", "\t index %u", p->index);
print_int(PRINT_ANY, "ref", " ref %d", p->refcnt);
print_int(PRINT_ANY, "bind", " bind %d", p->bindcnt);
if (show_stats) {
if (tb[TCA_SAMPLE_TM]) {
struct tcf_t *tm = RTA_DATA(tb[TCA_SAMPLE_TM]);
print_tm(f, tm);
}
}
print_nl();
return 0;
}
struct action_util sample_action_util = {
.id = "sample",
.parse_aopt = parse_sample,
.print_aopt = print_sample,
};
|
