act_api.c 27.6 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
/*
 * net/sched/act_api.c	Packet action API.
 *
 *		This program is free software; you can redistribute 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.
 *
 * Author:	Jamal Hadi Salim
 *
 *
 */

#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/string.h>
#include <linux/errno.h>
18
#include <linux/slab.h>
L
Linus Torvalds 已提交
19 20 21
#include <linux/skbuff.h>
#include <linux/init.h>
#include <linux/kmod.h>
22
#include <linux/err.h>
23
#include <linux/module.h>
24 25
#include <net/net_namespace.h>
#include <net/sock.h>
L
Linus Torvalds 已提交
26
#include <net/sch_generic.h>
27
#include <net/pkt_cls.h>
L
Linus Torvalds 已提交
28
#include <net/act_api.h>
29
#include <net/netlink.h>
L
Linus Torvalds 已提交
30

31 32 33 34 35 36
static int tcf_action_goto_chain_init(struct tc_action *a, struct tcf_proto *tp)
{
	u32 chain_index = a->tcfa_action & TC_ACT_EXT_VAL_MASK;

	if (!tp)
		return -EINVAL;
37
	a->goto_chain = tcf_chain_get(tp->chain->block, chain_index, true);
38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
	if (!a->goto_chain)
		return -ENOMEM;
	return 0;
}

static void tcf_action_goto_chain_fini(struct tc_action *a)
{
	tcf_chain_put(a->goto_chain);
}

static void tcf_action_goto_chain_exec(const struct tc_action *a,
				       struct tcf_result *res)
{
	const struct tcf_chain *chain = a->goto_chain;

	res->goto_tp = rcu_dereference_bh(chain->filter_chain);
}

56 57
static void free_tcf(struct rcu_head *head)
{
58
	struct tc_action *p = container_of(head, struct tc_action, tcfa_rcu);
59 60 61

	free_percpu(p->cpu_bstats);
	free_percpu(p->cpu_qstats);
62 63 64 65 66

	if (p->act_cookie) {
		kfree(p->act_cookie->data);
		kfree(p->act_cookie);
	}
67 68
	if (p->goto_chain)
		tcf_action_goto_chain_fini(p);
69

70 71 72
	kfree(p);
}

73
static void tcf_hash_destroy(struct tcf_hashinfo *hinfo, struct tc_action *p)
74
{
75
	spin_lock_bh(&hinfo->lock);
76
	hlist_del(&p->tcfa_head);
77
	spin_unlock_bh(&hinfo->lock);
78
	gen_kill_estimator(&p->tcfa_rate_est);
79
	/*
80
	 * gen_estimator est_timer() might access p->tcfa_lock
81 82
	 * or bstats, wait a RCU grace period before freeing p
	 */
83
	call_rcu(&p->tcfa_rcu, free_tcf);
84 85
}

86
int __tcf_hash_release(struct tc_action *p, bool bind, bool strict)
87 88 89 90 91
{
	int ret = 0;

	if (p) {
		if (bind)
92 93
			p->tcfa_bindcnt--;
		else if (strict && p->tcfa_bindcnt > 0)
94
			return -EPERM;
95

96 97 98 99 100
		p->tcfa_refcnt--;
		if (p->tcfa_bindcnt <= 0 && p->tcfa_refcnt <= 0) {
			if (p->ops->cleanup)
				p->ops->cleanup(p, bind);
			tcf_hash_destroy(p->hinfo, p);
101
			ret = ACT_P_DELETED;
102 103
		}
	}
104

105 106
	return ret;
}
107
EXPORT_SYMBOL(__tcf_hash_release);
108

109
static int tcf_dump_walker(struct tcf_hashinfo *hinfo, struct sk_buff *skb,
110
			   struct netlink_callback *cb)
111
{
E
Eric Dumazet 已提交
112
	int err = 0, index = -1, i = 0, s_i = 0, n_i = 0;
113
	u32 act_flags = cb->args[2];
114
	unsigned long jiffy_since = cb->args[3];
115
	struct nlattr *nest;
116

117
	spin_lock_bh(&hinfo->lock);
118 119 120 121

	s_i = cb->args[0];

	for (i = 0; i < (hinfo->hmask + 1); i++) {
122
		struct hlist_head *head;
123
		struct tc_action *p;
124

125
		head = &hinfo->htab[tcf_hash(i, hinfo->hmask)];
126

127
		hlist_for_each_entry_rcu(p, head, tcfa_head) {
128 129 130
			index++;
			if (index < s_i)
				continue;
131

132 133 134 135 136
			if (jiffy_since &&
			    time_after(jiffy_since,
				       (unsigned long)p->tcfa_tm.lastuse))
				continue;

137
			nest = nla_nest_start(skb, n_i);
138 139
			if (nest == NULL)
				goto nla_put_failure;
140
			err = tcf_action_dump_1(skb, p, 0, 0);
141 142
			if (err < 0) {
				index--;
143
				nlmsg_trim(skb, nest);
144 145
				goto done;
			}
146
			nla_nest_end(skb, nest);
147
			n_i++;
148 149
			if (!(act_flags & TCA_FLAG_LARGE_DUMP_ON) &&
			    n_i >= TCA_ACT_MAX_PRIO)
150 151 152 153
				goto done;
		}
	}
done:
154 155 156
	if (index >= 0)
		cb->args[0] = index + 1;

157
	spin_unlock_bh(&hinfo->lock);
158 159 160 161
	if (n_i) {
		if (act_flags & TCA_FLAG_LARGE_DUMP_ON)
			cb->args[1] = n_i;
	}
162 163
	return n_i;

164
nla_put_failure:
165
	nla_nest_cancel(skb, nest);
166 167 168
	goto done;
}

169
static int tcf_del_walker(struct tcf_hashinfo *hinfo, struct sk_buff *skb,
170
			  const struct tc_action_ops *ops)
171
{
172
	struct nlattr *nest;
E
Eric Dumazet 已提交
173
	int i = 0, n_i = 0;
174
	int ret = -EINVAL;
175

176
	nest = nla_nest_start(skb, 0);
177 178
	if (nest == NULL)
		goto nla_put_failure;
179
	if (nla_put_string(skb, TCA_KIND, ops->kind))
180
		goto nla_put_failure;
181
	for (i = 0; i < (hinfo->hmask + 1); i++) {
182 183
		struct hlist_head *head;
		struct hlist_node *n;
184
		struct tc_action *p;
185

186
		head = &hinfo->htab[tcf_hash(i, hinfo->hmask)];
187 188
		hlist_for_each_entry_safe(p, n, head, tcfa_head) {
			ret = __tcf_hash_release(p, false, true);
189
			if (ret == ACT_P_DELETED) {
190
				module_put(p->ops->owner);
191
				n_i++;
192 193
			} else if (ret < 0)
				goto nla_put_failure;
194 195
		}
	}
196 197
	if (nla_put_u32(skb, TCA_FCNT, n_i))
		goto nla_put_failure;
198
	nla_nest_end(skb, nest);
199 200

	return n_i;
201
nla_put_failure:
202
	nla_nest_cancel(skb, nest);
203
	return ret;
204 205
}

