HS 2.0R2: Add routine for fetching OSU provider information
[mech_eap.git] / wpa_supplicant / interworking.c
index eaf231b..0107ff1 100644 (file)
@@ -102,6 +102,9 @@ static void interworking_anqp_resp_cb(void *ctx, const u8 *dst,
 {
        struct wpa_supplicant *wpa_s = ctx;
 
+       wpa_printf(MSG_DEBUG, "ANQP: Response callback dst=" MACSTR
+                  " dialog_token=%u result=%d status_code=%u",
+                  MAC2STR(dst), dialog_token, result, status_code);
        anqp_resp_cb(wpa_s, dst, dialog_token, result, adv_proto, resp,
                     status_code);
        interworking_next_anqp_fetch(wpa_s);
@@ -155,7 +158,8 @@ static int cred_with_domain(struct wpa_supplicant *wpa_s)
        struct wpa_cred *cred;
 
        for (cred = wpa_s->conf->cred; cred; cred = cred->next) {
-               if (cred->domain || cred->pcsc || cred->imsi)
+               if (cred->domain || cred->pcsc || cred->imsi ||
+                   cred->roaming_partner)
                        return 1;
        }
        return 0;
@@ -233,6 +237,7 @@ static int interworking_anqp_send_req(struct wpa_supplicant *wpa_s,
                        wpabuf_put_u8(extra, HS20_STYPE_WAN_METRICS);
                        wpabuf_put_u8(extra, HS20_STYPE_CONNECTION_CAPABILITY);
                        wpabuf_put_u8(extra, HS20_STYPE_OPERATING_CLASS);
+                       wpabuf_put_u8(extra, HS20_STYPE_OSU_PROVIDERS_LIST);
                }
                gas_anqp_set_element_len(extra, len_pos);
        }
@@ -1630,7 +1635,7 @@ static struct wpa_cred * interworking_credentials_available(
 
 
 static int domain_name_list_contains(struct wpabuf *domain_names,
-                                    const char *domain)
+                                    const char *domain, int exact_match)
 {
        const u8 *pos, *end;
        size_t len;
@@ -1648,6 +1653,12 @@ static int domain_name_list_contains(struct wpabuf *domain_names,
                if (pos[0] == len &&
                    os_strncasecmp(domain, (const char *) (pos + 1), len) == 0)
                        return 1;
+               if (!exact_match && pos[0] > len && pos[pos[0] - len] == '.') {
+                       const char *ap = (const char *) (pos + 1);
+                       int offset = pos[0] - len;
+                       if (os_strncasecmp(domain, ap + offset, len) == 0)
+                               return 1;
+               }
 
                pos += 1 + pos[0];
        }
@@ -1690,7 +1701,7 @@ int interworking_home_sp_cred(struct wpa_supplicant *wpa_s,
                wpa_printf(MSG_DEBUG, "Interworking: Search for match "
                           "with SIM/USIM domain %s", realm);
                if (realm &&
-                   domain_name_list_contains(domain_names, realm))
+                   domain_name_list_contains(domain_names, realm, 1))
                        return 1;
                if (realm)
                        ret = 0;
@@ -1703,7 +1714,7 @@ int interworking_home_sp_cred(struct wpa_supplicant *wpa_s,
        for (i = 0; i < cred->num_domain; i++) {
                wpa_printf(MSG_DEBUG, "Interworking: Search for match with "
                           "home SP FQDN %s", cred->domain[i]);
-               if (domain_name_list_contains(domain_names, cred->domain[i]))
+               if (domain_name_list_contains(domain_names, cred->domain[i], 1))
                        return 1;
        }
 
@@ -1755,6 +1766,73 @@ static int interworking_find_network_match(struct wpa_supplicant *wpa_s)
 }
 
 
+static int roaming_partner_match(struct wpa_supplicant *wpa_s,
+                                struct roaming_partner *partner,
+                                struct wpabuf *domain_names)
+{
+       if (!domain_name_list_contains(domain_names, partner->fqdn,
+                                      partner->exact_match))
+               return 0;
+       /* TODO: match Country */
+       return 1;
+}
+
+
+static u8 roaming_prio(struct wpa_supplicant *wpa_s, struct wpa_cred *cred,
+                      struct wpa_bss *bss)
+{
+       size_t i;
+
+       if (bss->anqp == NULL || bss->anqp->domain_name == NULL)
+               return 128; /* cannot check preference with domain name */
+
+       if (interworking_home_sp_cred(wpa_s, cred, bss->anqp->domain_name) > 0)
+               return 0; /* max preference for home SP network */
+
+       for (i = 0; i < cred->num_roaming_partner; i++) {
+               if (roaming_partner_match(wpa_s, &cred->roaming_partner[i],
+                                         bss->anqp->domain_name))
+                       return cred->roaming_partner[i].priority;
+       }
+
+       return 128;
+}
+
+
+static struct wpa_bss * pick_best_roaming_partner(struct wpa_supplicant *wpa_s,
+                                                 struct wpa_bss *selected,
+                                                 struct wpa_cred *cred)
+{
+       struct wpa_bss *bss;
+       u8 best_prio, prio;
+
+       /*
+        * Check if any other BSS is operated by a more preferred roaming
+        * partner.
+        */
+
+       best_prio = roaming_prio(wpa_s, cred, selected);
+
+       dl_list_for_each(bss, &wpa_s->bss, struct wpa_bss, list) {
+               if (bss == selected)
+                       continue;
+               cred = interworking_credentials_available(wpa_s, bss);
+               if (!cred)
+                       continue;
+               if (!wpa_bss_get_ie(bss, WLAN_EID_RSN))
+                       continue;
+               prio = roaming_prio(wpa_s, cred, bss);
+               if (prio < best_prio) {
+                       best_prio = prio;
+                       selected = bss;
+               }
+       }
+
+
+       return selected;
+}
+
+
 static void interworking_select_network(struct wpa_supplicant *wpa_s)
 {
        struct wpa_bss *bss, *selected = NULL, *selected_home = NULL;
@@ -1762,7 +1840,8 @@ static void interworking_select_network(struct wpa_supplicant *wpa_s)
        unsigned int count = 0;
        const char *type;
        int res;
-       struct wpa_cred *cred;
+       struct wpa_cred *cred, *selected_cred = NULL;
+       struct wpa_cred *selected_home_cred = NULL;
 
        wpa_s->network_select = 0;
 
@@ -1798,12 +1877,14 @@ static void interworking_select_network(struct wpa_supplicant *wpa_s)
                            cred->priority > selected_prio) {
                                selected = bss;
                                selected_prio = cred->priority;
+                               selected_cred = cred;
                        }
                        if (res > 0 &&
                            (selected_home == NULL ||
                             cred->priority > selected_home_prio)) {
                                selected_home = bss;
                                selected_home_prio = cred->priority;
+                               selected_home_cred = cred;
                        }
                }
        }
