]> git.proxmox.com Git - mirror_iproute2.git/blob - ip/iprule.c
Merge branch 'master' into net-next
[mirror_iproute2.git] / ip / iprule.c
1 /*
2 * iprule.c "ip rule".
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public License
6 * as published by the Free Software Foundation; either version
7 * 2 of the License, or (at your option) any later version.
8 *
9 * Authors: Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
10 *
11 */
12
13 #include <stdio.h>
14 #include <stdlib.h>
15 #include <unistd.h>
16 #include <syslog.h>
17 #include <fcntl.h>
18 #include <sys/socket.h>
19 #include <netinet/in.h>
20 #include <netinet/ip.h>
21 #include <arpa/inet.h>
22 #include <string.h>
23 #include <linux/fib_rules.h>
24 #include <errno.h>
25
26 #include "rt_names.h"
27 #include "utils.h"
28 #include "ip_common.h"
29
30 extern struct rtnl_handle rth;
31
32 static void usage(void) __attribute__((noreturn));
33
34 static void usage(void)
35 {
36 fprintf(stderr, "Usage: ip rule { add | del } SELECTOR ACTION\n");
37 fprintf(stderr, " ip rule { flush | save | restore }\n");
38 fprintf(stderr, " ip rule [ list ]\n");
39 fprintf(stderr, "SELECTOR := [ not ] [ from PREFIX ] [ to PREFIX ] [ tos TOS ] [ fwmark FWMARK[/MASK] ]\n");
40 fprintf(stderr, " [ iif STRING ] [ oif STRING ] [ pref NUMBER ] [ l3mdev ]\n");
41 fprintf(stderr, "ACTION := [ table TABLE_ID ]\n");
42 fprintf(stderr, " [ nat ADDRESS ]\n");
43 fprintf(stderr, " [ realms [SRCREALM/]DSTREALM ]\n");
44 fprintf(stderr, " [ goto NUMBER ]\n");
45 fprintf(stderr, " SUPPRESSOR\n");
46 fprintf(stderr, "SUPPRESSOR := [ suppress_prefixlength NUMBER ]\n");
47 fprintf(stderr, " [ suppress_ifgroup DEVGROUP ]\n");
48 fprintf(stderr, "TABLE_ID := [ local | main | default | NUMBER ]\n");
49 exit(-1);
50 }
51
52 int print_rule(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
53 {
54 FILE *fp = (FILE *)arg;
55 struct rtmsg *r = NLMSG_DATA(n);
56 int len = n->nlmsg_len;
57 int host_len = -1;
58 __u32 table;
59 struct rtattr *tb[FRA_MAX+1];
60
61 SPRINT_BUF(b1);
62
63 if (n->nlmsg_type != RTM_NEWRULE && n->nlmsg_type != RTM_DELRULE)
64 return 0;
65
66 len -= NLMSG_LENGTH(sizeof(*r));
67 if (len < 0)
68 return -1;
69
70 parse_rtattr(tb, FRA_MAX, RTM_RTA(r), len);
71
72 host_len = af_bit_len(r->rtm_family);
73
74 if (n->nlmsg_type == RTM_DELRULE)
75 fprintf(fp, "Deleted ");
76
77 if (tb[FRA_PRIORITY])
78 fprintf(fp, "%u:\t",
79 rta_getattr_u32(tb[FRA_PRIORITY]));
80 else
81 fprintf(fp, "0:\t");
82
83 if (r->rtm_flags & FIB_RULE_INVERT)
84 fprintf(fp, "not ");
85
86 if (tb[FRA_SRC]) {
87 if (r->rtm_src_len != host_len) {
88 fprintf(fp, "from %s/%u ",
89 rt_addr_n2a_rta(r->rtm_family, tb[FRA_SRC]),
90 r->rtm_src_len);
91 } else {
92 fprintf(fp, "from %s ",
93 format_host_rta(r->rtm_family, tb[FRA_SRC]));
94 }
95 } else if (r->rtm_src_len) {
96 fprintf(fp, "from 0/%d ", r->rtm_src_len);
97 } else {
98 fprintf(fp, "from all ");
99 }
100
101 if (tb[FRA_DST]) {
102 if (r->rtm_dst_len != host_len) {
103 fprintf(fp, "to %s/%u ",
104 rt_addr_n2a_rta(r->rtm_family, tb[FRA_DST]),
105 r->rtm_dst_len);
106 } else {
107 fprintf(fp, "to %s ",
108 format_host_rta(r->rtm_family, tb[FRA_DST]));
109 }
110 } else if (r->rtm_dst_len) {
111 fprintf(fp, "to 0/%d ", r->rtm_dst_len);
112 }
113
114 if (r->rtm_tos) {
115 SPRINT_BUF(b1);
116 fprintf(fp, "tos %s ",
117 rtnl_dsfield_n2a(r->rtm_tos, b1, sizeof(b1)));
118 }
119
120 if (tb[FRA_FWMARK] || tb[FRA_FWMASK]) {
121 __u32 mark = 0, mask = 0;
122
123 if (tb[FRA_FWMARK])
124 mark = rta_getattr_u32(tb[FRA_FWMARK]);
125
126 if (tb[FRA_FWMASK] &&
127 (mask = rta_getattr_u32(tb[FRA_FWMASK])) != 0xFFFFFFFF)
128 fprintf(fp, "fwmark 0x%x/0x%x ", mark, mask);
129 else
130 fprintf(fp, "fwmark 0x%x ", mark);
131 }
132
133 if (tb[FRA_IFNAME]) {
134 fprintf(fp, "iif %s ", rta_getattr_str(tb[FRA_IFNAME]));
135 if (r->rtm_flags & FIB_RULE_IIF_DETACHED)
136 fprintf(fp, "[detached] ");
137 }
138
139 if (tb[FRA_OIFNAME]) {
140 fprintf(fp, "oif %s ", rta_getattr_str(tb[FRA_OIFNAME]));
141 if (r->rtm_flags & FIB_RULE_OIF_DETACHED)
142 fprintf(fp, "[detached] ");
143 }
144
145 if (tb[FRA_L3MDEV]) {
146 if (rta_getattr_u8(tb[FRA_L3MDEV]))
147 fprintf(fp, "lookup [l3mdev-table] ");
148 }
149
150 table = rtm_get_table(r, tb);
151 if (table) {
152 fprintf(fp, "lookup %s ",
153 rtnl_rttable_n2a(table, b1, sizeof(b1)));
154
155 if (tb[FRA_SUPPRESS_PREFIXLEN]) {
156 int pl = rta_getattr_u32(tb[FRA_SUPPRESS_PREFIXLEN]);
157
158 if (pl != -1)
159 fprintf(fp, "suppress_prefixlength %d ", pl);
160 }
161 if (tb[FRA_SUPPRESS_IFGROUP]) {
162 int group = rta_getattr_u32(tb[FRA_SUPPRESS_IFGROUP]);
163
164 if (group != -1) {
165 SPRINT_BUF(b1);
166 fprintf(fp, "suppress_ifgroup %s ",
167 rtnl_group_n2a(group, b1, sizeof(b1)));
168 }
169 }
170 }
171
172 if (tb[FRA_FLOW]) {
173 __u32 to = rta_getattr_u32(tb[FRA_FLOW]);
174 __u32 from = to>>16;
175
176 to &= 0xFFFF;
177 if (from) {
178 fprintf(fp, "realms %s/",
179 rtnl_rtrealm_n2a(from, b1, sizeof(b1)));
180 }
181 fprintf(fp, "%s ",
182 rtnl_rtrealm_n2a(to, b1, sizeof(b1)));
183 }
184
185 if (r->rtm_type == RTN_NAT) {
186 if (tb[RTA_GATEWAY]) {
187 fprintf(fp, "map-to %s ",
188 format_host_rta(r->rtm_family,
189 tb[RTA_GATEWAY]));
190 } else
191 fprintf(fp, "masquerade");
192 } else if (r->rtm_type == FR_ACT_GOTO) {
193 fprintf(fp, "goto ");
194 if (tb[FRA_GOTO])
195 fprintf(fp, "%u", rta_getattr_u32(tb[FRA_GOTO]));
196 else
197 fprintf(fp, "none");
198 if (r->rtm_flags & FIB_RULE_UNRESOLVED)
199 fprintf(fp, " [unresolved]");
200 } else if (r->rtm_type == FR_ACT_NOP)
201 fprintf(fp, "nop");
202 else if (r->rtm_type != RTN_UNICAST)
203 fprintf(fp, "%s",
204 rtnl_rtntype_n2a(r->rtm_type,
205 b1, sizeof(b1)));
206
207 fprintf(fp, "\n");
208 fflush(fp);
209 return 0;
210 }
211
212 static __u32 rule_dump_magic = 0x71706986;
213
214 static int save_rule_prep(void)
215 {
216 int ret;
217
218 if (isatty(STDOUT_FILENO)) {
219 fprintf(stderr, "Not sending a binary stream to stdout\n");
220 return -1;
221 }
222
223 ret = write(STDOUT_FILENO, &rule_dump_magic, sizeof(rule_dump_magic));
224 if (ret != sizeof(rule_dump_magic)) {
225 fprintf(stderr, "Can't write magic to dump file\n");
226 return -1;
227 }
228
229 return 0;
230 }
231
232 static int save_rule(const struct sockaddr_nl *who,
233 struct nlmsghdr *n, void *arg)
234 {
235 int ret;
236
237 ret = write(STDOUT_FILENO, n, n->nlmsg_len);
238 if ((ret > 0) && (ret != n->nlmsg_len)) {
239 fprintf(stderr, "Short write while saving nlmsg\n");
240 ret = -EIO;
241 }
242
243 return ret == n->nlmsg_len ? 0 : ret;
244 }
245
246 static int iprule_list_or_save(int argc, char **argv, int save)
247 {
248 rtnl_filter_t filter = print_rule;
249 int af = preferred_family;
250
251 if (af == AF_UNSPEC)
252 af = AF_INET;
253
254 if (argc > 0) {
255 fprintf(stderr, "\"ip rule %s\" does not take any arguments.\n",
256 save ? "save" : "show");
257 return -1;
258 }
259
260 if (save) {
261 if (save_rule_prep())
262 return -1;
263 filter = save_rule;
264 }
265
266 if (rtnl_wilddump_request(&rth, af, RTM_GETRULE) < 0) {
267 perror("Cannot send dump request");
268 return 1;
269 }
270
271 if (rtnl_dump_filter(&rth, filter, stdout) < 0) {
272 fprintf(stderr, "Dump terminated\n");
273 return 1;
274 }
275
276 return 0;
277 }
278
279 static int rule_dump_check_magic(void)
280 {
281 int ret;
282 __u32 magic = 0;
283
284 if (isatty(STDIN_FILENO)) {
285 fprintf(stderr, "Can't restore rule dump from a terminal\n");
286 return -1;
287 }
288
289 ret = fread(&magic, sizeof(magic), 1, stdin);
290 if (magic != rule_dump_magic) {
291 fprintf(stderr, "Magic mismatch (%d elems, %x magic)\n",
292 ret, magic);
293 return -1;
294 }
295
296 return 0;
297 }
298
299 static int restore_handler(const struct sockaddr_nl *nl,
300 struct rtnl_ctrl_data *ctrl,
301 struct nlmsghdr *n, void *arg)
302 {
303 int ret;
304
305 n->nlmsg_flags |= NLM_F_REQUEST | NLM_F_CREATE | NLM_F_ACK;
306
307 ll_init_map(&rth);
308
309 ret = rtnl_talk(&rth, n, n, sizeof(*n));
310 if ((ret < 0) && (errno == EEXIST))
311 ret = 0;
312
313 return ret;
314 }
315
316
317 static int iprule_restore(void)
318 {
319 if (rule_dump_check_magic())
320 exit(-1);
321
322 exit(rtnl_from_file(stdin, &restore_handler, NULL));
323 }
324
325 static int iprule_modify(int cmd, int argc, char **argv)
326 {
327 int l3mdev_rule = 0;
328 int table_ok = 0;
329 __u32 tid = 0;
330 struct {
331 struct nlmsghdr n;
332 struct rtmsg r;
333 char buf[1024];
334 } req;
335
336 memset(&req, 0, sizeof(req));
337
338 req.n.nlmsg_type = cmd;
339 req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct rtmsg));
340 req.n.nlmsg_flags = NLM_F_REQUEST;
341 req.r.rtm_family = preferred_family;
342 req.r.rtm_protocol = RTPROT_BOOT;
343 req.r.rtm_scope = RT_SCOPE_UNIVERSE;
344 req.r.rtm_table = 0;
345 req.r.rtm_type = RTN_UNSPEC;
346 req.r.rtm_flags = 0;
347
348 if (cmd == RTM_NEWRULE) {
349 req.n.nlmsg_flags |= NLM_F_CREATE|NLM_F_EXCL;
350 req.r.rtm_type = RTN_UNICAST;
351 }
352
353 while (argc > 0) {
354 if (strcmp(*argv, "not") == 0) {
355 req.r.rtm_flags |= FIB_RULE_INVERT;
356 } else if (strcmp(*argv, "from") == 0) {
357 inet_prefix dst;
358
359 NEXT_ARG();
360 get_prefix(&dst, *argv, req.r.rtm_family);
361 req.r.rtm_src_len = dst.bitlen;
362 addattr_l(&req.n, sizeof(req), FRA_SRC,
363 &dst.data, dst.bytelen);
364 } else if (strcmp(*argv, "to") == 0) {
365 inet_prefix dst;
366
367 NEXT_ARG();
368 get_prefix(&dst, *argv, req.r.rtm_family);
369 req.r.rtm_dst_len = dst.bitlen;
370 addattr_l(&req.n, sizeof(req), FRA_DST,
371 &dst.data, dst.bytelen);
372 } else if (matches(*argv, "preference") == 0 ||
373 matches(*argv, "order") == 0 ||
374 matches(*argv, "priority") == 0) {
375 __u32 pref;
376
377 NEXT_ARG();
378 if (get_u32(&pref, *argv, 0))
379 invarg("preference value is invalid\n", *argv);
380 addattr32(&req.n, sizeof(req), FRA_PRIORITY, pref);
381 } else if (strcmp(*argv, "tos") == 0 ||
382 matches(*argv, "dsfield") == 0) {
383 __u32 tos;
384
385 NEXT_ARG();
386 if (rtnl_dsfield_a2n(&tos, *argv))
387 invarg("TOS value is invalid\n", *argv);
388 req.r.rtm_tos = tos;
389 } else if (strcmp(*argv, "fwmark") == 0) {
390 char *slash;
391 __u32 fwmark, fwmask;
392
393 NEXT_ARG();
394
395 slash = strchr(*argv, '/');
396 if (slash != NULL)
397 *slash = '\0';
398 if (get_u32(&fwmark, *argv, 0))
399 invarg("fwmark value is invalid\n", *argv);
400 addattr32(&req.n, sizeof(req), FRA_FWMARK, fwmark);
401 if (slash) {
402 if (get_u32(&fwmask, slash+1, 0))
403 invarg("fwmask value is invalid\n",
404 slash+1);
405 addattr32(&req.n, sizeof(req),
406 FRA_FWMASK, fwmask);
407 }
408 } else if (matches(*argv, "realms") == 0) {
409 __u32 realm;
410
411 NEXT_ARG();
412 if (get_rt_realms_or_raw(&realm, *argv))
413 invarg("invalid realms\n", *argv);
414 addattr32(&req.n, sizeof(req), FRA_FLOW, realm);
415 } else if (matches(*argv, "table") == 0 ||
416 strcmp(*argv, "lookup") == 0) {
417 NEXT_ARG();
418 if (rtnl_rttable_a2n(&tid, *argv))
419 invarg("invalid table ID\n", *argv);
420 if (tid < 256)
421 req.r.rtm_table = tid;
422 else {
423 req.r.rtm_table = RT_TABLE_UNSPEC;
424 addattr32(&req.n, sizeof(req), FRA_TABLE, tid);
425 }
426 table_ok = 1;
427 } else if (matches(*argv, "suppress_prefixlength") == 0 ||
428 strcmp(*argv, "sup_pl") == 0) {
429 int pl;
430
431 NEXT_ARG();
432 if (get_s32(&pl, *argv, 0) || pl < 0)
433 invarg("suppress_prefixlength value is invalid\n",
434 *argv);
435 addattr32(&req.n, sizeof(req),
436 FRA_SUPPRESS_PREFIXLEN, pl);
437 } else if (matches(*argv, "suppress_ifgroup") == 0 ||
438 strcmp(*argv, "sup_group") == 0) {
439 NEXT_ARG();
440 int group;
441
442 if (rtnl_group_a2n(&group, *argv))
443 invarg("Invalid \"suppress_ifgroup\" value\n",
444 *argv);
445 addattr32(&req.n, sizeof(req),
446 FRA_SUPPRESS_IFGROUP, group);
447 } else if (strcmp(*argv, "dev") == 0 ||
448 strcmp(*argv, "iif") == 0) {
449 NEXT_ARG();
450 addattr_l(&req.n, sizeof(req), FRA_IFNAME,
451 *argv, strlen(*argv)+1);
452 } else if (strcmp(*argv, "oif") == 0) {
453 NEXT_ARG();
454 addattr_l(&req.n, sizeof(req), FRA_OIFNAME,
455 *argv, strlen(*argv)+1);
456 } else if (strcmp(*argv, "l3mdev") == 0) {
457 addattr8(&req.n, sizeof(req), FRA_L3MDEV, 1);
458 table_ok = 1;
459 l3mdev_rule = 1;
460 } else if (strcmp(*argv, "nat") == 0 ||
461 matches(*argv, "map-to") == 0) {
462 NEXT_ARG();
463 fprintf(stderr, "Warning: route NAT is deprecated\n");
464 addattr32(&req.n, sizeof(req), RTA_GATEWAY,
465 get_addr32(*argv));
466 req.r.rtm_type = RTN_NAT;
467 } else {
468 int type;
469
470 if (strcmp(*argv, "type") == 0)
471 NEXT_ARG();
472
473 if (matches(*argv, "help") == 0)
474 usage();
475 else if (matches(*argv, "goto") == 0) {
476 __u32 target;
477
478 type = FR_ACT_GOTO;
479 NEXT_ARG();
480 if (get_u32(&target, *argv, 0))
481 invarg("invalid target\n", *argv);
482 addattr32(&req.n, sizeof(req),
483 FRA_GOTO, target);
484 } else if (matches(*argv, "nop") == 0)
485 type = FR_ACT_NOP;
486 else if (rtnl_rtntype_a2n(&type, *argv))
487 invarg("Failed to parse rule type", *argv);
488 req.r.rtm_type = type;
489 table_ok = 1;
490 }
491 argc--;
492 argv++;
493 }
494
495 if (l3mdev_rule && tid != 0) {
496 fprintf(stderr,
497 "table can not be specified for l3mdev rules\n");
498 return -EINVAL;
499 }
500
501 if (req.r.rtm_family == AF_UNSPEC)
502 req.r.rtm_family = AF_INET;
503
504 if (!table_ok && cmd == RTM_NEWRULE)
505 req.r.rtm_table = RT_TABLE_MAIN;
506
507 if (rtnl_talk(&rth, &req.n, NULL, 0) < 0)
508 return -2;
509
510 return 0;
511 }
512
513
514 static int flush_rule(const struct sockaddr_nl *who, struct nlmsghdr *n,
515 void *arg)
516 {
517 struct rtnl_handle rth2;
518 struct rtmsg *r = NLMSG_DATA(n);
519 int len = n->nlmsg_len;
520 struct rtattr *tb[FRA_MAX+1];
521
522 len -= NLMSG_LENGTH(sizeof(*r));
523 if (len < 0)
524 return -1;
525
526 parse_rtattr(tb, FRA_MAX, RTM_RTA(r), len);
527
528 if (tb[FRA_PRIORITY]) {
529 n->nlmsg_type = RTM_DELRULE;
530 n->nlmsg_flags = NLM_F_REQUEST;
531
532 if (rtnl_open(&rth2, 0) < 0)
533 return -1;
534
535 if (rtnl_talk(&rth2, n, NULL, 0) < 0)
536 return -2;
537
538 rtnl_close(&rth2);
539 }
540
541 return 0;
542 }
543
544 static int iprule_flush(int argc, char **argv)
545 {
546 int af = preferred_family;
547
548 if (af == AF_UNSPEC)
549 af = AF_INET;
550
551 if (argc > 0) {
552 fprintf(stderr, "\"ip rule flush\" does not allow arguments\n");
553 return -1;
554 }
555
556 if (rtnl_wilddump_request(&rth, af, RTM_GETRULE) < 0) {
557 perror("Cannot send dump request");
558 return 1;
559 }
560
561 if (rtnl_dump_filter(&rth, flush_rule, NULL) < 0) {
562 fprintf(stderr, "Flush terminated\n");
563 return 1;
564 }
565
566 return 0;
567 }
568
569 int do_iprule(int argc, char **argv)
570 {
571 if (argc < 1) {
572 return iprule_list_or_save(0, NULL, 0);
573 } else if (matches(argv[0], "list") == 0 ||
574 matches(argv[0], "lst") == 0 ||
575 matches(argv[0], "show") == 0) {
576 return iprule_list_or_save(argc-1, argv+1, 0);
577 } else if (matches(argv[0], "save") == 0) {
578 return iprule_list_or_save(argc-1, argv+1, 1);
579 } else if (matches(argv[0], "restore") == 0) {
580 return iprule_restore();
581 } else if (matches(argv[0], "add") == 0) {
582 return iprule_modify(RTM_NEWRULE, argc-1, argv+1);
583 } else if (matches(argv[0], "delete") == 0) {
584 return iprule_modify(RTM_DELRULE, argc-1, argv+1);
585 } else if (matches(argv[0], "flush") == 0) {
586 return iprule_flush(argc-1, argv+1);
587 } else if (matches(argv[0], "help") == 0)
588 usage();
589
590 fprintf(stderr,
591 "Command \"%s\" is unknown, try \"ip rule help\".\n", *argv);
592 exit(-1);
593 }
594
595 int do_multirule(int argc, char **argv)
596 {
597 switch (preferred_family) {
598 case AF_UNSPEC:
599 case AF_INET:
600 preferred_family = RTNL_FAMILY_IPMR;
601 break;
602 case AF_INET6:
603 preferred_family = RTNL_FAMILY_IP6MR;
604 break;
605 case RTNL_FAMILY_IPMR:
606 case RTNL_FAMILY_IP6MR:
607 break;
608 default:
609 fprintf(stderr,
610 "Multicast rules are only supported for IPv4/IPv6, was: %i\n",
611 preferred_family);
612 exit(-1);
613 }
614
615 return do_iprule(argc, argv);
616 }