206 207
int tcf_generic_walker(struct tc_action_net *tn, struct sk_buff *skb,
		       struct netlink_callback *cb, int type,
208
		       const struct tc_action_ops *ops)
209
{
210 211
	struct tcf_hashinfo *hinfo = tn->hinfo;

212
	if (type == RTM_DELACTION) {
213
		return tcf_del_walker(hinfo, skb, ops);
214
	} else if (type == RTM_GETACTION) {
215
		return tcf_dump_walker(hinfo, skb, cb);
216
	} else {
217
		WARN(1, "tcf_generic_walker: unknown action %d\n", type);
218 219 220
		return -EINVAL;
	}
}
221
EXPORT_SYMBOL(tcf_generic_walker);
222

223
static struct tc_action *tcf_hash_lookup(u32 index, struct tcf_hashinfo *hinfo)
224
{
225
	struct tc_action *p = NULL;
226
	struct hlist_head *head;
227

228 229
	spin_lock_bh(&hinfo->lock);
	head = &hinfo->htab[tcf_hash(index, hinfo->hmask)];
230 231
	hlist_for_each_entry_rcu(p, head, tcfa_head)
		if (p->tcfa_index == index)
232
			break;
233
	spin_unlock_bh(&hinfo->lock);
234 235 236 237

	return p;
}

238
u32 tcf_hash_new_index(struct tc_action_net *tn)
239
{
240
	struct tcf_hashinfo *hinfo = tn->hinfo;
241
	u32 val = hinfo->index;
242 243 244 245 246 247

	do {
		if (++val == 0)
			val = 1;
	} while (tcf_hash_lookup(val, hinfo));

248
	hinfo->index = val;
249
	return val;
250 251 252
}
EXPORT_SYMBOL(tcf_hash_new_index);

253
int tcf_hash_search(struct tc_action_net *tn, struct tc_action **a, u32 index)
254
{
255
	struct tcf_hashinfo *hinfo = tn->hinfo;
256
	struct tc_action *p = tcf_hash_lookup(index, hinfo);
257 258

	if (p) {
259
		*a = p;
260 261 262 263
		return 1;
	}
	return 0;
}
264
EXPORT_SYMBOL(tcf_hash_search);
265

266
bool tcf_hash_check(struct tc_action_net *tn, u32 index, struct tc_action **a,
267
		    int bind)
268
{
269
	struct tcf_hashinfo *hinfo = tn->hinfo;
270 271
	struct tc_action *p = NULL;

272
	if (index && (p = tcf_hash_lookup(index, hinfo)) != NULL) {
273
		if (bind)
274 275 276
			p->tcfa_bindcnt++;
		p->tcfa_refcnt++;
		*a = p;
277
		return true;
278
	}
279
	return false;
280 281 282
}
EXPORT_SYMBOL(tcf_hash_check);

283 284 285
void tcf_hash_cleanup(struct tc_action *a, struct nlattr *est)
{
	if (est)
286
		gen_kill_estimator(&a->tcfa_rate_est);
287
	call_rcu(&a->tcfa_rcu, free_tcf);
288 289 290
}
EXPORT_SYMBOL(tcf_hash_cleanup);

291
int tcf_hash_create(struct tc_action_net *tn, u32 index, struct nlattr *est,
292 293
		    struct tc_action **a, const struct tc_action_ops *ops,
		    int bind, bool cpustats)
294
{
295
	struct tc_action *p = kzalloc(ops->size, GFP_KERNEL);
296
	struct tcf_hashinfo *hinfo = tn->hinfo;
297
	int err = -ENOMEM;
298 299

	if (unlikely(!p))
300
		return -ENOMEM;
301
	p->tcfa_refcnt = 1;
302
	if (bind)
303
		p->tcfa_bindcnt = 1;
304

305 306 307 308 309 310 311 312 313 314 315 316 317 318
	if (cpustats) {
		p->cpu_bstats = netdev_alloc_pcpu_stats(struct gnet_stats_basic_cpu);
		if (!p->cpu_bstats) {
err1:
			kfree(p);
			return err;
		}
		p->cpu_qstats = alloc_percpu(struct gnet_stats_queue);
		if (!p->cpu_qstats) {
err2:
			free_percpu(p->cpu_bstats);
			goto err1;
		}
	}
319 320 321 322 323 324
	spin_lock_init(&p->tcfa_lock);
	INIT_HLIST_NODE(&p->tcfa_head);
	p->tcfa_index = index ? index : tcf_hash_new_index(tn);
	p->tcfa_tm.install = jiffies;
	p->tcfa_tm.lastuse = jiffies;
	p->tcfa_tm.firstuse = 0;
325
	if (est) {
326 327 328
		err = gen_new_estimator(&p->tcfa_bstats, p->cpu_bstats,
					&p->tcfa_rate_est,
					&p->tcfa_lock, NULL, est);
329
		if (err) {
330 331
			free_percpu(p->cpu_qstats);
			goto err2;
332 333 334
		}
	}

335 336 337 338
	p->hinfo = hinfo;
	p->ops = ops;
	INIT_LIST_HEAD(&p->list);
	*a = p;
339
	return 0;
340 341 342
}
EXPORT_SYMBOL(tcf_hash_create);

343
void tcf_hash_insert(struct tc_action_net *tn, struct tc_action *a)
344
{
345
	struct tcf_hashinfo *hinfo = tn->hinfo;
346
	unsigned int h = tcf_hash(a->tcfa_index, hinfo->hmask);
347

348
	spin_lock_bh(&hinfo->lock);
349
	hlist_add_head(&a->tcfa_head, &hinfo->htab[h]);
350
	spin_unlock_bh(&hinfo->lock);
351 352
}
EXPORT_SYMBOL(tcf_hash_insert);
L
Linus Torvalds 已提交
353

354 355
void tcf_hashinfo_destroy(const struct tc_action_ops *ops,
			  struct tcf_hashinfo *hinfo)