@@ -1812,6 +1893,7 @@ static void interworking_select_network(struct wpa_supplicant *wpa_s)
            selected_home_prio >= selected_prio) {
                /* Prefer network operated by the Home SP */
                selected = selected_home;
+               selected_cred = selected_home_cred;
        }
 
        if (count == 0) {
@@ -1840,8 +1922,11 @@ static void interworking_select_network(struct wpa_supplicant *wpa_s)
                        "with matching credentials found");
        }
 
-       if (selected)
+       if (selected) {
+               selected = pick_best_roaming_partner(wpa_s, selected,
+                                                    selected_cred);
                interworking_connect(wpa_s, selected);
+       }
 }
 
 
@@ -1888,8 +1973,21 @@ static void interworking_next_anqp_fetch(struct wpa_supplicant *wpa_s)
        int found = 0;
        const u8 *ie;
 
-       if (eloop_terminated() || !wpa_s->fetch_anqp_in_progress)
+       wpa_printf(MSG_DEBUG, "Interworking: next_anqp_fetch - "
+                  "fetch_anqp_in_progress=%d fetch_osu_icon_in_progress=%d",
+                  wpa_s->fetch_anqp_in_progress,
+                  wpa_s->fetch_osu_icon_in_progress);
+
+       if (eloop_terminated() || !wpa_s->fetch_anqp_in_progress) {
+               wpa_printf(MSG_DEBUG, "Interworking: Stop next-ANQP-fetch");
+               return;
+       }
+
+       if (wpa_s->fetch_osu_icon_in_progress) {
+               wpa_printf(MSG_DEBUG, "Interworking: Next icon (in progress)");
+               hs20_next_osu_icon(wpa_s);
                return;
+       }
 
        dl_list_for_each(bss, &wpa_s->bss, struct wpa_bss, list) {
                if (!(bss->caps & IEEE80211_CAP_ESS))
@@ -1923,6 +2021,11 @@ static void interworking_next_anqp_fetch(struct wpa_supplicant *wpa_s)
        }
 
        if (found == 0) {
+               if (wpa_s->fetch_osu_info) {
+                       wpa_printf(MSG_DEBUG, "Interworking: Next icon");
+                       hs20_osu_icon_fetch(wpa_s);
+                       return;
+               }
                wpa_msg(wpa_s, MSG_INFO, "ANQP fetch completed");
                wpa_s->fetch_anqp_in_progress = 0;
                if (wpa_s->network_select)
@@ -1950,6 +2053,7 @@ int interworking_fetch_anqp(struct wpa_supplicant *wpa_s)
 
        wpa_s->network_select = 0;
        wpa_s->fetch_all_anqp = 1;
+       wpa_s->fetch_osu_info = 0;
 
        interworking_start_fetch_anqp(wpa_s);
 
@@ -2147,14 +2251,22 @@ void anqp_resp_cb(void *ctx, const u8 *dst, u8 dialog_token,
        u16 slen;
        struct wpa_bss *bss = NULL, *tmp;
 
-       if (result != GAS_QUERY_SUCCESS)
+       wpa_printf(MSG_DEBUG, "Interworking: anqp_resp_cb dst=" MACSTR
+                  " dialog_token=%u result=%d status_code=%u",
+                  MAC2STR(dst), dialog_token, result, status_code);
+       if (result != GAS_QUERY_SUCCESS) {
+               if (wpa_s->fetch_osu_icon_in_progress)
+                       hs20_icon_fetch_failed(wpa_s);
                return;
+       }
 
        pos = wpabuf_head(adv_proto);
        if (wpabuf_len(adv_proto) < 4 || pos[0] != WLAN_EID_ADV_PROTO ||
            pos[1] < 2 || pos[3] != ACCESS_NETWORK_QUERY_PROTOCOL) {
                wpa_printf(MSG_DEBUG, "ANQP: Unexpected Advertisement "
                           "Protocol in response");
+               if (wpa_s->fetch_osu_icon_in_progress)
+                       hs20_icon_fetch_failed(wpa_s);
                return;
        }
 
@@ -2194,6 +2306,8 @@ void anqp_resp_cb(void *ctx, const u8 *dst, u8 dialog_token,
                                                slen);
                pos += slen;
        }
+
+       hs20_notify_parse_done(wpa_s);
 }
 
 
@@ -2214,6 +2328,7 @@ int interworking_select(struct wpa_supplicant *wpa_s, int auto_select,
        wpa_s->auto_network_select = 0;
        wpa_s->auto_select = !!auto_select;
        wpa_s->fetch_all_anqp = 0;
+       wpa_s->fetch_osu_info = 0;
        wpa_printf(MSG_DEBUG, "Interworking: Start scan for network "
                   "selection");
        wpa_s->scan_res_handler = interworking_scan_res_handler;