Source-Changes-HG archive

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index][Old Index]

[src/trunk]: src/external/bsd/wpa/dist/src/drivers wpa: Share route(4) proces...



details:   https://anonhg.NetBSD.org/src/rev/e77591cfc0de
branches:  trunk
changeset: 744305:e77591cfc0de
user:      roy <roy%NetBSD.org@localhost>
date:      Wed Jan 29 11:44:43 2020 +0000

description:
wpa: Share route(4) processing with hostapd and wpa_supplicant.

There is little point in having both and it brings interface
addition/removal and IFF_UP notifications to hostapd.

diffstat:

 external/bsd/wpa/dist/src/drivers/driver_bsd.c |  384 +++++++++---------------
 1 files changed, 149 insertions(+), 235 deletions(-)

diffs (truncated from 447 to 300 lines):

diff -r 8547a3bbcfd5 -r e77591cfc0de external/bsd/wpa/dist/src/drivers/driver_bsd.c
--- a/external/bsd/wpa/dist/src/drivers/driver_bsd.c    Wed Jan 29 11:31:40 2020 +0000
+++ b/external/bsd/wpa/dist/src/drivers/driver_bsd.c    Wed Jan 29 11:44:43 2020 +0000
@@ -132,7 +132,6 @@
        return NULL;
 }
 
-#ifndef HOSTAPD
 static struct bsd_driver_data *
 bsd_get_drvname(void *priv, const char *ifname)
 {
@@ -145,7 +144,6 @@
        }
        return NULL;
 }
-#endif /* HOSTAPD */
 
 static int
 bsd_set80211(void *priv, int op, int val, const void *arg, int arg_len)
@@ -680,6 +678,154 @@
        return 0;
 }
 