356 357 358 359
{
	int i;

	for (i = 0; i < hinfo->hmask + 1; i++) {
360
		struct tc_action *p;
361 362
		struct hlist_node *n;

363
		hlist_for_each_entry_safe(p, n, &hinfo->htab[i], tcfa_head) {
364 365
			int ret;

366
			ret = __tcf_hash_release(p, false, true);
367 368 369 370 371 372 373 374
			if (ret == ACT_P_DELETED)
				module_put(ops->owner);
			else if (ret < 0)
				return;
		}
	}
	kfree(hinfo->htab);
}
375
EXPORT_SYMBOL(tcf_hashinfo_destroy);
376

377
static LIST_HEAD(act_base);
L
Linus Torvalds 已提交
378 379
static DEFINE_RWLOCK(act_mod_lock);

380 381
int tcf_register_action(struct tc_action_ops *act,
			struct pernet_operations *ops)
L
Linus Torvalds 已提交
382
{
383
	struct tc_action_ops *a;
384
	int ret;
L
Linus Torvalds 已提交
385

386
	if (!act->act || !act->dump || !act->init || !act->walk || !act->lookup)
387 388
		return -EINVAL;

389 390 391 392 393 394 395 396
	/* We have to register pernet ops before making the action ops visible,
	 * otherwise tcf_action_init_1() could get a partially initialized
	 * netns.
	 */
	ret = register_pernet_subsys(ops);
	if (ret)
		return ret;

L
Linus Torvalds 已提交
397
	write_lock(&act_mod_lock);
398
	list_for_each_entry(a, &act_base, head) {
L
Linus Torvalds 已提交
399 400
		if (act->type == a->type || (strcmp(act->kind, a->kind) == 0)) {
			write_unlock(&act_mod_lock);
401
			unregister_pernet_subsys(ops);
L
Linus Torvalds 已提交
402 403 404
			return -EEXIST;
		}
	}
405
	list_add_tail(&act->head, &act_base);
L
Linus Torvalds 已提交
406
	write_unlock(&act_mod_lock);
407

L
Linus Torvalds 已提交
408 409
	return 0;
}
410
EXPORT_SYMBOL(tcf_register_action);
L
Linus Torvalds 已提交
411

412 413
int tcf_unregister_action(struct tc_action_ops *act,
			  struct pernet_operations *ops)
L
Linus Torvalds 已提交
414
{
415
	struct tc_action_ops *a;
L
Linus Torvalds 已提交
416 417 418
	int err = -ENOENT;

	write_lock(&act_mod_lock);
419 420 421 422
	list_for_each_entry(a, &act_base, head) {
		if (a == act) {
			list_del(&act->head);
			err = 0;
L
Linus Torvalds 已提交
423
			break;
424
		}
L
Linus Torvalds 已提交
425 426
	}
	write_unlock(&act_mod_lock);
427 428
	if (!err)
		unregister_pernet_subsys(ops);
L
Linus Torvalds 已提交
429 430
	return err;
}
431
EXPORT_SYMBOL(tcf_unregister_action);
L
Linus Torvalds 已提交
432 433 434 435

/* lookup by name */
static struct tc_action_ops *tc_lookup_action_n(char *kind)
{
436
	struct tc_action_ops *a, *res = NULL;
L
Linus Torvalds 已提交
437 438 439

	if (kind) {
		read_lock(&act_mod_lock);
440
		list_for_each_entry(a, &act_base, head) {
L
Linus Torvalds 已提交
441
			if (strcmp(kind, a->kind) == 0) {
442 443
				if (try_module_get(a->owner))
					res = a;
L
Linus Torvalds 已提交
444 445 446 447 448
				break;
			}
		}
		read_unlock(&act_mod_lock);
	}
449
	return res;
L
Linus Torvalds 已提交
450 451
}

452 453
/* lookup by nlattr */
static struct tc_action_ops *tc_lookup_action(struct nlattr *kind)
L
Linus Torvalds 已提交
454
{
455
	struct tc_action_ops *a, *res = NULL;
L
Linus Torvalds 已提交
456 457 458

	if (kind) {
		read_lock(&act_mod_lock);
459
		list_for_each_entry(a, &act_base, head) {
460
			if (nla_strcmp(kind, a->kind) == 0) {
461 462
				if (try_module_get(a->owner))
					res = a;
L
Linus Torvalds 已提交
463 464 465 466 467
				break;
			}
		}
		read_unlock(&act_mod_lock);
	}
468
	return res;
L
Linus Torvalds 已提交
469 470
}

471 472
/*TCA_ACT_MAX_PRIO is 32, there count upto 32 */
#define TCA_ACT_MAX_PRIO_MASK 0x1FF
473 474
int tcf_action_exec(struct sk_buff *skb, struct tc_action **actions,
		    int nr_actions, struct tcf_result *res)
L
Linus Torvalds 已提交
475
{
476
	int ret = -1, i;
477 478
	u32 jmp_prgcnt = 0;
	u32 jmp_ttl = TCA_ACT_MAX_PRIO; /*matches actions per filter */
L
Linus Torvalds 已提交
479

480 481 482
	if (skb_skip_tc_classify(skb))
		return TC_ACT_OK;

483
restart_act_graph:
484 485 486
	for (i = 0; i < nr_actions; i++) {
		const struct tc_action *a = actions[i];

487 488 489 490
		if (jmp_prgcnt > 0) {
			jmp_prgcnt -= 1;
			continue;
		}
L
Linus Torvalds 已提交
491
repeat:
492 493 494
		ret = a->ops->act(skb, a, res);
		if (ret == TC_ACT_REPEAT)
			goto repeat;	/* we need a ttl - JHS */
495

496
		if (TC_ACT_EXT_CMP(ret, TC_ACT_JUMP)) {
497 498 499 500 501 502 503 504 505 506 507
			jmp_prgcnt = ret & TCA_ACT_MAX_PRIO_MASK;
			if (!jmp_prgcnt || (jmp_prgcnt > nr_actions)) {
				/* faulty opcode, stop pipeline */
				return TC_ACT_OK;
			} else {
				jmp_ttl -= 1;
				if (jmp_ttl > 0)
					goto restart_act_graph;
				else /* faulty graph, stop pipeline */
					return TC_ACT_OK;
			}
508 509
		} else if (TC_ACT_EXT_CMP(ret, TC_ACT_GOTO_CHAIN)) {
			tcf_action_goto_chain_exec(a, res);
510 511
		}

512
		if (ret != TC_ACT_PIPE)
513
			break;
L
Linus Torvalds 已提交
514
	}
515

L
Linus Torvalds 已提交
516 517
	return ret;
}
518
EXPORT_SYMBOL(tcf_action_exec);
L
Linus Torvalds 已提交
519

