]>
git.proxmox.com Git - mirror_ovs.git/blob - lib/route-table-bsd.c
2 * Copyright (c) 2012 Ed Maste. All rights reserved.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at:
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
19 #include "route-table.h"
21 #include <sys/socket.h>
22 #include <sys/types.h>
25 #include <net/route.h>
26 #include <net/if_dl.h>
27 #include <netinet/in.h>
34 #include "ovs-router.h"
36 #include "openvswitch/vlog.h"
39 VLOG_DEFINE_THIS_MODULE(route_table_bsd
);
41 /* OS X does not define RT_ROUNDUP() or equivalent macro. */
43 #define RT_ROUNDUP(l) ((l) > 0 ? ROUND_UP((l), sizeof(long)) : sizeof(long))
47 route_table_fallback_lookup(const struct in6_addr
*ip6_dst
, char name
[],
56 struct rt_msghdr
*rtm
= &rtmsg
.rtm
;
57 struct sockaddr_dl
*ifp
= NULL
;
58 struct sockaddr_in
*sin
;
61 int i
, namelen
, rtsock
;
63 const pid_t pid
= getpid();
65 unsigned int retry_count
= 5; /* arbitrary */
67 if (!IN6_IS_ADDR_V4MAPPED(ip6_dst
)) {
70 ip
= in6_addr_get_mapped_ipv4(ip6_dst
);
72 VLOG_DBG("looking route up for " IP_FMT
" pid %" PRIuMAX
,
73 IP_ARGS(ip
), (uintmax_t)pid
);
75 rtsock
= socket(PF_ROUTE
, SOCK_RAW
, 0);
80 memset(&rtmsg
, 0, sizeof(rtmsg
));
81 rtm
->rtm_msglen
= sizeof(struct rt_msghdr
) + sizeof(struct sockaddr_in
);
82 rtm
->rtm_version
= RTM_VERSION
;
83 rtm
->rtm_type
= RTM_GET
;
84 rtm
->rtm_addrs
= RTA_DST
| RTA_IFP
;
87 sin
= (struct sockaddr_in
*)(rtm
+ 1);
88 sin
->sin_len
= len
= sizeof(struct sockaddr_in
);
89 sin
->sin_family
= AF_INET
;
90 sin
->sin_addr
.s_addr
= ip
;
92 len
= write(rtsock
, (char *)&rtmsg
, rtm
->rtm_msglen
);
94 if (errno
== ENOBUFS
&& retry_count
-- > 0) {
95 VLOG_INFO("Recoverable error writing to routing socket: %s",
97 usleep(500 * 1000); /* arbitrary */
100 VLOG_ERR("Error writing to routing socket: %s", ovs_strerror(errno
));
104 if (len
!= rtm
->rtm_msglen
) {
105 VLOG_ERR("Short write to routing socket");
114 memset(&pfd
, 0, sizeof(pfd
));
118 * The timeout value below is somehow arbitrary.
119 * It's to detect the lost of routing messages due to
120 * buffer exhaustion etc. The routing socket is not
123 ret
= poll(&pfd
, 1, 500);
125 VLOG_ERR("Error polling on routing socket: %s",
126 ovs_strerror(errno
));
131 if (retry_count
-- > 0) {
132 VLOG_INFO("Timeout; resending routing message");
138 len
= read(rtsock
, (char *)&rtmsg
, sizeof(rtmsg
));
140 VLOG_DBG("got rtmsg pid %" PRIuMAX
" seq %d",
141 (uintmax_t)rtmsg
.rtm
.rtm_pid
,
144 } while (len
> 0 && (rtmsg
.rtm
.rtm_seq
!= seq
||
145 rtmsg
.rtm
.rtm_pid
!= pid
));
148 VLOG_ERR("Error reading from routing socket: %s", ovs_strerror(errno
));
153 sa
= (struct sockaddr
*)(rtm
+ 1);
154 for (i
= 1; i
; i
<<= 1) {
155 if (rtm
->rtm_addrs
& i
) {
156 if (i
== RTA_IFP
&& sa
->sa_family
== AF_LINK
&&
157 ALIGNED_CAST(struct sockaddr_dl
*, sa
)->sdl_nlen
) {
158 ifp
= ALIGNED_CAST(struct sockaddr_dl
*, sa
);
159 namelen
= ifp
->sdl_nlen
;
160 if (namelen
> IFNAMSIZ
- 1)
161 namelen
= IFNAMSIZ
- 1;
162 memcpy(name
, ifp
->sdl_data
, namelen
);
163 name
[namelen
] = '\0';
164 VLOG_DBG("got ifp %s", name
);
166 } else if (i
== RTA_GATEWAY
&& sa
->sa_family
== AF_INET
) {
167 const struct sockaddr_in
*sin_dst
=
168 ALIGNED_CAST(struct sockaddr_in
*, sa
);
170 in6_addr_set_mapped_ipv4(gw6
, sin_dst
->sin_addr
.s_addr
);
171 VLOG_DBG("got gateway " IP_FMT
, IP_ARGS(sin_dst
->sin_addr
.s_addr
));
173 #if defined(__FreeBSD__)
174 sa
= (struct sockaddr
*)((char *)sa
+ SA_SIZE(sa
));
175 #elif defined(__NetBSD__)
176 sa
= (struct sockaddr
*)((char *)sa
+ RT_ROUNDUP(sa
->sa_len
));
177 #elif defined(__MACH__)
178 sa
= (struct sockaddr
*)((char *)sa
+ RT_ROUNDUP(sa
->sa_len
));
188 route_table_get_change_seq(void)
194 route_table_init(void)
200 route_table_run(void)
205 route_table_wait(void)