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);
42 route_table_fallback_lookup(ovs_be32 ip, char name[], ovs_be32 *gw)
49 struct rt_msghdr *rtm = &rtmsg.rtm;
50 struct sockaddr_dl *ifp = NULL;
51 struct sockaddr_in *sin;
54 int i, namelen, rtsock;
56 const pid_t pid = getpid();
58 unsigned int retry_count = 5; /* arbitrary */
60 VLOG_DBG("looking route up for " IP_FMT " pid %" PRIuMAX,
61 IP_ARGS(ip), (uintmax_t)pid);
63 rtsock = socket(PF_ROUTE, SOCK_RAW, 0);
68 memset(&rtmsg, 0, sizeof(rtmsg));
69 rtm->rtm_msglen = sizeof(struct rt_msghdr) + sizeof(struct sockaddr_in);
70 rtm->rtm_version = RTM_VERSION;
71 rtm->rtm_type = RTM_GET;
72 rtm->rtm_addrs = RTA_DST | RTA_IFP;
75 sin = (struct sockaddr_in *)(rtm + 1);
76 sin->sin_len = len = sizeof(struct sockaddr_in);
77 sin->sin_family = AF_INET;
78 sin->sin_addr.s_addr = ip;
80 len = write(rtsock, (char *)&rtmsg, rtm->rtm_msglen);
82 if (errno == ENOBUFS && retry_count-- > 0) {
83 VLOG_INFO("Recoverable error writing to routing socket: %s",
85 usleep(500 * 1000); /* arbitrary */
88 VLOG_ERR("Error writing to routing socket: %s", ovs_strerror(errno));
92 if (len != rtm->rtm_msglen) {
93 VLOG_ERR("Short write to routing socket");
102 memset(&pfd, 0, sizeof(pfd));
106 * The timeout value below is somehow arbitrary.
107 * It's to detect the lost of routing messages due to
108 * buffer exhaustion etc. The routing socket is not
111 ret = poll(&pfd, 1, 500);
113 VLOG_ERR("Error polling on routing socket: %s",
114 ovs_strerror(errno));
119 if (retry_count-- > 0) {
120 VLOG_INFO("Timeout; resending routing message");
126 len = read(rtsock, (char *)&rtmsg, sizeof(rtmsg));
128 VLOG_DBG("got rtmsg pid %" PRIuMAX " seq %d",
129 (uintmax_t)rtmsg.rtm.rtm_pid,
132 } while (len > 0 && (rtmsg.rtm.rtm_seq != seq ||
133 rtmsg.rtm.rtm_pid != pid));
136 VLOG_ERR("Error reading from routing socket: %s", ovs_strerror(errno));
141 sa = (struct sockaddr *)(rtm + 1);
142 for (i = 1; i; i <<= 1) {
143 if (rtm->rtm_addrs & i) {
144 if (i == RTA_IFP && sa->sa_family == AF_LINK &&
145 ALIGNED_CAST(struct sockaddr_dl *, sa)->sdl_nlen) {
146 ifp = ALIGNED_CAST(struct sockaddr_dl *, sa);
147 namelen = ifp->sdl_nlen;
148 if (namelen > IFNAMSIZ - 1)
149 namelen = IFNAMSIZ - 1;
150 memcpy(name, ifp->sdl_data, namelen);
151 name[namelen] = '\0';
152 VLOG_DBG("got ifp %s", name);
154 } else if (i == RTA_GATEWAY && sa->sa_family == AF_INET) {
155 const struct sockaddr_in *sin_dst =
156 ALIGNED_CAST(struct sockaddr_in *, sa);
158 *gw = sin_dst->sin_addr.s_addr;
159 VLOG_DBG("got gateway " IP_FMT, IP_ARGS(*gw));
161 #if defined(__FreeBSD__)
162 sa = (struct sockaddr *)((char *)sa + SA_SIZE(sa));
163 #elif defined(__NetBSD__)
164 sa = (struct sockaddr *)((char *)sa + RT_ROUNDUP(sa->sa_len));
174 route_table_get_change_seq(void)
180 route_table_init(void)
186 route_table_run(void)
191 route_table_wait(void)