520
int tcf_action_destroy(struct list_head *actions, int bind)
L
Linus Torvalds 已提交
521
{
522
	struct tc_action *a, *tmp;
523
	int ret = 0;
L
Linus Torvalds 已提交
524

525
	list_for_each_entry_safe(a, tmp, actions, list) {
526
		ret = __tcf_hash_release(a, bind, true);
527
		if (ret == ACT_P_DELETED)
528
			module_put(a->ops->owner);
529 530
		else if (ret < 0)
			return ret;
L
Linus Torvalds 已提交
531
	}
532
	return ret;
L
Linus Torvalds 已提交
533 534 535 536 537 538 539 540 541 542 543 544
}

int
tcf_action_dump_old(struct sk_buff *skb, struct tc_action *a, int bind, int ref)
{
	return a->ops->dump(skb, a, bind, ref);
}

int
tcf_action_dump_1(struct sk_buff *skb, struct tc_action *a, int bind, int ref)
{
	int err = -EINVAL;
545
	unsigned char *b = skb_tail_pointer(skb);
546
	struct nlattr *nest;
L
Linus Torvalds 已提交
547

548 549
	if (nla_put_string(skb, TCA_KIND, a->ops->kind))
		goto nla_put_failure;
L
Linus Torvalds 已提交
550
	if (tcf_action_copy_stats(skb, a, 0))
551
		goto nla_put_failure;
552 553 554 555 556 557
	if (a->act_cookie) {
		if (nla_put(skb, TCA_ACT_COOKIE, a->act_cookie->len,
			    a->act_cookie->data))
			goto nla_put_failure;
	}

558 559 560
	nest = nla_nest_start(skb, TCA_OPTIONS);
	if (nest == NULL)
		goto nla_put_failure;
E
Eric Dumazet 已提交
561 562
	err = tcf_action_dump_old(skb, a, bind, ref);
	if (err > 0) {
563
		nla_nest_end(skb, nest);
L
Linus Torvalds 已提交
564 565 566
		return err;
	}

567
nla_put_failure:
568
	nlmsg_trim(skb, b);
L
Linus Torvalds 已提交
569 570
	return -1;
}
571
EXPORT_SYMBOL(tcf_action_dump_1);
L
Linus Torvalds 已提交
572

573 574
int tcf_action_dump(struct sk_buff *skb, struct list_head *actions,
		    int bind, int ref)
L
Linus Torvalds 已提交
575 576 577
{
	struct tc_action *a;
	int err = -EINVAL;
578
	struct nlattr *nest;
L
Linus Torvalds 已提交
579

580
	list_for_each_entry(a, actions, list) {
581 582 583
		nest = nla_nest_start(skb, a->order);
		if (nest == NULL)
			goto nla_put_failure;
L
Linus Torvalds 已提交
584 585
		err = tcf_action_dump_1(skb, a, bind, ref);
		if (err < 0)
586
			goto errout;
587
		nla_nest_end(skb, nest);
L
Linus Torvalds 已提交
588 589 590 591
	}

	return 0;

592
nla_put_failure:
593 594
	err = -EINVAL;
errout:
595
	nla_nest_cancel(skb, nest);
596
	return err;
L
Linus Torvalds 已提交
597 598
}

599
static struct tc_cookie *nla_memdup_cookie(struct nlattr **tb)
600
{
601 602 603 604 605 606 607 608
	struct tc_cookie *c = kzalloc(sizeof(*c), GFP_KERNEL);
	if (!c)
		return NULL;

	c->data = nla_memdup(tb[TCA_ACT_COOKIE], GFP_KERNEL);
	if (!c->data) {
		kfree(c);
		return NULL;
609
	}
610
	c->len = nla_len(tb[TCA_ACT_COOKIE]);
611

612
	return c;
613 614
}

615 616 617
struct tc_action *tcf_action_init_1(struct net *net, struct tcf_proto *tp,
				    struct nlattr *nla, struct nlattr *est,
				    char *name, int ovr, int bind)
L
Linus Torvalds 已提交
618 619 620
{
	struct tc_action *a;
	struct tc_action_ops *a_o;
621
	struct tc_cookie *cookie = NULL;
L
Linus Torvalds 已提交
622
	char act_name[IFNAMSIZ];
E
Eric Dumazet 已提交
623
	struct nlattr *tb[TCA_ACT_MAX + 1];
624
	struct nlattr *kind;
625
	int err;
L
Linus Torvalds 已提交
626 627

	if (name == NULL) {
628
		err = nla_parse_nested(tb, TCA_ACT_MAX, nla, NULL, NULL);
629
		if (err < 0)
L
Linus Torvalds 已提交
630
			goto err_out;
631
		err = -EINVAL;
632
		kind = tb[TCA_ACT_KIND];
L
Linus Torvalds 已提交
633 634
		if (kind == NULL)
			goto err_out;
635
		if (nla_strlcpy(act_name, kind, IFNAMSIZ) >= IFNAMSIZ)
L
Linus Torvalds 已提交
636
			goto err_out;
637 638 639 640 641 642 643 644 645 646 647 648
		if (tb[TCA_ACT_COOKIE]) {
			int cklen = nla_len(tb[TCA_ACT_COOKIE]);

			if (cklen > TC_COOKIE_MAX_SIZE)
				goto err_out;

			cookie = nla_memdup_cookie(tb);
			if (!cookie) {
				err = -ENOMEM;
				goto err_out;
			}
		}
L
Linus Torvalds 已提交
649
	} else {
650
		err = -EINVAL;
L
Linus Torvalds 已提交
651 652 653 654 655 656
		if (strlcpy(act_name, name, IFNAMSIZ) >= IFNAMSIZ)
			goto err_out;
	}

	a_o = tc_lookup_action_n(act_name);
	if (a_o == NULL) {
657
#ifdef CONFIG_MODULES
L
Linus Torvalds 已提交
658
		rtnl_unlock();
659
		request_module("act_%s", act_name);
L
Linus Torvalds 已提交
660 661 662 663 664 665 666 667 668 669 670
		rtnl_lock();

		a_o = tc_lookup_action_n(act_name);

		/* We dropped the RTNL semaphore in order to
		 * perform the module load.  So, even if we
		 * succeeded in loading the module we have to
		 * tell the caller to replay the request.  We
		 * indicate this using -EAGAIN.
		 */
		if (a_o != NULL) {
671
			err = -EAGAIN;
L
Linus Torvalds 已提交
672 673 674
			goto err_mod;
		}
#endif
675
		err = -ENOENT;
L
Linus Torvalds 已提交
676 677 678 679 680
		goto err_out;
	}

	/* backward compatibility for policer */
	if (name == NULL)
681
		err = a_o->init(net, tb[TCA_ACT_OPTIONS], est, &a, ovr, bind);
L
Linus Torvalds 已提交
682
	else
683
		err = a_o->init(net, nla, est, &a, ovr, bind);
684
	if (err < 0)
685
		goto err_mod;
L
Linus Torvalds 已提交
686

687 688 689 690
	if (name == NULL && tb[TCA_ACT_COOKIE]) {
		if (a->act_cookie) {
			kfree(a->act_cookie->data);
			kfree(a->act_cookie);
691
		}
692
		a->act_cookie = cookie;
693 694
	}

L
Linus Torvalds 已提交
695
	/* module count goes up only when brand new policy is created
E
Eric Dumazet 已提交
696 697 698
	 * if it exists and is only bound to in a_o->init() then
	 * ACT_P_CREATED is not returned (a zero is).
	 */
699
	if (err != ACT_P_CREATED)
L
Linus Torvalds 已提交
700 701
		module_put(a_o->owner);

702 703 704 705 706 707 708 709 710 711 712
	if (TC_ACT_EXT_CMP(a->tcfa_action, TC_ACT_GOTO_CHAIN)) {
		err = tcf_action_goto_chain_init(a, tp);
		if (err) {
			LIST_HEAD(actions);

			list_add_tail(&a->list, &actions);
			tcf_action_destroy(&actions, bind);
			return ERR_PTR(err);
		}
	}

L
Linus Torvalds 已提交
713 714 715 716 717
	return a;

err_mod:
	module_put(a_o->owner);
err_out:
718 719 720 721
	if (cookie) {
		kfree(cookie->data);
		kfree(cookie);
	}
722
	return ERR_PTR(err);
L
Linus Torvalds 已提交
723 724
}

