]>
git.proxmox.com Git - mirror_iproute2.git/blob - bridge/fdb.c
1 /* SPDX-License-Identifier: GPL-2.0 */
3 * Get/set/delete fdb table with netlink
5 * TODO: merge/replace this with ip neighbour
7 * Authors: Stephen Hemminger <shemminger@vyatta.com>
16 #include <sys/socket.h>
19 #include <netinet/in.h>
20 #include <linux/if_bridge.h>
21 #include <linux/if_ether.h>
22 #include <linux/neighbour.h>
25 #include <json_writer.h>
28 #include "libnetlink.h"
29 #include "br_common.h"
33 static unsigned int filter_index
, filter_vlan
, filter_state
;
35 json_writer_t
*jw_global
;
37 static void usage(void)
40 "Usage: bridge fdb { add | append | del | replace } ADDR dev DEV\n"
41 " [ self ] [ master ] [ use ] [ router ]\n"
42 " [ local | static | dynamic ] [ dst IPADDR ] [ vlan VID ]\n"
43 " [ port PORT] [ vni VNI ] [ via DEV ]\n"
44 " bridge fdb [ show [ br BRDEV ] [ brport DEV ] [ vlan VID ] [ state STATE ] ]\n");
48 static const char *state_n2a(unsigned int s
)
52 if (s
& NUD_PERMANENT
)
61 if (s
& NUD_REACHABLE
)
64 sprintf(buf
, "state=%#x", s
);
68 static int state_a2n(unsigned int *s
, const char *arg
)
70 if (matches(arg
, "permanent") == 0)
72 else if (matches(arg
, "static") == 0 || matches(arg
, "temp") == 0)
74 else if (matches(arg
, "stale") == 0)
76 else if (matches(arg
, "reachable") == 0 || matches(arg
, "dynamic") == 0)
78 else if (strcmp(arg
, "all") == 0)
80 else if (get_unsigned(s
, arg
, 0))
86 static void start_json_fdb_flags_array(bool *fdb_flags
)
90 jsonw_name(jw_global
, "flags");
91 jsonw_start_array(jw_global
);
95 int print_fdb(const struct sockaddr_nl
*who
, struct nlmsghdr
*n
, void *arg
)
98 struct ndmsg
*r
= NLMSG_DATA(n
);
99 int len
= n
->nlmsg_len
;
100 struct rtattr
*tb
[NDA_MAX
+1];
102 bool fdb_flags
= false;
105 if (n
->nlmsg_type
!= RTM_NEWNEIGH
&& n
->nlmsg_type
!= RTM_DELNEIGH
) {
106 fprintf(stderr
, "Not RTM_NEWNEIGH: %08x %08x %08x\n",
107 n
->nlmsg_len
, n
->nlmsg_type
, n
->nlmsg_flags
);
111 len
-= NLMSG_LENGTH(sizeof(*r
));
113 fprintf(stderr
, "BUG: wrong nlmsg len %d\n", len
);
117 if (r
->ndm_family
!= AF_BRIDGE
)
120 if (filter_index
&& filter_index
!= r
->ndm_ifindex
)
123 if (filter_state
&& !(r
->ndm_state
& filter_state
))
126 parse_rtattr(tb
, NDA_MAX
, NDA_RTA(r
),
127 n
->nlmsg_len
- NLMSG_LENGTH(sizeof(*r
)));
130 vid
= rta_getattr_u16(tb
[NDA_VLAN
]);
132 if (filter_vlan
&& filter_vlan
!= vid
)
136 jsonw_pretty(jw_global
, 1);
137 jsonw_start_object(jw_global
);
140 if (n
->nlmsg_type
== RTM_DELNEIGH
) {
142 jsonw_string_field(jw_global
, "opCode", "deleted");
144 fprintf(fp
, "Deleted ");
147 if (tb
[NDA_LLADDR
]) {
149 ll_addr_n2a(RTA_DATA(tb
[NDA_LLADDR
]),
150 RTA_PAYLOAD(tb
[NDA_LLADDR
]),
151 ll_index_to_type(r
->ndm_ifindex
),
154 jsonw_string_field(jw_global
, "mac", b1
);
156 fprintf(fp
, "%s ", b1
);
159 if (!filter_index
&& r
->ndm_ifindex
) {
161 jsonw_string_field(jw_global
, "dev",
162 ll_index_to_name(r
->ndm_ifindex
));
164 fprintf(fp
, "dev %s ",
165 ll_index_to_name(r
->ndm_ifindex
));
169 int family
= AF_INET
;
172 if (RTA_PAYLOAD(tb
[NDA_DST
]) == sizeof(struct in6_addr
))
175 abuf_s
= format_host(family
,
176 RTA_PAYLOAD(tb
[NDA_DST
]),
177 RTA_DATA(tb
[NDA_DST
]));
179 jsonw_string_field(jw_global
, "dst", abuf_s
);
181 fprintf(fp
, "dst %s ", abuf_s
);
186 jsonw_uint_field(jw_global
, "vlan", vid
);
188 fprintf(fp
, "vlan %hu ", vid
);
193 jsonw_uint_field(jw_global
, "port",
194 rta_getattr_be16(tb
[NDA_PORT
]));
196 fprintf(fp
, "port %d ",
197 rta_getattr_be16(tb
[NDA_PORT
]));
202 jsonw_uint_field(jw_global
, "vni",
203 rta_getattr_u32(tb
[NDA_VNI
]));
205 fprintf(fp
, "vni %d ",
206 rta_getattr_u32(tb
[NDA_VNI
]));
209 if (tb
[NDA_SRC_VNI
]) {
211 jsonw_uint_field(jw_global
, "src_vni",
212 rta_getattr_u32(tb
[NDA_SRC_VNI
]));
214 fprintf(fp
, "src_vni %d ",
215 rta_getattr_u32(tb
[NDA_SRC_VNI
]));
218 if (tb
[NDA_IFINDEX
]) {
219 unsigned int ifindex
= rta_getattr_u32(tb
[NDA_IFINDEX
]);
222 if (!tb
[NDA_LINK_NETNSID
]) {
223 const char *ifname
= ll_index_to_name(ifindex
);
226 jsonw_string_field(jw_global
, "viaIf",
229 fprintf(fp
, "via %s ", ifname
);
232 jsonw_uint_field(jw_global
, "viaIfIndex",
235 fprintf(fp
, "via ifindex %u ", ifindex
);
240 if (tb
[NDA_LINK_NETNSID
]) {
242 jsonw_uint_field(jw_global
, "linkNetNsId",
243 rta_getattr_u32(tb
[NDA_LINK_NETNSID
]));
245 fprintf(fp
, "link-netnsid %d ",
246 rta_getattr_u32(tb
[NDA_LINK_NETNSID
]));
249 if (show_stats
&& tb
[NDA_CACHEINFO
]) {
250 struct nda_cacheinfo
*ci
= RTA_DATA(tb
[NDA_CACHEINFO
]);
251 int hz
= get_user_hz();
254 jsonw_uint_field(jw_global
, "used",
256 jsonw_uint_field(jw_global
, "updated",
259 fprintf(fp
, "used %d/%d ", ci
->ndm_used
/hz
,
265 if (r
->ndm_flags
& NTF_SELF
) {
266 start_json_fdb_flags_array(&fdb_flags
);
267 jsonw_string(jw_global
, "self");
269 if (r
->ndm_flags
& NTF_ROUTER
) {
270 start_json_fdb_flags_array(&fdb_flags
);
271 jsonw_string(jw_global
, "router");
273 if (r
->ndm_flags
& NTF_EXT_LEARNED
) {
274 start_json_fdb_flags_array(&fdb_flags
);
275 jsonw_string(jw_global
, "extern_learn");
277 if (r
->ndm_flags
& NTF_OFFLOADED
) {
278 start_json_fdb_flags_array(&fdb_flags
);
279 jsonw_string(jw_global
, "offload");
281 if (r
->ndm_flags
& NTF_MASTER
)
282 jsonw_string(jw_global
, "master");
284 jsonw_end_array(jw_global
);
287 jsonw_string_field(jw_global
,
289 ll_index_to_name(rta_getattr_u32(tb
[NDA_MASTER
])));
292 if (r
->ndm_flags
& NTF_SELF
)
293 fprintf(fp
, "self ");
294 if (r
->ndm_flags
& NTF_ROUTER
)
295 fprintf(fp
, "router ");
296 if (r
->ndm_flags
& NTF_EXT_LEARNED
)
297 fprintf(fp
, "extern_learn ");
298 if (r
->ndm_flags
& NTF_OFFLOADED
)
299 fprintf(fp
, "offload ");
300 if (tb
[NDA_MASTER
]) {
301 fprintf(fp
, "master %s ",
302 ll_index_to_name(rta_getattr_u32(tb
[NDA_MASTER
])));
303 } else if (r
->ndm_flags
& NTF_MASTER
) {
304 fprintf(fp
, "master ");
308 state_s
= state_n2a(r
->ndm_state
);
311 jsonw_string_field(jw_global
, "state", state_s
);
313 jsonw_end_object(jw_global
);
315 fprintf(fp
, "%s\n", state_s
);
323 static int fdb_show(int argc
, char **argv
)
327 struct ifinfomsg ifm
;
330 .n
.nlmsg_len
= NLMSG_LENGTH(sizeof(struct ifinfomsg
)),
331 .ifm
.ifi_family
= PF_BRIDGE
,
334 char *filter_dev
= NULL
;
336 int msg_size
= sizeof(struct ifinfomsg
);
339 if ((strcmp(*argv
, "brport") == 0) || strcmp(*argv
, "dev") == 0) {
342 } else if (strcmp(*argv
, "br") == 0) {
345 } else if (strcmp(*argv
, "vlan") == 0) {
348 duparg("vlan", *argv
);
349 filter_vlan
= atoi(*argv
);
350 } else if (strcmp(*argv
, "state") == 0) {
354 if (state_a2n(&state
, *argv
))
355 invarg("invalid state", *argv
);
356 filter_state
|= state
;
358 if (matches(*argv
, "help") == 0)
365 int br_ifindex
= ll_name_to_index(br
);
367 if (br_ifindex
== 0) {
368 fprintf(stderr
, "Cannot find bridge device \"%s\"\n", br
);
371 addattr32(&req
.n
, sizeof(req
), IFLA_MASTER
, br_ifindex
);
372 msg_size
+= RTA_LENGTH(4);
375 /*we'll keep around filter_dev for older kernels */
377 filter_index
= ll_name_to_index(filter_dev
);
378 if (filter_index
== 0) {
379 fprintf(stderr
, "Cannot find device \"%s\"\n",
383 req
.ifm
.ifi_index
= filter_index
;
386 if (rtnl_dump_request(&rth
, RTM_GETNEIGH
, &req
.ifm
, msg_size
) < 0) {
387 perror("Cannot send dump request");
392 jw_global
= jsonw_new(stdout
);
394 fprintf(stderr
, "Error allocation json object\n");
397 jsonw_start_array(jw_global
);
399 if (rtnl_dump_filter(&rth
, print_fdb
, stdout
) < 0) {
400 fprintf(stderr
, "Dump terminated\n");
404 jsonw_end_array(jw_global
);
405 jsonw_destroy(&jw_global
);
411 static int fdb_modify(int cmd
, int flags
, int argc
, char **argv
)
418 .n
.nlmsg_len
= NLMSG_LENGTH(sizeof(struct ndmsg
)),
419 .n
.nlmsg_flags
= NLM_F_REQUEST
| flags
,
421 .ndm
.ndm_family
= PF_BRIDGE
,
422 .ndm
.ndm_state
= NUD_NOARP
,
429 unsigned long port
= 0;
430 unsigned long vni
= ~0;
431 unsigned int via
= 0;
436 if (strcmp(*argv
, "dev") == 0) {
439 } else if (strcmp(*argv
, "dst") == 0) {
442 duparg2("dst", *argv
);
443 get_addr(&dst
, *argv
, preferred_family
);
445 } else if (strcmp(*argv
, "port") == 0) {
448 port
= strtoul(*argv
, &endptr
, 0);
449 if (endptr
&& *endptr
) {
452 pse
= getservbyname(*argv
, "udp");
454 invarg("invalid port\n", *argv
);
455 port
= ntohs(pse
->s_port
);
456 } else if (port
> 0xffff)
457 invarg("invalid port\n", *argv
);
458 } else if (strcmp(*argv
, "vni") == 0) {
460 vni
= strtoul(*argv
, &endptr
, 0);
461 if ((endptr
&& *endptr
) ||
462 (vni
>> 24) || vni
== ULONG_MAX
)
463 invarg("invalid VNI\n", *argv
);
464 } else if (strcmp(*argv
, "via") == 0) {
466 via
= ll_name_to_index(*argv
);
468 invarg("invalid device\n", *argv
);
469 } else if (strcmp(*argv
, "self") == 0) {
470 req
.ndm
.ndm_flags
|= NTF_SELF
;
471 } else if (matches(*argv
, "master") == 0) {
472 req
.ndm
.ndm_flags
|= NTF_MASTER
;
473 } else if (matches(*argv
, "router") == 0) {
474 req
.ndm
.ndm_flags
|= NTF_ROUTER
;
475 } else if (matches(*argv
, "local") == 0 ||
476 matches(*argv
, "permanent") == 0) {
477 req
.ndm
.ndm_state
|= NUD_PERMANENT
;
478 } else if (matches(*argv
, "temp") == 0 ||
479 matches(*argv
, "static") == 0) {
480 req
.ndm
.ndm_state
|= NUD_REACHABLE
;
481 } else if (matches(*argv
, "dynamic") == 0) {
482 req
.ndm
.ndm_state
|= NUD_REACHABLE
;
483 req
.ndm
.ndm_state
&= ~NUD_NOARP
;
484 } else if (matches(*argv
, "vlan") == 0) {
486 duparg2("vlan", *argv
);
489 } else if (matches(*argv
, "use") == 0) {
490 req
.ndm
.ndm_flags
|= NTF_USE
;
492 if (strcmp(*argv
, "to") == 0)
495 if (matches(*argv
, "help") == 0)
498 duparg2("to", *argv
);
504 if (d
== NULL
|| addr
== NULL
) {
505 fprintf(stderr
, "Device and address are required arguments.\n");
510 if (!(req
.ndm
.ndm_flags
&(NTF_SELF
|NTF_MASTER
)))
511 req
.ndm
.ndm_flags
|= NTF_SELF
;
513 /* Assume permanent */
514 if (!(req
.ndm
.ndm_state
&(NUD_PERMANENT
|NUD_REACHABLE
)))
515 req
.ndm
.ndm_state
|= NUD_PERMANENT
;
517 if (sscanf(addr
, "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx",
518 abuf
, abuf
+1, abuf
+2,
519 abuf
+3, abuf
+4, abuf
+5) != 6) {
520 fprintf(stderr
, "Invalid mac address %s\n", addr
);
524 addattr_l(&req
.n
, sizeof(req
), NDA_LLADDR
, abuf
, ETH_ALEN
);
526 addattr_l(&req
.n
, sizeof(req
), NDA_DST
, &dst
.data
, dst
.bytelen
);
529 addattr16(&req
.n
, sizeof(req
), NDA_VLAN
, vid
);
532 unsigned short dport
;
534 dport
= htons((unsigned short)port
);
535 addattr16(&req
.n
, sizeof(req
), NDA_PORT
, dport
);
538 addattr32(&req
.n
, sizeof(req
), NDA_VNI
, vni
);
540 addattr32(&req
.n
, sizeof(req
), NDA_IFINDEX
, via
);
542 req
.ndm
.ndm_ifindex
= ll_name_to_index(d
);
543 if (req
.ndm
.ndm_ifindex
== 0) {
544 fprintf(stderr
, "Cannot find device \"%s\"\n", d
);
548 if (rtnl_talk(&rth
, &req
.n
, NULL
) < 0)
554 int do_fdb(int argc
, char **argv
)
559 if (matches(*argv
, "add") == 0)
560 return fdb_modify(RTM_NEWNEIGH
, NLM_F_CREATE
|NLM_F_EXCL
, argc
-1, argv
+1);
561 if (matches(*argv
, "append") == 0)
562 return fdb_modify(RTM_NEWNEIGH
, NLM_F_CREATE
|NLM_F_APPEND
, argc
-1, argv
+1);
563 if (matches(*argv
, "replace") == 0)
564 return fdb_modify(RTM_NEWNEIGH
, NLM_F_CREATE
|NLM_F_REPLACE
, argc
-1, argv
+1);
565 if (matches(*argv
, "delete") == 0)
566 return fdb_modify(RTM_DELNEIGH
, 0, argc
-1, argv
+1);
567 if (matches(*argv
, "show") == 0 ||
568 matches(*argv
, "lst") == 0 ||
569 matches(*argv
, "list") == 0)
570 return fdb_show(argc
-1, argv
+1);
571 if (matches(*argv
, "help") == 0)
574 return fdb_show(0, NULL
);
576 fprintf(stderr
, "Command \"%s\" is unknown, try \"bridge fdb help\".\n", *argv
);