+static void
+bsd_wireless_event_receive(int sock, void *ctx, void *sock_ctx)
+{
+       struct bsd_driver_global *global = sock_ctx;
+       struct bsd_driver_data *drv;
+       struct if_announcemsghdr *ifan;
+       struct if_msghdr *ifm;
+       struct rt_msghdr *rtm;
+       union wpa_event_data event;
+       struct ieee80211_michael_event *mic;
+       struct ieee80211_leave_event *leave;
+       struct ieee80211_join_event *join;
+       int n;
+       struct msghdr msg = { .msg_iov = global->event_iov, .msg_iovlen = 1};
+
+       n = recvmsg_realloc(sock, &msg, 0);
+       if (n < 0) {
+               if (errno != EINTR && errno != EAGAIN)
+                       wpa_printf(MSG_ERROR, "%s read() failed: %s",
+                                  __func__, strerror(errno));
+               return;
+       }
+
+       rtm = (struct rt_msghdr *) global->event_iov[0].iov_base;
+       if (rtm->rtm_version != RTM_VERSION) {
+               wpa_printf(MSG_DEBUG, "Invalid routing message version=%d",
+                          rtm->rtm_version);
+               return;
+       }
+       os_memset(&event, 0, sizeof(event));
+       switch (rtm->rtm_type) {
+       case RTM_IEEE80211:
+               ifan = (struct if_announcemsghdr *) rtm;
+               drv = bsd_get_drvindex(global, ifan->ifan_index);
+               if (drv == NULL)
+                       return;
+               switch (ifan->ifan_what) {
+               case RTM_IEEE80211_ASSOC:
+               case RTM_IEEE80211_REASSOC:
+                       if (drv->is_ap)
+                               break;
+                       wpa_supplicant_event(drv->ctx, EVENT_ASSOC, NULL);
+                       break;
+               case RTM_IEEE80211_DISASSOC:
+                       if (drv->is_ap)
+                               break;
+                       wpa_supplicant_event(drv->ctx, EVENT_DISASSOC, NULL);
+                       break;
+               case RTM_IEEE80211_SCAN:
+                       if (drv->is_ap)
+                               break;
+                       wpa_supplicant_event(drv->ctx, EVENT_SCAN_RESULTS,
+                                            NULL);
+                       break;
+               case RTM_IEEE80211_LEAVE:
+                       leave = (struct ieee80211_leave_event *) &ifan[1];
+                       drv_event_disassoc(drv->ctx, leave->iev_addr);
+                       break;
+               case RTM_IEEE80211_JOIN:
+#ifdef RTM_IEEE80211_REJOIN
+               case RTM_IEEE80211_REJOIN:
+#endif
+                       join = (struct ieee80211_join_event *) &ifan[1];
+                       bsd_new_sta(drv, drv->ctx, join->iev_addr);
+                       break;
+               case RTM_IEEE80211_REPLAY:
+                       /* ignore */
+                       break;
+               case RTM_IEEE80211_MICHAEL:
+                       mic = (struct ieee80211_michael_event *) &ifan[1];
+                       wpa_printf(MSG_DEBUG,
+                               "Michael MIC failure wireless event: "
+                               "keyix=%u src_addr=" MACSTR, mic->iev_keyix,
+                               MAC2STR(mic->iev_src));
+                       os_memset(&event, 0, sizeof(event));
+                       event.michael_mic_failure.unicast =
+                               !IEEE80211_IS_MULTICAST(mic->iev_dst);
+                       event.michael_mic_failure.src = mic->iev_src;
+                       wpa_supplicant_event(drv->ctx,
+                                            EVENT_MICHAEL_MIC_FAILURE, &event);
+                       break;
+               }
+               break;
+       case RTM_IFANNOUNCE:
+               ifan = (struct if_announcemsghdr *) rtm;
+               switch (ifan->ifan_what) {
+               case IFAN_DEPARTURE:
+                       drv = bsd_get_drvindex(global, ifan->ifan_index);
+                       if (drv)
+                               drv->if_removed = 1;
+                       event.interface_status.ievent = EVENT_INTERFACE_REMOVED;
+                       break;
+               case IFAN_ARRIVAL:
+                       drv = bsd_get_drvname(global, ifan->ifan_name);
+                       if (drv) {
+                               drv->ifindex = ifan->ifan_index;
+                               drv->if_removed = 0;
+                       }
+                       event.interface_status.ievent = EVENT_INTERFACE_ADDED;
+                       break;
+               default:
+                       wpa_printf(MSG_DEBUG, "RTM_IFANNOUNCE: unknown action");
+                       return;
+               }
+               wpa_printf(MSG_DEBUG, "RTM_IFANNOUNCE: Interface '%s' %s",
+                          ifan->ifan_name,
+                          ifan->ifan_what == IFAN_DEPARTURE ?
+                               "removed" : "added");
+               os_strlcpy(event.interface_status.ifname, ifan->ifan_name,
+                          sizeof(event.interface_status.ifname));
+               if (drv) {
+                       wpa_supplicant_event(drv->ctx, EVENT_INTERFACE_STATUS,
+                                            &event);
+                       /*
+                        * Set ifindex to zero after sending the event as the
+                        * event might query the driver to ensure a match.
+                        */
+                       if (ifan->ifan_what == IFAN_DEPARTURE)
+                               drv->ifindex = 0;
+               } else {
+                       wpa_supplicant_event_global(global->ctx,
+                                                   EVENT_INTERFACE_STATUS,
+                                                   &event);
+               }
+               break;
+       case RTM_IFINFO:
+               ifm = (struct if_msghdr *) rtm;
+               drv = bsd_get_drvindex(global, ifm->ifm_index);
+               if (drv == NULL)
+                       return;
+               if ((ifm->ifm_flags & IFF_UP) == 0 &&
+                   (drv->flags & IFF_UP) != 0) {
+                       wpa_printf(MSG_DEBUG, "RTM_IFINFO: Interface '%s' DOWN",
+                                  drv->ifname);
+                       wpa_supplicant_event(drv->ctx, EVENT_INTERFACE_DISABLED,
+                                            NULL);
+               } else if ((ifm->ifm_flags & IFF_UP) != 0 &&
+                   (drv->flags & IFF_UP) == 0) {
+                       wpa_printf(MSG_DEBUG, "RTM_IFINFO: Interface '%s' UP",
+                                  drv->ifname);
+                       wpa_supplicant_event(drv->ctx, EVENT_INTERFACE_ENABLED,
+                                            NULL);
+               }
+               drv->flags = ifm->ifm_flags;
+               break;
+       }
+}
+
 #ifdef HOSTAPD
 
 /*
@@ -798,80 +944,6 @@
 }
 
 static void
-bsd_wireless_event_receive(int sock, void *ctx, void *sock_ctx)
-{
-       struct bsd_driver_global *global = sock_ctx;
-       struct bsd_driver_data *drv;
-       struct msghdr msg;
-       struct if_announcemsghdr *ifan;
-       struct rt_msghdr *rtm;
-       struct ieee80211_michael_event *mic;
-       struct ieee80211_join_event *join;
-       struct ieee80211_leave_event *leave;
-       ssize_t n;
-       union wpa_event_data data;
-
-       memset(&msg, 0, sizeof(msg));
-       msg.msg_iov = global->event_iov;
-       msg.msg_iovlen = 1;
-       n = recvmsg_realloc(sock, &msg, 0);
-       if (n < 0) {
-               if (errno != EINTR && errno != EAGAIN)
-                       wpa_printf(MSG_ERROR, "%s read() failed: %s",
-                                  __func__, strerror(errno));
-               return;
-       }
-
-       rtm = (struct rt_msghdr *) global->event_iov[0].iov_base;
-       if (rtm->rtm_version != RTM_VERSION) {
-               wpa_printf(MSG_DEBUG, "Invalid routing message version=%d",
-                          rtm->rtm_version);
-               return;
-       }
-       switch (rtm->rtm_type) {
-       case RTM_IEEE80211:
-               ifan = (struct if_announcemsghdr *) rtm;
-               drv = bsd_get_drvindex(global, ifan->ifan_index);
-               if (drv == NULL)
-                       return;
-               switch (ifan->ifan_what) {
-               case RTM_IEEE80211_ASSOC:
-               case RTM_IEEE80211_REASSOC:
-               case RTM_IEEE80211_DISASSOC:
-               case RTM_IEEE80211_SCAN:
-                       break;
-               case RTM_IEEE80211_LEAVE:
-                       leave = (struct ieee80211_leave_event *) &ifan[1];
-                       drv_event_disassoc(drv->ctx, leave->iev_addr);
-                       break;
-               case RTM_IEEE80211_JOIN:
-#ifdef RTM_IEEE80211_REJOIN
-               case RTM_IEEE80211_REJOIN:
-#endif
-                       join = (struct ieee80211_join_event *) &ifan[1];
-                       bsd_new_sta(drv, drv->ctx, join->iev_addr);
-                       break;
-               case RTM_IEEE80211_REPLAY:
-                       /* ignore */
-                       break;
-               case RTM_IEEE80211_MICHAEL:
-                       mic = (struct ieee80211_michael_event *) &ifan[1];
-                       wpa_printf(MSG_DEBUG,
-                               "Michael MIC failure wireless event: "
-                               "keyix=%u src_addr=" MACSTR, mic->iev_keyix,
-                               MAC2STR(mic->iev_src));
-                       os_memset(&data, 0, sizeof(data));
-                       data.michael_mic_failure.unicast = 1;
-                       data.michael_mic_failure.src = mic->iev_src;
-                       wpa_supplicant_event(drv->ctx,
-                                            EVENT_MICHAEL_MIC_FAILURE, &data);
-                       break;
-               }
-               break;
-       }
-}
-
-static void
 handle_read(void *ctx, const u8 *src_addr, const u8 *buf, size_t len)
 {
        struct bsd_driver_data *drv = ctx;
@@ -897,6 +969,7 @@
        }
 
        drv->ctx = hapd;