725 726 727 728 729 730 731 732 733 734 735
static void cleanup_a(struct list_head *actions, int ovr)
{
	struct tc_action *a;

	if (!ovr)
		return;

	list_for_each_entry(a, actions, list)
		a->tcfa_refcnt--;
}

736 737 738
int tcf_action_init(struct net *net, struct tcf_proto *tp, struct nlattr *nla,
		    struct nlattr *est, char *name, int ovr, int bind,
		    struct list_head *actions)
L
Linus Torvalds 已提交
739
{
E
Eric Dumazet 已提交
740
	struct nlattr *tb[TCA_ACT_MAX_PRIO + 1];
741
	struct tc_action *act;
742
	int err;
L
Linus Torvalds 已提交
743 744
	int i;

745
	err = nla_parse_nested(tb, TCA_ACT_MAX_PRIO, nla, NULL, NULL);
746
	if (err < 0)
747
		return err;
L
Linus Torvalds 已提交
748

749
	for (i = 1; i <= TCA_ACT_MAX_PRIO && tb[i]; i++) {
750
		act = tcf_action_init_1(net, tp, tb[i], est, name, ovr, bind);
751 752
		if (IS_ERR(act)) {
			err = PTR_ERR(act);
L
Linus Torvalds 已提交
753
			goto err;
754
		}
755
		act->order = i;
756 757
		if (ovr)
			act->tcfa_refcnt++;
758
		list_add_tail(&act->list, actions);
L
Linus Torvalds 已提交
759
	}
760 761 762 763 764

	/* Remove the temp refcnt which was necessary to protect against
	 * destroying an existing action which was being replaced
	 */
	cleanup_a(actions, ovr);
765
	return 0;
L
Linus Torvalds 已提交
766 767

err:
768 769
	tcf_action_destroy(actions, bind);
	return err;
L
Linus Torvalds 已提交
770 771
}

772
int tcf_action_copy_stats(struct sk_buff *skb, struct tc_action *p,
L
Linus Torvalds 已提交
773 774 775 776
			  int compat_mode)
{
	int err = 0;
	struct gnet_dump d;
777

778
	if (p == NULL)
L
Linus Torvalds 已提交
779 780 781
		goto errout;

	/* compat_mode being true specifies a call that is supposed
782
	 * to add additional backward compatibility statistic TLVs.
L
Linus Torvalds 已提交
783 784
	 */
	if (compat_mode) {
785
		if (p->type == TCA_OLD_COMPAT)
L
Linus Torvalds 已提交
786
			err = gnet_stats_start_copy_compat(skb, 0,
787 788
							   TCA_STATS,
							   TCA_XSTATS,
789
							   &p->tcfa_lock, &d,
790
							   TCA_PAD);
L
Linus Torvalds 已提交
791 792 793 794
		else
			return 0;
	} else
		err = gnet_stats_start_copy(skb, TCA_ACT_STATS,
795
					    &p->tcfa_lock, &d, TCA_ACT_PAD);
L
Linus Torvalds 已提交
796 797 798 799

	if (err < 0)
		goto errout;

800
	if (gnet_stats_copy_basic(NULL, &d, p->cpu_bstats, &p->tcfa_bstats) < 0 ||
801
	    gnet_stats_copy_rate_est(&d, &p->tcfa_rate_est) < 0 ||
802
	    gnet_stats_copy_queue(&d, p->cpu_qstats,
803 804
				  &p->tcfa_qstats,
				  p->tcfa_qstats.qlen) < 0)
L
Linus Torvalds 已提交
805 806 807 808 809 810 811 812 813 814 815
		goto errout;

	if (gnet_stats_finish_copy(&d) < 0)
		goto errout;

	return 0;

errout:
	return -1;
}

816 817 818
static int tca_get_fill(struct sk_buff *skb, struct list_head *actions,
			u32 portid, u32 seq, u16 flags, int event, int bind,
			int ref)
L
Linus Torvalds 已提交
819 820 821
{
	struct tcamsg *t;
	struct nlmsghdr *nlh;
822
	unsigned char *b = skb_tail_pointer(skb);
823
	struct nlattr *nest;
L
Linus Torvalds 已提交
824

825
	nlh = nlmsg_put(skb, portid, seq, event, sizeof(*t), flags);
826 827 828
	if (!nlh)
		goto out_nlmsg_trim;
	t = nlmsg_data(nlh);
L
Linus Torvalds 已提交
829
	t->tca_family = AF_UNSPEC;
830 831
	t->tca__pad1 = 0;
	t->tca__pad2 = 0;
832

833 834
	nest = nla_nest_start(skb, TCA_ACT_TAB);
	if (nest == NULL)
835
		goto out_nlmsg_trim;
L
Linus Torvalds 已提交
836

837
	if (tcf_action_dump(skb, actions, bind, ref) < 0)
838
		goto out_nlmsg_trim;
L
Linus Torvalds 已提交
839

840
	nla_nest_end(skb, nest);
841

842
	nlh->nlmsg_len = skb_tail_pointer(skb) - b;
L
Linus Torvalds 已提交
843 844
	return skb->len;

845
out_nlmsg_trim:
846
	nlmsg_trim(skb, b);
L
Linus Torvalds 已提交
847 848 849 850
	return -1;
}

