2 * Kernel routing table updates by routing socket.
3 * Copyright (C) 1997, 98 Kunihiro Ishiguro
5 * This file is part of GNU Zebra.
7 * GNU Zebra is free software; you can redistribute it and/or modify it
8 * under the terms of the GNU General Public License as published by the
9 * Free Software Foundation; either version 2, or (at your option) any
12 * GNU Zebra is distributed in the hope that it will be useful, but
13 * WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * General Public License for more details.
17 * You should have received a copy of the GNU General Public License along
18 * with this program; see the file COPYING; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
27 #include <netmpls/mpls.h>
32 #include "sockunion.h"
36 #include "lib_errors.h"
38 #include "zebra/debug.h"
39 #include "zebra/rib.h"
41 #include "zebra/kernel_socket.h"
42 #include "zebra/zebra_mpls.h"
43 #include "zebra/zebra_errors.h"
45 extern struct zebra_privs_t zserv_privs
;
48 static int kernel_rtm_add_labels(struct mpls_label_stack
*nh_label
,
49 struct sockaddr_mpls
*smpls
)
51 if (nh_label
->num_labels
> 1) {
52 flog_warn(EC_ZEBRA_MAX_LABELS_PUSH
,
53 "%s: can't push %u labels at once (maximum is 1)",
54 __func__
, nh_label
->num_labels
);
58 memset(smpls
, 0, sizeof(*smpls
));
59 smpls
->smpls_len
= sizeof(*smpls
);
60 smpls
->smpls_family
= AF_MPLS
;
61 smpls
->smpls_label
= htonl(nh_label
->label
[0] << MPLS_LABEL_OFFSET
);
67 /* Interface between zebra message and rtm message. */
68 static int kernel_rtm(int cmd
, const struct prefix
*p
,
69 const struct nexthop_group
*ng
, uint32_t metric
)
72 union sockunion sin_dest
, sin_mask
, sin_gate
;
74 struct sockaddr_mpls smpls
;
76 union sockunion
*smplsp
= NULL
;
77 struct nexthop
*nexthop
;
79 ifindex_t ifindex
= 0;
82 char gate_buf
[INET6_BUFSIZ
];
83 enum blackhole_type bh_type
= BLACKHOLE_UNSPEC
;
86 * We only have the ability to ADD or DELETE at this point
89 if (cmd
!= RTM_ADD
&& cmd
!= RTM_DELETE
) {
90 if (IS_ZEBRA_DEBUG_KERNEL
)
91 zlog_debug("%s: %pFX odd command %s", __func__
, p
,
92 lookup_msg(rtm_type_str
, cmd
, NULL
));
96 memset(&sin_dest
, 0, sizeof(sin_dest
));
97 memset(&sin_gate
, 0, sizeof(sin_gate
));
98 memset(&sin_mask
, 0, sizeof(sin_mask
));
102 sin_dest
.sin
.sin_family
= AF_INET
;
103 sin_dest
.sin
.sin_addr
= p
->u
.prefix4
;
104 sin_gate
.sin
.sin_family
= AF_INET
;
105 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
106 sin_dest
.sin
.sin_len
= sizeof(struct sockaddr_in
);
107 sin_gate
.sin
.sin_len
= sizeof(struct sockaddr_in
);
108 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
111 sin_dest
.sin6
.sin6_family
= AF_INET6
;
112 sin_dest
.sin6
.sin6_addr
= p
->u
.prefix6
;
113 sin_gate
.sin6
.sin6_family
= AF_INET6
;
114 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
115 sin_dest
.sin6
.sin6_len
= sizeof(struct sockaddr_in6
);
116 sin_gate
.sin6
.sin6_len
= sizeof(struct sockaddr_in6
);
117 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
122 for (ALL_NEXTHOPS_PTR(ng
, nexthop
)) {
124 * We only want to use the actual good nexthops
126 if (CHECK_FLAG(nexthop
->flags
, NEXTHOP_FLAG_RECURSIVE
) ||
127 !CHECK_FLAG(nexthop
->flags
, NEXTHOP_FLAG_ACTIVE
))
132 snprintf(gate_buf
, sizeof(gate_buf
), "NULL");
134 switch (nexthop
->type
) {
135 case NEXTHOP_TYPE_IPV4
:
136 case NEXTHOP_TYPE_IPV4_IFINDEX
:
137 sin_gate
.sin
.sin_addr
= nexthop
->gate
.ipv4
;
138 sin_gate
.sin
.sin_family
= AF_INET
;
139 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
140 sin_gate
.sin
.sin_len
= sizeof(struct sockaddr_in
);
141 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
142 ifindex
= nexthop
->ifindex
;
145 case NEXTHOP_TYPE_IPV6
:
146 case NEXTHOP_TYPE_IPV6_IFINDEX
:
147 sin_gate
.sin6
.sin6_addr
= nexthop
->gate
.ipv6
;
148 sin_gate
.sin6
.sin6_family
= AF_INET6
;
149 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
150 sin_gate
.sin6
.sin6_len
= sizeof(struct sockaddr_in6
);
151 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
152 ifindex
= nexthop
->ifindex
;
153 /* Under kame set interface index to link local address */
156 #define SET_IN6_LINKLOCAL_IFINDEX(a, i) \
158 (a).s6_addr[2] = ((i) >> 8) & 0xff; \
159 (a).s6_addr[3] = (i)&0xff; \
162 if (IN6_IS_ADDR_LINKLOCAL(&sin_gate
.sin6
.sin6_addr
))
163 SET_IN6_LINKLOCAL_IFINDEX(
164 sin_gate
.sin6
.sin6_addr
,
170 case NEXTHOP_TYPE_IFINDEX
:
171 ifindex
= nexthop
->ifindex
;
173 case NEXTHOP_TYPE_BLACKHOLE
:
174 bh_type
= nexthop
->bh_type
;
177 struct in_addr loopback
;
179 loopback
.s_addr
= htonl(INADDR_LOOPBACK
);
180 sin_gate
.sin
.sin_addr
= loopback
;
181 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
182 sin_gate
.sin
.sin_len
=
183 sizeof(struct sockaddr_in
);
184 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
188 struct in6_addr loopback
;
190 inet_pton(AF_INET6
, "::1", &loopback
);
192 sin_gate
.sin6
.sin6_addr
= loopback
;
193 sin_gate
.sin6
.sin6_family
= AF_INET6
;
195 #ifdef HAVE_STRUCTSOCKADDR_SA_LEN
196 sin_gate
.sin6
.sin6_len
=
197 sizeof(struct sockaddr_in6
);
198 #endif /* HAVE_STRUCTSOCKADDR_SA_LEN */
206 masklen2ip(p
->prefixlen
, &sin_mask
.sin
.sin_addr
);
207 sin_mask
.sin
.sin_family
= AF_INET
;
208 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
209 sin_mask
.sin
.sin_len
= sizeof(struct sockaddr_in
);
210 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
213 masklen2ip6(p
->prefixlen
, &sin_mask
.sin6
.sin6_addr
);
214 sin_mask
.sin6
.sin6_family
= AF_INET6
;
215 #ifdef HAVE_STRUCT_SOCKADDR_SA_LEN
216 sin_mask
.sin6
.sin6_len
= sizeof(struct sockaddr_in6
);
217 #endif /* HAVE_STRUCT_SOCKADDR_SA_LEN */
222 if (nexthop
->nh_label
) {
223 if (kernel_rtm_add_labels(nexthop
->nh_label
,
226 smplsp
= (union sockunion
*)&smpls
;
229 error
= rtm_write(cmd
, &sin_dest
, &sin_mask
,
230 gate
? &sin_gate
: NULL
, smplsp
,
231 ifindex
, bh_type
, metric
);
233 if (IS_ZEBRA_DEBUG_KERNEL
) {
236 "%s: %pFX: attention! gate not found for re",
242 &sin_gate
.sin
.sin_addr
,
243 gate_buf
, sizeof(gate_buf
));
248 &sin_gate
.sin6
.sin6_addr
,
249 gate_buf
, sizeof(gate_buf
));
253 snprintf(gate_buf
, sizeof(gate_buf
),
260 /* We only flag nexthops as being in FIB if
261 * rtm_write() did its work. */
262 case ZEBRA_ERR_NOERROR
:
264 if (IS_ZEBRA_DEBUG_KERNEL
)
265 zlog_debug("%s: %pFX: successfully did NH %s",
266 __func__
, p
, gate_buf
);
268 SET_FLAG(nexthop
->flags
, NEXTHOP_FLAG_FIB
);
271 /* The only valid case for this error is
272 * kernel's failure to install a multipath
273 * route, which is common for FreeBSD. This
274 * should be ignored silently, but logged as an error
277 case ZEBRA_ERR_RTEXIST
:
279 flog_err(EC_LIB_SYSTEM_CALL
,
280 "%s: rtm_write() returned %d for command %d",
281 __func__
, error
, cmd
);
284 /* Note any unexpected status returns */
285 case ZEBRA_ERR_RTNOEXIST
:
286 if (cmd
!= RTM_DELETE
)
287 flog_err(EC_LIB_SYSTEM_CALL
,
288 "%s: rtm_write() returned %d for command %d",
289 __func__
, error
, cmd
);
294 "%s: %pFX: rtm_write() unexpectedly returned %d for command %s",
296 lookup_msg(rtm_type_str
, cmd
, NULL
));
299 } /* for (ALL_NEXTHOPS(...))*/
301 /* If there was no useful nexthop, then complain. */
302 if (nexthop_num
== 0) {
303 if (IS_ZEBRA_DEBUG_KERNEL
)
305 "%s: No useful nexthops were found in RIB prefix %pFX",
314 * Update or delete a prefix from the kernel,
315 * using info from a dataplane context struct.
317 enum zebra_dplane_result
kernel_route_update(struct zebra_dplane_ctx
*ctx
)
319 enum zebra_dplane_result res
= ZEBRA_DPLANE_REQUEST_SUCCESS
;
320 uint32_t type
, old_type
;
322 if (dplane_ctx_get_src(ctx
) != NULL
) {
323 zlog_err("route add: IPv6 sourcedest routes unsupported!");
324 return ZEBRA_DPLANE_REQUEST_FAILURE
;
327 type
= dplane_ctx_get_type(ctx
);
328 old_type
= dplane_ctx_get_old_type(ctx
);
330 frr_with_privs(&zserv_privs
) {
332 if (dplane_ctx_get_op(ctx
) == DPLANE_OP_ROUTE_DELETE
) {
333 if (!RSYSTEM_ROUTE(type
))
334 kernel_rtm(RTM_DELETE
, dplane_ctx_get_dest(ctx
),
335 dplane_ctx_get_ng(ctx
),
336 dplane_ctx_get_metric(ctx
));
337 } else if (dplane_ctx_get_op(ctx
) == DPLANE_OP_ROUTE_INSTALL
) {
338 if (!RSYSTEM_ROUTE(type
))
339 kernel_rtm(RTM_ADD
, dplane_ctx_get_dest(ctx
),
340 dplane_ctx_get_ng(ctx
),
341 dplane_ctx_get_metric(ctx
));
342 } else if (dplane_ctx_get_op(ctx
) == DPLANE_OP_ROUTE_UPDATE
) {
343 /* Must do delete and add separately -
344 * no update available
346 if (!RSYSTEM_ROUTE(old_type
))
347 kernel_rtm(RTM_DELETE
, dplane_ctx_get_dest(ctx
),
348 dplane_ctx_get_old_ng(ctx
),
349 dplane_ctx_get_old_metric(ctx
));
351 if (!RSYSTEM_ROUTE(type
))
352 kernel_rtm(RTM_ADD
, dplane_ctx_get_dest(ctx
),
353 dplane_ctx_get_ng(ctx
),
354 dplane_ctx_get_metric(ctx
));
356 zlog_err("Invalid routing socket update op %s (%u)",
357 dplane_op2str(dplane_ctx_get_op(ctx
)),
358 dplane_ctx_get_op(ctx
));
359 res
= ZEBRA_DPLANE_REQUEST_FAILURE
;
361 } /* Elevated privs */
366 enum zebra_dplane_result
kernel_nexthop_update(struct zebra_dplane_ctx
*ctx
)
368 return ZEBRA_DPLANE_REQUEST_SUCCESS
;
371 int kernel_neigh_register(vrf_id_t vrf_id
, struct zserv
*client
, bool reg
)
377 int kernel_neigh_update(int add
, int ifindex
, void *addr
, char *lla
, int llalen
,
378 ns_id_t ns_id
, uint8_t family
, bool permanent
)
384 /* NYI on routing-socket platforms, but we've always returned 'success'... */
385 enum zebra_dplane_result
kernel_neigh_update_ctx(struct zebra_dplane_ctx
*ctx
)
387 return ZEBRA_DPLANE_REQUEST_SUCCESS
;
390 extern int kernel_get_ipmr_sg_stats(struct zebra_vrf
*zvrf
, void *mroute
)
396 * Update MAC, using dataplane context object. No-op here for now.
398 enum zebra_dplane_result
kernel_mac_update_ctx(struct zebra_dplane_ctx
*ctx
)
400 return ZEBRA_DPLANE_REQUEST_SUCCESS
;
403 extern int kernel_interface_set_master(struct interface
*master
,
404 struct interface
*slave
)
409 uint32_t kernel_get_speed(struct interface
*ifp
, int *error
)
414 int kernel_upd_mac_nh(uint32_t nh_id
, struct in_addr vtep_ip
)
419 int kernel_del_mac_nh(uint32_t nh_id
)
424 int kernel_upd_mac_nhg(uint32_t nhg_id
, uint32_t nh_cnt
,
425 struct nh_grp
*nh_ids
)
430 int kernel_del_mac_nhg(uint32_t nhg_id
)
435 #endif /* !HAVE_NETLINK */