+       drv->is_ap = 1;
        drv->global = params->global_priv;
        os_strlcpy(drv->ifname, params->ifname, sizeof(drv->ifname));
 
@@ -1240,157 +1313,6 @@
 }
 
 static void
-wpa_driver_bsd_event_receive(int sock, void *ctx, void *sock_ctx)
-{
-       struct bsd_driver_global *global = sock_ctx;
-       struct bsd_driver_data *drv;
-       struct msghdr msg;
-       struct if_announcemsghdr *ifan;
-       struct if_msghdr *ifm;
-       struct rt_msghdr *rtm;
-       union wpa_event_data event;
-       struct ieee80211_michael_event *mic;
-       struct ieee80211_leave_event *leave;
-       struct ieee80211_join_event *join;
-       ssize_t n;
-
-       memset(&msg, 0, sizeof(msg));
-       msg.msg_iov = global->event_iov;
-       msg.msg_iovlen = 1;
-       n = recvmsg_realloc(sock, &msg, 0);
-       if (n < 0) {
-               if (errno != EINTR && errno != EAGAIN)
-                       wpa_printf(MSG_ERROR, "%s read() failed: %s",
-                                  __func__, strerror(errno));
-               return;
-       }
-
-       rtm = (struct rt_msghdr *) global->event_iov[0].iov_base;
-       if (rtm->rtm_version != RTM_VERSION) {
-               wpa_printf(MSG_DEBUG, "Invalid routing message version=%d",
-                          rtm->rtm_version);
-               return;
-       }
-       os_memset(&event, 0, sizeof(event));
-       switch (rtm->rtm_type) {



Home | Main Index | Thread Index | Old Index