static int
851
tcf_get_notify(struct net *net, u32 portid, struct nlmsghdr *n,
852
	       struct list_head *actions, int event)
L
Linus Torvalds 已提交
853 854 855 856 857 858
{
	struct sk_buff *skb;

	skb = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
	if (!skb)
		return -ENOBUFS;
859 860
	if (tca_get_fill(skb, actions, portid, n->nlmsg_seq, 0, event,
			 0, 0) <= 0) {
L
Linus Torvalds 已提交
861 862 863
		kfree_skb(skb);
		return -EINVAL;
	}
864

865
	return rtnl_unicast(skb, net, portid);
L
Linus Torvalds 已提交
866 867
}

868 869
static struct tc_action *tcf_action_get_1(struct net *net, struct nlattr *nla,
					  struct nlmsghdr *n, u32 portid)
L
Linus Torvalds 已提交
870
{
E
Eric Dumazet 已提交
871
	struct nlattr *tb[TCA_ACT_MAX + 1];
872
	const struct tc_action_ops *ops;
L
Linus Torvalds 已提交
873 874
	struct tc_action *a;
	int index;
875
	int err;
L
Linus Torvalds 已提交
876

877
	err = nla_parse_nested(tb, TCA_ACT_MAX, nla, NULL, NULL);
878
	if (err < 0)
879
		goto err_out;
L
Linus Torvalds 已提交
880

881
	err = -EINVAL;
882 883
	if (tb[TCA_ACT_INDEX] == NULL ||
	    nla_len(tb[TCA_ACT_INDEX]) < sizeof(index))
884
		goto err_out;
885
	index = nla_get_u32(tb[TCA_ACT_INDEX]);
L
Linus Torvalds 已提交
886

887
	err = -EINVAL;
888 889 890
	ops = tc_lookup_action(tb[TCA_ACT_KIND]);
	if (!ops) /* could happen in batch of actions */
		goto err_out;
891
	err = -ENOENT;
892
	if (ops->lookup(net, &a, index) == 0)
L
Linus Torvalds 已提交
893 894
		goto err_mod;

895
	module_put(ops->owner);
L
Linus Torvalds 已提交
896
	return a;
897

L
Linus Torvalds 已提交
898
err_mod:
899
	module_put(ops->owner);
900 901
err_out:
	return ERR_PTR(err);
L
Linus Torvalds 已提交
902 903
}

904
static int tca_action_flush(struct net *net, struct nlattr *nla,
905
			    struct nlmsghdr *n, u32 portid)
L
Linus Torvalds 已提交
906 907 908 909 910 911
{
	struct sk_buff *skb;
	unsigned char *b;
	struct nlmsghdr *nlh;
	struct tcamsg *t;
	struct netlink_callback dcb;
912
	struct nlattr *nest;
E
Eric Dumazet 已提交
913
	struct nlattr *tb[TCA_ACT_MAX + 1];
914
	const struct tc_action_ops *ops;
915
	struct nlattr *kind;
916
	int err = -ENOMEM;
L
Linus Torvalds 已提交
917 918 919

	skb = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
	if (!skb) {
920
		pr_debug("tca_action_flush: failed skb alloc\n");
921
		return err;
L
Linus Torvalds 已提交
922 923
	}

924
	b = skb_tail_pointer(skb);
L
Linus Torvalds 已提交
925

926
	err = nla_parse_nested(tb, TCA_ACT_MAX, nla, NULL, NULL);
927
	if (err < 0)
L
Linus Torvalds 已提交
928 929
		goto err_out;

930
	err = -EINVAL;
931
	kind = tb[TCA_ACT_KIND];
932 933
	ops = tc_lookup_action(kind);
	if (!ops) /*some idjot trying to flush unknown action */
L
Linus Torvalds 已提交
934 935
		goto err_out;

936 937
	nlh = nlmsg_put(skb, portid, n->nlmsg_seq, RTM_DELACTION,
			sizeof(*t), 0);
938 939 940
	if (!nlh)
		goto out_module_put;
	t = nlmsg_data(nlh);
L
Linus Torvalds 已提交
941
	t->tca_family = AF_UNSPEC;
942 943
	t->tca__pad1 = 0;
	t->tca__pad2 = 0;
L
Linus Torvalds 已提交
944

945 946
	nest = nla_nest_start(skb, TCA_ACT_TAB);
	if (nest == NULL)
947
		goto out_module_put;
L
Linus Torvalds 已提交
948

949
	err = ops->walk(net, skb, &dcb, RTM_DELACTION, ops);
950
	if (err <= 0)
951
		goto out_module_put;
L
Linus Torvalds 已提交
952

953
	nla_nest_end(skb, nest);
L
Linus Torvalds 已提交
954

955
	nlh->nlmsg_len = skb_tail_pointer(skb) - b;
L
Linus Torvalds 已提交
956
	nlh->nlmsg_flags |= NLM_F_ROOT;
957
	module_put(ops->owner);
958
	err = rtnetlink_send(skb, net, portid, RTNLGRP_TC,
E
Eric Dumazet 已提交
959
			     n->nlmsg_flags & NLM_F_ECHO);
L
Linus Torvalds 已提交
960 961 962 963 964
	if (err > 0)
		return 0;

	return err;

965
out_module_put:
966
	module_put(ops->owner);
L
Linus Torvalds 已提交
967 968 969 970 971
err_out:
	kfree_skb(skb);
	return err;
}

972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989
static int
tcf_del_notify(struct net *net, struct nlmsghdr *n, struct list_head *actions,
	       u32 portid)
{
	int ret;
	struct sk_buff *skb;

	skb = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
	if (!skb)
		return -ENOBUFS;

	if (tca_get_fill(skb, actions, portid, n->nlmsg_seq, 0, RTM_DELACTION,
			 0, 1) <= 0) {
		kfree_skb(skb);
		return -EINVAL;
	}

	/* now do the delete */
990 991 992 993 994
	ret = tcf_action_destroy(actions, 0);
	if (ret < 0) {
		kfree_skb(skb);
		return ret;
	}
995 996 997 998 999 1000 1001 1002

	ret = rtnetlink_send(skb, net, portid, RTNLGRP_TC,
			     n->nlmsg_flags & NLM_F_ECHO);
	if (ret > 0)
		return 0;
	return ret;
}

L
Linus Torvalds 已提交
1003
static int
1004
tca_action_gd(struct net *net, struct nlattr *nla, struct nlmsghdr *n,
1005
	      u32 portid, int event)
