]> git.proxmox.com Git - mirror_iproute2.git/blame - bridge/fdb.c
fix print_ipt: segfault if more then one filter with action -j MARK.
[mirror_iproute2.git] / bridge / fdb.c
CommitLineData
d04bc300
SH
1/*
2 * Get/set/delete fdb table with netlink
3 *
0849e60a
SH
4 * TODO: merge/replace this with ip neighbour
5 *
d04bc300
SH
6 * Authors: Stephen Hemminger <shemminger@vyatta.com>
7 */
8
9#include <stdio.h>
10#include <stdlib.h>
11#include <unistd.h>
5f409678 12#include <netdb.h>
d04bc300
SH
13#include <time.h>
14#include <fcntl.h>
15#include <sys/socket.h>
16#include <sys/time.h>
17#include <net/if.h>
18#include <netinet/in.h>
19#include <linux/if_bridge.h>
20#include <linux/if_ether.h>
21#include <linux/neighbour.h>
22#include <string.h>
23
24#include "libnetlink.h"
25#include "br_common.h"
0849e60a 26#include "rt_names.h"
d04bc300
SH
27#include "utils.h"
28
29int filter_index;
30
31static void usage(void)
32{
5464049b 33 fprintf(stderr, "Usage: bridge fdb { add | append | del | replace } ADDR dev DEV {self|master} [ temp ]\n"
7578ae88 34 " [router] [ dst IPADDR] [ vlan VID ]\n"
5f409678 35 " [ port PORT] [ vni VNI ] [via DEV]\n");
90698170 36 fprintf(stderr, " bridge fdb {show} [ dev DEV ]\n");
d04bc300
SH
37 exit(-1);
38}
39
40static const char *state_n2a(unsigned s)
41{
42 static char buf[32];
43
0849e60a
SH
44 if (s & NUD_PERMANENT)
45 return "permanent";
d04bc300
SH
46
47 if (s & NUD_NOARP)
48 return "static";
49
50 if (s & NUD_STALE)
51 return "stale";
0849e60a 52
d04bc300
SH
53 if (s & NUD_REACHABLE)
54 return "";
55
56 sprintf(buf, "state=%#x", s);
57 return buf;
58}
59
d04bc300
SH
60int print_fdb(const struct sockaddr_nl *who, struct nlmsghdr *n, void *arg)
61{
0849e60a 62 FILE *fp = arg;
d04bc300
SH
63 struct ndmsg *r = NLMSG_DATA(n);
64 int len = n->nlmsg_len;
65 struct rtattr * tb[NDA_MAX+1];
0849e60a
SH
66
67 if (n->nlmsg_type != RTM_NEWNEIGH && n->nlmsg_type != RTM_DELNEIGH) {
68 fprintf(stderr, "Not RTM_NEWNEIGH: %08x %08x %08x\n",
69 n->nlmsg_len, n->nlmsg_type, n->nlmsg_flags);
70
71 return 0;
72 }
d04bc300
SH
73
74 len -= NLMSG_LENGTH(sizeof(*r));
75 if (len < 0) {
76 fprintf(stderr, "BUG: wrong nlmsg len %d\n", len);
77 return -1;
78 }
79
80 if (r->ndm_family != AF_BRIDGE)
81 return 0;
82
83 if (filter_index && filter_index != r->ndm_ifindex)
84 return 0;
85
86 parse_rtattr(tb, NDA_MAX, NDA_RTA(r),
87 n->nlmsg_len - NLMSG_LENGTH(sizeof(*r)));
88
89 if (n->nlmsg_type == RTM_DELNEIGH)
0849e60a
SH
90 fprintf(fp, "Deleted ");
91
92 if (tb[NDA_LLADDR]) {
93 SPRINT_BUF(b1);
94 fprintf(fp, "%s ",
95 ll_addr_n2a(RTA_DATA(tb[NDA_LLADDR]),
96 RTA_PAYLOAD(tb[NDA_LLADDR]),
97 ll_index_to_type(r->ndm_ifindex),
98 b1, sizeof(b1)));
d04bc300 99 }
38df7ac9 100
0849e60a
SH
101 if (!filter_index && r->ndm_ifindex)
102 fprintf(fp, "dev %s ", ll_index_to_name(r->ndm_ifindex));
103
104 if (tb[NDA_DST]) {
105 SPRINT_BUF(abuf);
9e763fa5
MR
106 int family = AF_INET;
107
108 if (RTA_PAYLOAD(tb[NDA_DST]) == sizeof(struct in6_addr))
109 family = AF_INET6;
110
0849e60a 111 fprintf(fp, "dst %s ",
9e763fa5 112 format_host(family,
0849e60a
SH
113 RTA_PAYLOAD(tb[NDA_DST]),
114 RTA_DATA(tb[NDA_DST]),
115 abuf, sizeof(abuf)));
116 }
38df7ac9 117
fd08839c
VY
118 if (tb[NDA_VLAN]) {
119 __u16 vid = rta_getattr_u16(tb[NDA_VLAN]);
120 fprintf(fp, "vlan %hu ", vid);
121 }
122
5f409678
DS
123 if (tb[NDA_PORT])
124 fprintf(fp, "port %d ", ntohs(rta_getattr_u16(tb[NDA_PORT])));
125 if (tb[NDA_VNI])
126 fprintf(fp, "vni %d ", rta_getattr_u32(tb[NDA_VNI]));
127 if (tb[NDA_IFINDEX]) {
128 unsigned int ifindex = rta_getattr_u32(tb[NDA_IFINDEX]);
129
130 if (ifindex) {
131 char ifname[IF_NAMESIZE];
132
133 if (if_indextoname(ifindex, ifname))
134 fprintf(fp, "via %s ", ifname);
135 else
136 fprintf(fp, "via ifindex %u ", ifindex);
137 }
138 }
139
d04bc300
SH
140 if (show_stats && tb[NDA_CACHEINFO]) {
141 struct nda_cacheinfo *ci = RTA_DATA(tb[NDA_CACHEINFO]);
0849e60a 142 int hz = get_user_hz();
d04bc300 143
0849e60a
SH
144 fprintf(fp, " used %d/%d", ci->ndm_used/hz,
145 ci->ndm_updated/hz);
d04bc300 146 }
0849e60a
SH
147 if (r->ndm_flags & NTF_SELF)
148 fprintf(fp, "self ");
149 if (r->ndm_flags & NTF_MASTER)
150 fprintf(fp, "master ");
5b8a1d4a
DS
151 if (r->ndm_flags & NTF_ROUTER)
152 fprintf(fp, "router ");
d04bc300 153
0849e60a 154 fprintf(fp, "%s\n", state_n2a(r->ndm_state));
d04bc300
SH
155 return 0;
156}
157
158static int fdb_show(int argc, char **argv)
159{
160 char *filter_dev = NULL;
0849e60a 161
d04bc300
SH
162 while (argc > 0) {
163 if (strcmp(*argv, "dev") == 0) {
164 NEXT_ARG();
165 if (filter_dev)
166 duparg("dev", *argv);
167 filter_dev = *argv;
168 }
169 argc--; argv++;
170 }
171
172 if (filter_dev) {
0849e60a
SH
173 filter_index = if_nametoindex(filter_dev);
174 if (filter_index == 0) {
175 fprintf(stderr, "Cannot find device \"%s\"\n",
176 filter_dev);
d04bc300
SH
177 return -1;
178 }
179 }
180
181 if (rtnl_wilddump_request(&rth, PF_BRIDGE, RTM_GETNEIGH) < 0) {
182 perror("Cannot send dump request");
183 exit(1);
184 }
d04bc300 185
0849e60a 186 if (rtnl_dump_filter(&rth, print_fdb, stdout) < 0) {
d04bc300
SH
187 fprintf(stderr, "Dump terminated\n");
188 exit(1);
189 }
190
191 return 0;
192}
193
194static int fdb_modify(int cmd, int flags, int argc, char **argv)
195{
196 struct {
197 struct nlmsghdr n;
198 struct ndmsg ndm;
199 char buf[256];
200 } req;
201 char *addr = NULL;
202 char *d = NULL;
203 char abuf[ETH_ALEN];
0849e60a
SH
204 int dst_ok = 0;
205 inet_prefix dst;
5f409678
DS
206 unsigned long port = 0;
207 unsigned long vni = ~0;
208 unsigned int via = 0;
209 char *endptr;
fd08839c 210 short vid = -1;
d04bc300
SH
211
212 memset(&req, 0, sizeof(req));
213
214 req.n.nlmsg_len = NLMSG_LENGTH(sizeof(struct ndmsg));
215 req.n.nlmsg_flags = NLM_F_REQUEST|flags;
216 req.n.nlmsg_type = cmd;
217 req.ndm.ndm_family = PF_BRIDGE;
218 req.ndm.ndm_state = NUD_NOARP;
219
220 while (argc > 0) {
221 if (strcmp(*argv, "dev") == 0) {
222 NEXT_ARG();
223 d = *argv;
0849e60a
SH
224 } else if (strcmp(*argv, "dst") == 0) {
225 NEXT_ARG();
226 if (dst_ok)
227 duparg2("dst", *argv);
228 get_addr(&dst, *argv, preferred_family);
229 dst_ok = 1;
5f409678
DS
230 } else if (strcmp(*argv, "port") == 0) {
231
232 NEXT_ARG();
233 port = strtoul(*argv, &endptr, 0);
234 if (endptr && *endptr) {
235 struct servent *pse;
236
237 pse = getservbyname(*argv, "udp");
238 if (!pse)
239 invarg("invalid port\n", *argv);
240 port = ntohs(pse->s_port);
241 } else if (port > 0xffff)
242 invarg("invalid port\n", *argv);
243 } else if (strcmp(*argv, "vni") == 0) {
244 NEXT_ARG();
245 vni = strtoul(*argv, &endptr, 0);
246 if ((endptr && *endptr) ||
247 (vni >> 24) || vni == ULONG_MAX)
248 invarg("invalid VNI\n", *argv);
249 } else if (strcmp(*argv, "via") == 0) {
250 NEXT_ARG();
251 via = if_nametoindex(*argv);
252 if (via == 0)
253 invarg("invalid device\n", *argv);
dc6a6a25
JF
254 } else if (strcmp(*argv, "self") == 0) {
255 req.ndm.ndm_flags |= NTF_SELF;
0849e60a 256 } else if (matches(*argv, "master") == 0) {
dc6a6a25 257 req.ndm.ndm_flags |= NTF_MASTER;
5b8a1d4a
DS
258 } else if (matches(*argv, "router") == 0) {
259 req.ndm.ndm_flags |= NTF_ROUTER;
38df7ac9 260 } else if (matches(*argv, "local") == 0||
0849e60a
SH
261 matches(*argv, "permanent") == 0) {
262 req.ndm.ndm_state |= NUD_PERMANENT;
263 } else if (matches(*argv, "temp") == 0) {
264 req.ndm.ndm_state |= NUD_REACHABLE;
fd08839c
VY
265 } else if (matches(*argv, "vlan") == 0) {
266 if (vid >= 0)
267 duparg2("vlan", *argv);
268 NEXT_ARG();
269 vid = atoi(*argv);
d04bc300
SH
270 } else {
271 if (strcmp(*argv, "to") == 0) {
272 NEXT_ARG();
273 }
0849e60a
SH
274 if (matches(*argv, "help") == 0)
275 usage();
d04bc300
SH
276 if (addr)
277 duparg2("to", *argv);
278 addr = *argv;
279 }
280 argc--; argv++;
281 }
282
283 if (d == NULL || addr == NULL) {
284 fprintf(stderr, "Device and address are required arguments.\n");
285 exit(-1);
286 }
287
0849e60a
SH
288 /* Assume self */
289 if (!(req.ndm.ndm_flags&(NTF_SELF|NTF_MASTER)))
290 req.ndm.ndm_flags |= NTF_SELF;
291
292 /* Assume permanent */
293 if (!(req.ndm.ndm_state&(NUD_PERMANENT|NUD_REACHABLE)))
294 req.ndm.ndm_state |= NUD_PERMANENT;
295
296 if (sscanf(addr, "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx",
d04bc300
SH
297 abuf, abuf+1, abuf+2,
298 abuf+3, abuf+4, abuf+5) != 6) {
299 fprintf(stderr, "Invalid mac address %s\n", addr);
300 exit(-1);
301 }
302
303 addattr_l(&req.n, sizeof(req), NDA_LLADDR, abuf, ETH_ALEN);
0849e60a
SH
304 if (dst_ok)
305 addattr_l(&req.n, sizeof(req), NDA_DST, &dst.data, dst.bytelen);
d04bc300 306
fd08839c 307 if (vid >= 0)
8ae66094 308 addattr16(&req.n, sizeof(req), NDA_VLAN, vid);
fd08839c 309
5f409678
DS
310 if (port) {
311 unsigned short dport;
312
313 dport = htons((unsigned short)port);
314 addattr16(&req.n, sizeof(req), NDA_PORT, dport);
315 }
316 if (vni != ~0)
317 addattr32(&req.n, sizeof(req), NDA_VNI, vni);
318 if (via)
319 addattr32(&req.n, sizeof(req), NDA_IFINDEX, via);
320
d04bc300
SH
321 req.ndm.ndm_ifindex = ll_name_to_index(d);
322 if (req.ndm.ndm_ifindex == 0) {
323 fprintf(stderr, "Cannot find device \"%s\"\n", d);
324 return -1;
325 }
326
327 if (rtnl_talk(&rth, &req.n, 0, 0, NULL) < 0)
328 exit(2);
329
330 return 0;
331}
332
333int do_fdb(int argc, char **argv)
334{
335 ll_init_map(&rth);
336
337 if (argc > 0) {
338 if (matches(*argv, "add") == 0)
339 return fdb_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_EXCL, argc-1, argv+1);
5f409678
DS
340 if (matches(*argv, "append") == 0)
341 return fdb_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_APPEND, argc-1, argv+1);
5464049b
TR
342 if (matches(*argv, "replace") == 0)
343 return fdb_modify(RTM_NEWNEIGH, NLM_F_CREATE|NLM_F_REPLACE, argc-1, argv+1);
d04bc300
SH
344 if (matches(*argv, "delete") == 0)
345 return fdb_modify(RTM_DELNEIGH, 0, argc-1, argv+1);
346 if (matches(*argv, "show") == 0 ||
347 matches(*argv, "lst") == 0 ||
348 matches(*argv, "list") == 0)
349 return fdb_show(argc-1, argv+1);
350 if (matches(*argv, "help") == 0)
351 usage();
352 } else
353 return fdb_show(0, NULL);
354
083b46bb 355 fprintf(stderr, "Command \"%s\" is unknown, try \"bridge fdb help\".\n", *argv);
d04bc300
SH
356 exit(-1);
357}