diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/config.c | 3 | ||||
| -rw-r--r-- | src/ndp.c | 15 | ||||
| -rw-r--r-- | src/odhcpd.c | 13 | ||||
| -rw-r--r-- | src/odhcpd.h | 1 |
4 files changed, 24 insertions, 8 deletions
diff --git a/src/config.c b/src/config.c index ea69066..5fbb921 100644 --- a/src/config.c +++ b/src/config.c @@ -717,5 +717,8 @@ void odhcpd_run(void) odhcpd_reload(); uloop_run(); + + while (!list_empty(&interfaces)) + close_interface(list_first_entry(&interfaces, struct interface, head)); } @@ -115,6 +115,7 @@ static void dump_neigh_table(bool proxy) {.ndm_family = AF_INET6, .ndm_flags = (proxy) ? NTF_PROXY : 0} }; send(rtnl_event.uloop.fd, &req, sizeof(req), MSG_DONTWAIT); + odhcpd_process(&rtnl_event); } @@ -309,18 +310,15 @@ void odhcpd_setup_route(const struct in6_addr *addr, int prefixlen, } // Use rtnetlink to modify kernel routes -static void setup_route(struct in6_addr *addr, struct interface *iface, - bool add) +static void setup_route(struct in6_addr *addr, struct interface *iface, bool add) { char namebuf[INET6_ADDRSTRLEN]; inet_ntop(AF_INET6, addr, namebuf, sizeof(namebuf)); - syslog(LOG_NOTICE, "%s about %s on %s", (add) ? "Learned" : "Forgot", - namebuf, (iface) ? iface->ifname : "<pending>"); + syslog(LOG_NOTICE, "%s about %s on %s", + (add) ? "Learned" : "Forgot", namebuf, iface->ifname); - if (!iface || !iface->learn_routes) - return; - - odhcpd_setup_route(addr, 128, iface, NULL, add); + if (iface->learn_routes) + odhcpd_setup_route(addr, 128, iface, NULL, add); } @@ -406,6 +404,7 @@ static void handle_rtnetlink(_unused void *addr, void *data, size_t len, if (nh->nlmsg_type == RTM_NEWNEIGH) { req.ndm.ndm_ifindex = iface->ifindex; send(rtnl_event.uloop.fd, &req, sizeof(req), MSG_DONTWAIT); + setup_route(addr, iface, false); dump_neigh = true; } } else if (add) { diff --git a/src/odhcpd.c b/src/odhcpd.c index b8651dd..0edf63e 100644 --- a/src/odhcpd.c +++ b/src/odhcpd.c @@ -49,6 +49,12 @@ static int rtnl_seq = 0; static int urandom_fd = -1; +static void sighandler(_unused int signal) +{ + uloop_end(); +} + + int main() { openlog("odhcpd", LOG_PERROR | LOG_PID, LOG_DAEMON); @@ -71,6 +77,8 @@ int main() return 4; signal(SIGUSR1, SIG_IGN); + signal(SIGINT, sighandler); + signal(SIGTERM, sighandler); if (init_router()) return 4; @@ -377,6 +385,11 @@ int odhcpd_register(struct odhcpd_event *event) return uloop_fd_add(&event->uloop, ULOOP_READ); } +void odhcpd_process(struct odhcpd_event *event) +{ + odhcpd_receive_packets(&event->uloop, 0); +} + void odhcpd_urandom(void *data, size_t len) { read(urandom_fd, data, len); diff --git a/src/odhcpd.h b/src/odhcpd.h index 91c4f94..c0e509d 100644 --- a/src/odhcpd.h +++ b/src/odhcpd.h @@ -179,6 +179,7 @@ extern struct list_head interfaces; // Exported main functions int odhcpd_open_rtnl(void); int odhcpd_register(struct odhcpd_event *event); +void odhcpd_process(struct odhcpd_event *event); ssize_t odhcpd_send(int socket, struct sockaddr_in6 *dest, struct iovec *iov, size_t iov_len, |