L
Linus Torvalds 已提交
1006
{
1007
	int i, ret;
E
Eric Dumazet 已提交
1008
	struct nlattr *tb[TCA_ACT_MAX_PRIO + 1];
1009 1010
	struct tc_action *act;
	LIST_HEAD(actions);
L
Linus Torvalds 已提交
1011

1012
	ret = nla_parse_nested(tb, TCA_ACT_MAX_PRIO, nla, NULL, NULL);
1013 1014
	if (ret < 0)
		return ret;
L
Linus Torvalds 已提交
1015

E
Eric Dumazet 已提交
1016
	if (event == RTM_DELACTION && n->nlmsg_flags & NLM_F_ROOT) {
1017
		if (tb[1] != NULL)
1018
			return tca_action_flush(net, tb[1], n, portid);
1019 1020
		else
			return -EINVAL;
L
Linus Torvalds 已提交
1021 1022
	}

1023
	for (i = 1; i <= TCA_ACT_MAX_PRIO && tb[i]; i++) {
1024
		act = tcf_action_get_1(net, tb[i], n, portid);
1025 1026
		if (IS_ERR(act)) {
			ret = PTR_ERR(act);
L
Linus Torvalds 已提交
1027
			goto err;
1028
		}
1029
		act->order = i;
1030
		list_add_tail(&act->list, &actions);
L
Linus Torvalds 已提交
1031 1032 1033
	}

	if (event == RTM_GETACTION)
1034
		ret = tcf_get_notify(net, portid, n, &actions, event);
L
Linus Torvalds 已提交
1035
	else { /* delete */
1036 1037
		ret = tcf_del_notify(net, n, &actions, portid);
		if (ret)
L
Linus Torvalds 已提交
1038 1039 1040 1041
			goto err;
		return ret;
	}
err:
1042 1043
	if (event != RTM_GETACTION)
		tcf_action_destroy(&actions, 0);
L
Linus Torvalds 已提交
1044 1045 1046
	return ret;
}

1047 1048 1049
static int
tcf_add_notify(struct net *net, struct nlmsghdr *n, struct list_head *actions,
	       u32 portid)
L
Linus Torvalds 已提交
1050 1051 1052 1053 1054 1055 1056 1057
{
	struct sk_buff *skb;
	int err = 0;

	skb = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
	if (!skb)
		return -ENOBUFS;

1058 1059 1060 1061 1062
	if (tca_get_fill(skb, actions, portid, n->nlmsg_seq, n->nlmsg_flags,
			 RTM_NEWACTION, 0, 0) <= 0) {
		kfree_skb(skb);
		return -EINVAL;
	}
1063

1064 1065
	err = rtnetlink_send(skb, net, portid, RTNLGRP_TC,
			     n->nlmsg_flags & NLM_F_ECHO);
L
Linus Torvalds 已提交
1066 1067 1068 1069 1070
	if (err > 0)
		err = 0;
	return err;
}

J
Jamal Hadi Salim 已提交
1071 1072
static int tcf_action_add(struct net *net, struct nlattr *nla,
			  struct nlmsghdr *n, u32 portid, int ovr)
L
Linus Torvalds 已提交
1073 1074
{
	int ret = 0;
1075
	LIST_HEAD(actions);
L
Linus Torvalds 已提交
1076

1077
	ret = tcf_action_init(net, NULL, nla, NULL, NULL, ovr, 0, &actions);
1078
	if (ret)
1079
		return ret;
L
Linus Torvalds 已提交
1080

1081
	return tcf_add_notify(net, n, &actions, portid);
L
Linus Torvalds 已提交
1082 1083
}

1084 1085 1086 1087
static u32 tcaa_root_flags_allowed = TCA_FLAG_LARGE_DUMP_ON;
static const struct nla_policy tcaa_policy[TCA_ROOT_MAX + 1] = {
	[TCA_ROOT_FLAGS] = { .type = NLA_BITFIELD32,
			     .validation_data = &tcaa_root_flags_allowed },
1088
	[TCA_ROOT_TIME_DELTA]      = { .type = NLA_U32 },
1089 1090
};

1091 1092
static int tc_ctl_action(struct sk_buff *skb, struct nlmsghdr *n,
			 struct netlink_ext_ack *extack)
L
Linus Torvalds 已提交
1093
{
1094
	struct net *net = sock_net(skb->sk);
1095
	struct nlattr *tca[TCA_ROOT_MAX + 1];
1096
	u32 portid = skb ? NETLINK_CB(skb).portid : 0;
L
Linus Torvalds 已提交
1097 1098
	int ret = 0, ovr = 0;

1099 1100
	if ((n->nlmsg_type != RTM_GETACTION) &&
	    !netlink_capable(skb, CAP_NET_ADMIN))
1101 1102
		return -EPERM;

1103
	ret = nlmsg_parse(n, sizeof(struct tcamsg), tca, TCA_ROOT_MAX, NULL,
1104
			  extack);
1105 1106 1107 1108
	if (ret < 0)
		return ret;

	if (tca[TCA_ACT_TAB] == NULL) {
1109
		pr_notice("tc_ctl_action: received NO action attribs\n");
L
Linus Torvalds 已提交
1110 1111 1112
		return -EINVAL;
	}

E
Eric Dumazet 已提交
1113
	/* n->nlmsg_flags & NLM_F_CREATE */
L
Linus Torvalds 已提交
1114 1115 1116
	switch (n->nlmsg_type) {
	case RTM_NEWACTION:
		/* we are going to assume all other flags
L
Lucas De Marchi 已提交
1117
		 * imply create only if it doesn't exist
L
Linus Torvalds 已提交
1118 1119 1120 1121
		 * Note that CREATE | EXCL implies that
		 * but since we want avoid ambiguity (eg when flags
		 * is zero) then just set this
		 */
E
Eric Dumazet 已提交
1122
		if (n->nlmsg_flags & NLM_F_REPLACE)
L
Linus Torvalds 已提交
1123 1124
			ovr = 1;
replay:
1125
		ret = tcf_action_add(net, tca[TCA_ACT_TAB], n, portid, ovr);
L
Linus Torvalds 已提交
1126 1127 1128 1129
		if (ret == -EAGAIN)
			goto replay;
		break;
	case RTM_DELACTION:
1130
		ret = tca_action_gd(net, tca[TCA_ACT_TAB], n,
1131
				    portid, RTM_DELACTION);
L
Linus Torvalds 已提交
1132 1133
		break;
	case RTM_GETACTION:
1134
		ret = tca_action_gd(net, tca[TCA_ACT_TAB], n,
1135
				    portid, RTM_GETACTION);
L
Linus Torvalds 已提交
1136 1137 1138 1139 1140 1141 1142 1143
		break;
	default:
		BUG();
	}

	return ret;
}

1144
static struct nlattr *find_dump_kind(struct nlattr **nla)
L
Linus Torvalds 已提交
1145
{
E
Eric Dumazet 已提交
1146
	struct nlattr *tb1, *tb2[TCA_ACT_MAX + 1];
1147 1148
	struct nlattr *tb[TCA_ACT_MAX_PRIO + 1];
	struct nlattr *kind;
L
Linus Torvalds 已提交
1149

1150
	tb1 = nla[TCA_ACT_TAB];
L
Linus Torvalds 已提交
1151 1152 1153
	if (tb1 == NULL)
		return NULL;

1154
	if (nla_parse(tb, TCA_ACT_MAX_PRIO, nla_data(tb1),
1155
		      NLMSG_ALIGN(nla_len(tb1)), NULL, NULL) < 0)
L
Linus Torvalds 已提交
1156 1157
		return NULL;

1158 1159
	if (tb[1] == NULL)
		return NULL;
1160
	if (nla_parse_nested(tb2, TCA_ACT_MAX, tb[1], NULL, NULL) < 0)
L
Linus Torvalds 已提交
1161
		return NULL;
1162
	kind = tb2[TCA_ACT_KIND];
L
Linus Torvalds 已提交
1163

1164
	return kind;
L
Linus Torvalds 已提交
1165 1166
}

J
Jamal Hadi Salim 已提交
1167
static int tc_dump_action(struct sk_buff *skb, struct netlink_callback *cb)
L
Linus Torvalds 已提交
1168
{
1169
	struct net *net = sock_net(skb->sk);
L
Linus Torvalds 已提交
1170
	struct nlmsghdr *nlh;
1171
	unsigned char *b = skb_tail_pointer(skb);
1172
	struct nlattr *nest;
L
Linus Torvalds 已提交
1173 1174
	struct tc_action_ops *a_o;
	int ret = 0;
1175
	struct tcamsg *t = (struct tcamsg *) nlmsg_data(cb->nlh);
1176 1177
	struct nlattr *tb[TCA_ROOT_MAX + 1];
	struct nlattr *count_attr = NULL;
1178
	unsigned long jiffy_since = 0;
1179 1180
	struct nlattr *kind = NULL;
	struct nla_bitfield32 bf;
1181
	u32 msecs_since = 0;
1182 1183 1184 1185 1186 1187
	u32 act_count = 0;

	ret = nlmsg_parse(cb->nlh, sizeof(struct tcamsg), tb, TCA_ROOT_MAX,
			  tcaa_policy, NULL);
	if (ret < 0)
		return ret;
L
Linus Torvalds 已提交
1188

1189
	kind = find_dump_kind(tb);
L
Linus Torvalds 已提交
1190
	if (kind == NULL) {
1191
		pr_info("tc_dump_action: action bad kind\n");
L
Linus Torvalds 已提交
1192 1193 1194
		return 0;
	}

1195
	a_o = tc_lookup_action(kind);
E
Eric Dumazet 已提交
1196
	if (a_o == NULL)
L
Linus Torvalds 已提交
1197 1198
		return 0;

1199 1200 1201 1202 1203 1204
	cb->args[2] = 0;
	if (tb[TCA_ROOT_FLAGS]) {
		bf = nla_get_bitfield32(tb[TCA_ROOT_FLAGS]);
		cb->args[2] = bf.value;
	}

1205 1206 1207 1208
	if (tb[TCA_ROOT_TIME_DELTA]) {
		msecs_since = nla_get_u32(tb[TCA_ROOT_TIME_DELTA]);
	}

1209
	nlh = nlmsg_put(skb, NETLINK_CB(cb->skb).portid, cb->nlh->nlmsg_seq,
1210 1211 1212
			cb->nlh->nlmsg_type, sizeof(*t), 0);
	if (!nlh)
		goto out_module_put;
1213

1214 1215 1216
	if (msecs_since)
		jiffy_since = jiffies - msecs_to_jiffies(msecs_since);

1217
	t = nlmsg_data(nlh);
L
Linus Torvalds 已提交
1218
	t->tca_family = AF_UNSPEC;
1219 1220
	t->tca__pad1 = 0;
	t->tca__pad2 = 0;
1221
	cb->args[3] = jiffy_since;
1222 1223 1224
	count_attr = nla_reserve(skb, TCA_ROOT_COUNT, sizeof(u32));
	if (!count_attr)
		goto out_module_put;
L
Linus Torvalds 已提交
1225

1226 1227
	nest = nla_nest_start(skb, TCA_ACT_TAB);
	if (nest == NULL)
1228
		goto out_module_put;
L
Linus Torvalds 已提交
1229

1230
	ret = a_o->walk(net, skb, cb, RTM_GETACTION, a_o);
L
Linus Torvalds 已提交
1231
	if (ret < 0)
1232
		goto out_module_put;
L
Linus Torvalds 已提交
1233 1234

	if (ret > 0) {
1235
		nla_nest_end(skb, nest);
L
Linus Torvalds 已提交
1236
		ret = skb->len;
1237 1238 1239
		act_count = cb->args[1];
		memcpy(nla_data(count_attr), &act_count, sizeof(u32));
		cb->args[1] = 0;
L
Linus Torvalds 已提交
1240
	} else
1241
		nlmsg_trim(skb, b);
L
Linus Torvalds 已提交
1242

1243
	nlh->nlmsg_len = skb_tail_pointer(skb) - b;
1244
	if (NETLINK_CB(cb->skb).portid && ret)
L
Linus Torvalds 已提交
1245 1246 1247 1248
		nlh->nlmsg_flags |= NLM_F_MULTI;
	module_put(a_o->owner);
	return skb->len;

1249
out_module_put:
L
Linus Torvalds 已提交
1250
	module_put(a_o->owner);
1251
	nlmsg_trim(skb, b);
L
Linus Torvalds 已提交
1252 1253 1254 1255 1256
	return skb->len;
}

static int __init tc_action_init(void)
{
1257 1258 1259 1260
	rtnl_register(PF_UNSPEC, RTM_NEWACTION, tc_ctl_action, NULL, NULL);
	rtnl_register(PF_UNSPEC, RTM_DELACTION, tc_ctl_action, NULL, NULL);
	rtnl_register(PF_UNSPEC, RTM_GETACTION, tc_ctl_action, tc_dump_action,
		      NULL);
L
Linus Torvalds 已提交
1261 1262 1263 1264 1265

	return 0;
}

subsys_initcall(tc_action_init);