src/p2p/p2p_group.c

   1 /*
   2  * Wi-Fi Direct - P2P group operations
   3  * Copyright (c) 2009-2010, Atheros Communications
   4  *
   5  * This software may be distributed under the terms of the BSD license.
   6  * See README for more details.
   7  */
   8
   9 #include "includes.h"
  10
  11 #include "common.h"
  12 #include "common/ieee802_11_defs.h"
  13 #include "common/ieee802_11_common.h"
  14 #include "wps/wps_defs.h"
  15 #include "wps/wps_i.h"
  16 #include "p2p_i.h"
  17 #include "p2p.h"
  18
  19
  20 struct p2p_group_member {
  21         struct p2p_group_member *next;
  22         u8 addr[ETH_ALEN]; /* P2P Interface Address */
  23         u8 dev_addr[ETH_ALEN]; /* P2P Device Address */
  24         struct wpabuf *p2p_ie;
  25         struct wpabuf *wfd_ie;
  26         struct wpabuf *client_info;
  27         u8 dev_capab;
  28 };
  29
  30 /**
  31  * struct p2p_group - Internal P2P module per-group data
  32  */
  33 struct p2p_group {
  34         struct p2p_data *p2p;
  35         struct p2p_group_config *cfg;
  36         struct p2p_group_member *members;
  37         unsigned int num_members;
  38         int group_formation;
  39         int beacon_update;
  40         struct wpabuf *noa;
  41         struct wpabuf *wfd_ie;
  42 };
  43
  44
  45 struct p2p_group * p2p_group_init(struct p2p_data *p2p,
  46                                   struct p2p_group_config *config)
  47 {
  48         struct p2p_group *group, **groups;
  49
  50         group = os_zalloc(sizeof(*group));
  51         if (group == NULL)
  52                 return NULL;
  53
  54         groups = os_realloc_array(p2p->groups, p2p->num_groups + 1,
  55                                   sizeof(struct p2p_group *));
  56         if (groups == NULL) {
  57                 os_free(group);
  58                 return NULL;
  59         }
  60         groups[p2p->num_groups++] = group;
  61         p2p->groups = groups;
  62
  63         group->p2p = p2p;
  64         group->cfg = config;
  65         group->group_formation = 1;
  66         group->beacon_update = 1;
  67         p2p_group_update_ies(group);
  68         group->cfg->idle_update(group->cfg->cb_ctx, 1);
  69
  70         return group;
  71 }
  72
  73
  74 static void p2p_group_free_member(struct p2p_group_member *m)
  75 {
  76         wpabuf_free(m->wfd_ie);
  77         wpabuf_free(m->p2p_ie);
  78         wpabuf_free(m->client_info);
  79         os_free(m);
  80 }
  81
  82
  83 static void p2p_group_free_members(struct p2p_group *group)
  84 {
  85         struct p2p_group_member *m, *prev;
  86         m = group->members;
  87         group->members = NULL;
  88         group->num_members = 0;
  89         while (m) {
  90                 prev = m;
  91                 m = m->next;
  92                 p2p_group_free_member(prev);
  93         }
  94 }
  95
  96
  97 void p2p_group_deinit(struct p2p_group *group)
  98 {
  99         size_t g;
 100         struct p2p_data *p2p;
 101
 102         if (group == NULL)
 103                 return;
 104
 105         p2p = group->p2p;
 106
 107         for (g = 0; g < p2p->num_groups; g++) {
 108                 if (p2p->groups[g] == group) {
 109                         while (g + 1 < p2p->num_groups) {
 110                                 p2p->groups[g] = p2p->groups[g + 1];
 111                                 g++;
 112                         }
 113                         p2p->num_groups--;
 114                         break;
 115                 }
 116         }
 117
 118         p2p_group_free_members(group);
 119         os_free(group->cfg);
 120         wpabuf_free(group->noa);
 121         wpabuf_free(group->wfd_ie);
 122         os_free(group);
 123 }
 124
 125
 126 static void p2p_client_info(struct wpabuf *ie, struct p2p_group_member *m)
 127 {
 128         if (m->client_info == NULL)
 129                 return;
 130         if (wpabuf_tailroom(ie) < wpabuf_len(m->client_info) + 1)
 131                 return;
 132         wpabuf_put_buf(ie, m->client_info);
 133 }
 134
 135
 136 static void p2p_group_add_common_ies(struct p2p_group *group,
 137                                      struct wpabuf *ie)
 138 {
 139         u8 dev_capab = group->p2p->dev_capab, group_capab = 0;
 140
 141         /* P2P Capability */
 142         dev_capab &= ~P2P_DEV_CAPAB_CLIENT_DISCOVERABILITY;
 143         group_capab |= P2P_GROUP_CAPAB_GROUP_OWNER;
 144         if (group->cfg->persistent_group) {
 145                 group_capab |= P2P_GROUP_CAPAB_PERSISTENT_GROUP;
 146                 if (group->cfg->persistent_group == 2)
 147                         group_capab |= P2P_GROUP_CAPAB_PERSISTENT_RECONN;
 148         }
 149         if (group->p2p->cfg->p2p_intra_bss)
 150                 group_capab |= P2P_GROUP_CAPAB_INTRA_BSS_DIST;
 151         if (group->group_formation)
 152                 group_capab |= P2P_GROUP_CAPAB_GROUP_FORMATION;
 153         if (group->p2p->cross_connect)
 154                 group_capab |= P2P_GROUP_CAPAB_CROSS_CONN;
 155         if (group->num_members >= group->cfg->max_clients)
 156                 group_capab |= P2P_GROUP_CAPAB_GROUP_LIMIT;
 157         p2p_buf_add_capability(ie, dev_capab, group_capab);
 158 }
 159
 160
 161 static void p2p_group_add_noa(struct wpabuf *ie, struct wpabuf *noa)
 162 {
 163         if (noa == NULL)
 164                 return;
 165         /* Notice of Absence */
 166         wpabuf_put_u8(ie, P2P_ATTR_NOTICE_OF_ABSENCE);
 167         wpabuf_put_le16(ie, wpabuf_len(noa));
 168         wpabuf_put_buf(ie, noa);
 169 }
 170
 171
 172 static struct wpabuf * p2p_group_encaps_probe_resp(struct wpabuf *subelems)
 173 {
 174         struct wpabuf *ie;
 175         const u8 *pos, *end;
 176         size_t len;
 177
 178         if (subelems == NULL)
 179                 return NULL;
 180
 181         len = wpabuf_len(subelems) + 100;
 182
 183         ie = wpabuf_alloc(len);
 184         if (ie == NULL)
 185                 return NULL;
 186
 187         pos = wpabuf_head(subelems);
 188         end = pos + wpabuf_len(subelems);
 189
 190         while (end > pos) {
 191                 size_t frag_len = end - pos;
 192                 if (frag_len > 251)
 193                         frag_len = 251;
 194                 wpabuf_put_u8(ie, WLAN_EID_VENDOR_SPECIFIC);
 195                 wpabuf_put_u8(ie, 4 + frag_len);
 196                 wpabuf_put_be32(ie, P2P_IE_VENDOR_TYPE);
 197                 wpabuf_put_data(ie, pos, frag_len);
 198                 pos += frag_len;
 199         }
 200
 201         return ie;
 202 }
 203
 204
 205 static struct wpabuf * p2p_group_build_beacon_ie(struct p2p_group *group)
 206 {
 207         struct wpabuf *ie;
 208         u8 *len;
 209         size_t extra = 0;
 210
 211 #ifdef CONFIG_WIFI_DISPLAY
 212         if (group->p2p->wfd_ie_beacon)
 213                 extra = wpabuf_len(group->p2p->wfd_ie_beacon);
 214 #endif /* CONFIG_WIFI_DISPLAY */
 215
 216         ie = wpabuf_alloc(257 + extra);
 217         if (ie == NULL)
 218                 return NULL;
 219
 220 #ifdef CONFIG_WIFI_DISPLAY
 221         if (group->p2p->wfd_ie_beacon)
 222                 wpabuf_put_buf(ie, group->p2p->wfd_ie_beacon);
 223 #endif /* CONFIG_WIFI_DISPLAY */
 224
 225         len = p2p_buf_add_ie_hdr(ie);
 226         p2p_group_add_common_ies(group, ie);
 227         p2p_buf_add_device_id(ie, group->p2p->cfg->dev_addr);
 228         p2p_group_add_noa(ie, group->noa);
 229         p2p_buf_update_ie_hdr(ie, len);
 230
 231         return ie;
 232 }
 233
 234
 235 #ifdef CONFIG_WIFI_DISPLAY
 236
 237 struct wpabuf * p2p_group_get_wfd_ie(struct p2p_group *g)
 238 {
 239         return g->wfd_ie;
 240 }
 241
 242
 243 struct wpabuf * wifi_display_encaps(struct wpabuf *subelems)
 244 {
 245         struct wpabuf *ie;
 246         const u8 *pos, *end;
 247
 248         if (subelems == NULL)
 249                 return NULL;
 250
 251         ie = wpabuf_alloc(wpabuf_len(subelems) + 100);
 252         if (ie == NULL)
 253                 return NULL;
 254
 255         pos = wpabuf_head(subelems);
 256         end = pos + wpabuf_len(subelems);
 257
 258         while (end > pos) {
 259                 size_t frag_len = end - pos;
 260                 if (frag_len > 251)
 261                         frag_len = 251;
 262                 wpabuf_put_u8(ie, WLAN_EID_VENDOR_SPECIFIC);
 263                 wpabuf_put_u8(ie, 4 + frag_len);
 264                 wpabuf_put_be32(ie, WFD_IE_VENDOR_TYPE);
 265                 wpabuf_put_data(ie, pos, frag_len);
 266                 pos += frag_len;
 267         }
 268
 269         return ie;
 270 }
 271
 272
 273 static int wifi_display_add_dev_info_descr(struct wpabuf *buf,
 274                                            struct p2p_group_member *m)
 275 {
 276         const u8 *pos, *end;
 277         const u8 *dev_info = NULL;
 278         const u8 *assoc_bssid = NULL;
 279         const u8 *coupled_sink = NULL;
 280         u8 zero_addr[ETH_ALEN];
 281
 282         if (m->wfd_ie == NULL)
 283                 return 0;
 284
 285         os_memset(zero_addr, 0, ETH_ALEN);
 286         pos = wpabuf_head_u8(m->wfd_ie);
 287         end = pos + wpabuf_len(m->wfd_ie);
 288         while (pos + 1 < end) {
 289                 u8 id;
 290                 u16 len;
 291
 292                 id = *pos++;
 293                 len = WPA_GET_BE16(pos);
 294                 pos += 2;
 295                 if (pos + len > end)
 296                         break;
 297
 298                 switch (id) {
 299                 case WFD_SUBELEM_DEVICE_INFO:
 300                         if (len < 6)
 301                                 break;
 302                         dev_info = pos;
 303                         break;
 304                 case WFD_SUBELEM_ASSOCIATED_BSSID:
 305                         if (len < ETH_ALEN)
 306                                 break;
 307                         assoc_bssid = pos;
 308                         break;
 309                 case WFD_SUBELEM_COUPLED_SINK:
 310                         if (len < 1 + ETH_ALEN)
 311                                 break;
 312                         coupled_sink = pos;
 313                         break;
 314                 }
 315
 316                 pos += len;
 317         }
 318
 319         if (dev_info == NULL)
 320                 return 0;
 321
 322         wpabuf_put_u8(buf, 23);
 323         wpabuf_put_data(buf, m->dev_addr, ETH_ALEN);
 324         if (assoc_bssid)
 325                 wpabuf_put_data(buf, assoc_bssid, ETH_ALEN);
 326         else
 327                 wpabuf_put_data(buf, zero_addr, ETH_ALEN);
 328         wpabuf_put_data(buf, dev_info, 2); /* WFD Device Info */
 329         wpabuf_put_data(buf, dev_info + 4, 2); /* WFD Device Max Throughput */
 330         if (coupled_sink) {
 331                 wpabuf_put_data(buf, coupled_sink, 1 + ETH_ALEN);
 332         } else {
 333                 wpabuf_put_u8(buf, 0);
 334                 wpabuf_put_data(buf, zero_addr, ETH_ALEN);
 335         }
 336
 337         return 1;
 338 }
 339
 340
 341 static struct wpabuf *
 342 wifi_display_build_go_ie(struct p2p_group *group)
 343 {
 344         struct wpabuf *wfd_subelems, *wfd_ie;
 345         struct p2p_group_member *m;
 346         u8 *len;
 347         unsigned int count = 0;
 348
 349         if (!group->p2p->wfd_ie_probe_resp)
 350                 return NULL;
 351
 352         wfd_subelems = wpabuf_alloc(wpabuf_len(group->p2p->wfd_ie_probe_resp) +
 353                                     group->num_members * 24 + 100);
 354         if (wfd_subelems == NULL)
 355                 return NULL;
 356         if (group->p2p->wfd_dev_info)
 357                 wpabuf_put_buf(wfd_subelems, group->p2p->wfd_dev_info);
 358         if (group->p2p->wfd_assoc_bssid)
 359                 wpabuf_put_buf(wfd_subelems,
 360                                group->p2p->wfd_assoc_bssid);
 361         if (group->p2p->wfd_coupled_sink_info)
 362                 wpabuf_put_buf(wfd_subelems,
 363                                group->p2p->wfd_coupled_sink_info);
 364
 365         /* Build WFD Session Info */
 366         wpabuf_put_u8(wfd_subelems, WFD_SUBELEM_SESSION_INFO);
 367         len = wpabuf_put(wfd_subelems, 2);
 368         m = group->members;
 369         while (m) {
 370                 if (wifi_display_add_dev_info_descr(wfd_subelems, m))
 371                         count++;
 372                 m = m->next;
 373         }
 374
 375         if (count == 0) {
 376                 /* No Wi-Fi Display clients - do not include subelement */
 377                 wfd_subelems->used -= 3;
 378         } else {
 379                 WPA_PUT_BE16(len, (u8 *) wpabuf_put(wfd_subelems, 0) - len -
 380                              2);
 381                 wpa_printf(MSG_DEBUG, "WFD: WFD Session Info: %u descriptors",
 382                            count);
 383         }
 384
 385         wfd_ie = wifi_display_encaps(wfd_subelems);
 386         wpabuf_free(wfd_subelems);
 387
 388         return wfd_ie;
 389 }
 390
 391 static void wifi_display_group_update(struct p2p_group *group)
 392 {
 393         wpabuf_free(group->wfd_ie);
 394         group->wfd_ie = wifi_display_build_go_ie(group);
 395 }
 396
 397 #endif /* CONFIG_WIFI_DISPLAY */
 398
 399
 400 static struct wpabuf * p2p_group_build_probe_resp_ie(struct p2p_group *group)
 401 {
 402         u8 *group_info;
 403         struct wpabuf *p2p_subelems, *ie;
 404         struct p2p_group_member *m;
 405
 406         p2p_subelems = wpabuf_alloc(500);
 407         if (p2p_subelems == NULL)
 408                 return NULL;
 409
 410         p2p_group_add_common_ies(group, p2p_subelems);
 411         p2p_group_add_noa(p2p_subelems, group->noa);
 412
 413         /* P2P Device Info */
 414         p2p_buf_add_device_info(p2p_subelems, group->p2p, NULL);
 415
 416         /* P2P Group Info */
 417         group_info = wpabuf_put(p2p_subelems, 0);
 418         wpabuf_put_u8(p2p_subelems, P2P_ATTR_GROUP_INFO);
 419         wpabuf_put_le16(p2p_subelems, 0); /* Length to be filled */
 420         for (m = group->members; m; m = m->next)
 421                 p2p_client_info(p2p_subelems, m);
 422         WPA_PUT_LE16(group_info + 1,
 423                      (u8 *) wpabuf_put(p2p_subelems, 0) - group_info - 3);
 424
 425         ie = p2p_group_encaps_probe_resp(p2p_subelems);
 426         wpabuf_free(p2p_subelems);
 427
 428 #ifdef CONFIG_WIFI_DISPLAY
 429         if (group->wfd_ie) {
 430                 struct wpabuf *wfd = wpabuf_dup(group->wfd_ie);
 431                 ie = wpabuf_concat(wfd, ie);
 432         }
 433 #endif /* CONFIG_WIFI_DISPLAY */
 434
 435         return ie;
 436 }
 437
 438
 439 void p2p_group_update_ies(struct p2p_group *group)
 440 {
 441         struct wpabuf *beacon_ie;
 442         struct wpabuf *probe_resp_ie;
 443
 444 #ifdef CONFIG_WIFI_DISPLAY
 445         wifi_display_group_update(group);
 446 #endif /* CONFIG_WIFI_DISPLAY */
 447
 448         probe_resp_ie = p2p_group_build_probe_resp_ie(group);
 449         if (probe_resp_ie == NULL)
 450                 return;
 451         wpa_hexdump_buf(MSG_MSGDUMP, "P2P: Update GO Probe Response P2P IE",
 452                         probe_resp_ie);
 453
 454         if (group->beacon_update) {
 455                 beacon_ie = p2p_group_build_beacon_ie(group);
 456                 if (beacon_ie)
 457                         group->beacon_update = 0;
 458                 wpa_hexdump_buf(MSG_MSGDUMP, "P2P: Update GO Beacon P2P IE",
 459                                 beacon_ie);
 460         } else
 461                 beacon_ie = NULL;
 462
 463         group->cfg->ie_update(group->cfg->cb_ctx, beacon_ie, probe_resp_ie);
 464 }
 465
 466
 467 /**
 468  * p2p_build_client_info - Build P2P Client Info Descriptor
 469  * @addr: MAC address of the peer device
 470  * @p2p_ie: P2P IE from (Re)Association Request
 471  * @dev_capab: Buffer for returning Device Capability
 472  * @dev_addr: Buffer for returning P2P Device Address
 473  * Returns: P2P Client Info Descriptor or %NULL on failure
 474  *
 475  * This function builds P2P Client Info Descriptor based on the information
 476  * available from (Re)Association Request frame. Group owner can use this to
 477  * build the P2P Group Info attribute for Probe Response frames.
 478  */
 479 static struct wpabuf * p2p_build_client_info(const u8 *addr,
 480                                              struct wpabuf *p2p_ie,
 481                                              u8 *dev_capab, u8 *dev_addr)
 482 {
 483         const u8 *spos;
 484         struct p2p_message msg;
 485         u8 *len_pos;
 486         struct wpabuf *buf;
 487
 488         if (p2p_ie == NULL)
 489                 return NULL;
 490
 491         os_memset(&msg, 0, sizeof(msg));
 492         if (p2p_parse_p2p_ie(p2p_ie, &msg) ||
 493             msg.capability == NULL || msg.p2p_device_info == NULL)
 494                 return NULL;
 495
 496         buf = wpabuf_alloc(ETH_ALEN + 1 + 1 + msg.p2p_device_info_len);
 497         if (buf == NULL)
 498                 return NULL;
 499
 500         *dev_capab = msg.capability[0];
 501         os_memcpy(dev_addr, msg.p2p_device_addr, ETH_ALEN);
 502
 503         spos = msg.p2p_device_info; /* P2P Device address */
 504
 505         /* P2P Client Info Descriptor */
 506         /* Length to be set */
 507         len_pos = wpabuf_put(buf, 1);
 508         /* P2P Device address */
 509         wpabuf_put_data(buf, spos, ETH_ALEN);
 510         /* P2P Interface address */
 511         wpabuf_put_data(buf, addr, ETH_ALEN);
 512         /* Device Capability Bitmap */
 513         wpabuf_put_u8(buf, msg.capability[0]);
 514         /*
 515          * Config Methods, Primary Device Type, Number of Secondary Device
 516          * Types, Secondary Device Type List, Device Name copied from
 517          * Device Info
 518          */
 519         wpabuf_put_data(buf, spos + ETH_ALEN,
 520                         msg.p2p_device_info_len - ETH_ALEN);
 521
 522         *len_pos = wpabuf_len(buf) - 1;
 523
 524
 525         return buf;
 526 }
 527
 528
 529 static int p2p_group_remove_member(struct p2p_group *group, const u8 *addr)
 530 {
 531         struct p2p_group_member *m, *prev;
 532
 533         if (group == NULL)
 534                 return 0;
 535
 536         m = group->members;
 537         prev = NULL;
 538         while (m) {
 539                 if (os_memcmp(m->addr, addr, ETH_ALEN) == 0)
 540                         break;
 541                 prev = m;
 542                 m = m->next;
 543         }
 544
 545         if (m == NULL)
 546                 return 0;
 547
 548         if (prev)
 549                 prev->next = m->next;
 550         else
 551                 group->members = m->next;
 552         p2p_group_free_member(m);
 553         group->num_members--;
 554
 555         return 1;
 556 }
 557
 558
 559 int p2p_group_notif_assoc(struct p2p_group *group, const u8 *addr,
 560                           const u8 *ie, size_t len)
 561 {
 562         struct p2p_group_member *m;
 563
 564         if (group == NULL)
 565                 return -1;
 566
 567         m = os_zalloc(sizeof(*m));
 568         if (m == NULL)
 569                 return -1;
 570         os_memcpy(m->addr, addr, ETH_ALEN);
 571         m->p2p_ie = ieee802_11_vendor_ie_concat(ie, len, P2P_IE_VENDOR_TYPE);
 572         if (m->p2p_ie) {
 573                 m->client_info = p2p_build_client_info(addr, m->p2p_ie,
 574                                                        &m->dev_capab,
 575                                                        m->dev_addr);
 576         }
 577 #ifdef CONFIG_WIFI_DISPLAY
 578         m->wfd_ie = ieee802_11_vendor_ie_concat(ie, len, WFD_IE_VENDOR_TYPE);
 579 #endif /* CONFIG_WIFI_DISPLAY */
 580
 581         p2p_group_remove_member(group, addr);
 582
 583         m->next = group->members;
 584         group->members = m;
 585         group->num_members++;
 586         wpa_msg(group->p2p->cfg->msg_ctx, MSG_DEBUG, "P2P: Add client " MACSTR
 587                 " to group (p2p=%d wfd=%d client_info=%d); num_members=%u/%u",
 588                 MAC2STR(addr), m->p2p_ie ? 1 : 0, m->wfd_ie ? 1 : 0,
 589                 m->client_info ? 1 : 0,
 590                 group->num_members, group->cfg->max_clients);
 591         if (group->num_members == group->cfg->max_clients)
 592                 group->beacon_update = 1;
 593         p2p_group_update_ies(group);
 594         if (group->num_members == 1)
 595                 group->cfg->idle_update(group->cfg->cb_ctx, 0);
 596
 597         return 0;
 598 }
 599
 600
 601 struct wpabuf * p2p_group_assoc_resp_ie(struct p2p_group *group, u8 status)
 602 {
 603         struct wpabuf *resp;
 604         u8 *rlen;
 605         size_t extra = 0;
 606
 607 #ifdef CONFIG_WIFI_DISPLAY
 608         if (group->wfd_ie)
 609                 extra = wpabuf_len(group->wfd_ie);
 610 #endif /* CONFIG_WIFI_DISPLAY */
 611
 612         /*
 613          * (Re)Association Response - P2P IE
 614          * Status attribute (shall be present when association request is
 615          *      denied)
 616          * Extended Listen Timing (may be present)
 617          */
 618         resp = wpabuf_alloc(20 + extra);
 619         if (resp == NULL)
 620                 return NULL;
 621
 622 #ifdef CONFIG_WIFI_DISPLAY
 623         if (group->wfd_ie)
 624                 wpabuf_put_buf(resp, group->wfd_ie);
 625 #endif /* CONFIG_WIFI_DISPLAY */
 626
 627         rlen = p2p_buf_add_ie_hdr(resp);
 628         if (status != P2P_SC_SUCCESS)
 629                 p2p_buf_add_status(resp, status);
 630         p2p_buf_update_ie_hdr(resp, rlen);
 631
 632         return resp;
 633 }
 634
 635
 636 void p2p_group_notif_disassoc(struct p2p_group *group, const u8 *addr)
 637 {
 638         if (p2p_group_remove_member(group, addr)) {
 639                 wpa_msg(group->p2p->cfg->msg_ctx, MSG_DEBUG, "P2P: Remove "
 640                         "client " MACSTR " from group; num_members=%u/%u",
 641                         MAC2STR(addr), group->num_members,
 642                         group->cfg->max_clients);
 643                 if (group->num_members == group->cfg->max_clients - 1)
 644                         group->beacon_update = 1;
 645                 p2p_group_update_ies(group);
 646                 if (group->num_members == 0)
 647                         group->cfg->idle_update(group->cfg->cb_ctx, 1);
 648         }
 649 }
 650
 651
 652 /**
 653  * p2p_match_dev_type_member - Match client device type with requested type
 654  * @m: Group member
 655  * @wps: WPS TLVs from Probe Request frame (concatenated WPS IEs)
 656  * Returns: 1 on match, 0 on mismatch
 657  *
 658  * This function can be used to match the Requested Device Type attribute in
 659  * WPS IE with the device types of a group member for deciding whether a GO
 660  * should reply to a Probe Request frame.
 661  */
 662 static int p2p_match_dev_type_member(struct p2p_group_member *m,
 663                                      struct wpabuf *wps)
 664 {
 665         const u8 *pos, *end;
 666         struct wps_parse_attr attr;
 667         u8 num_sec;
 668
 669         if (m->client_info == NULL || wps == NULL)
 670                 return 0;
 671
 672         pos = wpabuf_head(m->client_info);
 673         end = pos + wpabuf_len(m->client_info);
 674
 675         pos += 1 + 2 * ETH_ALEN + 1 + 2;
 676         if (end - pos < WPS_DEV_TYPE_LEN + 1)
 677                 return 0;
 678
 679         if (wps_parse_msg(wps, &attr))
 680                 return 1; /* assume no Requested Device Type attributes */
 681
 682         if (attr.num_req_dev_type == 0)
 683                 return 1; /* no Requested Device Type attributes -> match */
 684
 685         if (dev_type_list_match(pos, attr.req_dev_type, attr.num_req_dev_type))
 686                 return 1; /* Match with client Primary Device Type */
 687
 688         pos += WPS_DEV_TYPE_LEN;
 689         num_sec = *pos++;
 690         if (end - pos < num_sec * WPS_DEV_TYPE_LEN)
 691                 return 0;
 692         while (num_sec > 0) {
 693                 num_sec--;
 694                 if (dev_type_list_match(pos, attr.req_dev_type,
 695                                         attr.num_req_dev_type))
 696                         return 1; /* Match with client Secondary Device Type */
 697                 pos += WPS_DEV_TYPE_LEN;
 698         }
 699
 700         /* No matching device type found */
 701         return 0;
 702 }
 703
 704
 705 int p2p_group_match_dev_type(struct p2p_group *group, struct wpabuf *wps)
 706 {
 707         struct p2p_group_member *m;
 708
 709         if (p2p_match_dev_type(group->p2p, wps))
 710                 return 1; /* Match with own device type */
 711
 712         for (m = group->members; m; m = m->next) {
 713                 if (p2p_match_dev_type_member(m, wps))
 714                         return 1; /* Match with group client device type */
 715         }
 716
 717         /* No match with Requested Device Type */
 718         return 0;
 719 }
 720
 721
 722 int p2p_group_match_dev_id(struct p2p_group *group, struct wpabuf *p2p)
 723 {
 724         struct p2p_group_member *m;
 725         struct p2p_message msg;
 726
 727         os_memset(&msg, 0, sizeof(msg));
 728         if (p2p_parse_p2p_ie(p2p, &msg))
 729                 return 1; /* Failed to parse - assume no filter on Device ID */
 730
 731         if (!msg.device_id)
 732                 return 1; /* No filter on Device ID */
 733
 734         if (os_memcmp(msg.device_id, group->p2p->cfg->dev_addr, ETH_ALEN) == 0)
 735                 return 1; /* Match with our P2P Device Address */
 736
 737         for (m = group->members; m; m = m->next) {
 738                 if (os_memcmp(msg.device_id, m->dev_addr, ETH_ALEN) == 0)
 739                         return 1; /* Match with group client P2P Device Address */
 740         }
 741
 742         /* No match with Device ID */
 743         return 0;
 744 }
 745
 746
 747 void p2p_group_notif_formation_done(struct p2p_group *group)
 748 {
 749         if (group == NULL)
 750                 return;
 751         group->group_formation = 0;
 752         group->beacon_update = 1;
 753         p2p_group_update_ies(group);
 754 }
 755
 756
 757 int p2p_group_notif_noa(struct p2p_group *group, const u8 *noa,
 758                         size_t noa_len)
 759 {
 760         if (noa == NULL) {
 761                 wpabuf_free(group->noa);
 762                 group->noa = NULL;
 763         } else {
 764                 if (group->noa) {
 765                         if (wpabuf_size(group->noa) >= noa_len) {
 766                                 group->noa->used = 0;
 767                                 wpabuf_put_data(group->noa, noa, noa_len);
 768                         } else {
 769                                 wpabuf_free(group->noa);
 770                                 group->noa = NULL;
 771                         }
 772                 }
 773
 774                 if (!group->noa) {
 775                         group->noa = wpabuf_alloc_copy(noa, noa_len);
 776                         if (group->noa == NULL)
 777                                 return -1;
 778                 }
 779         }
 780
 781         group->beacon_update = 1;
 782         p2p_group_update_ies(group);
 783         return 0;
 784 }
 785
 786
 787 static struct p2p_group_member * p2p_group_get_client(struct p2p_group *group,
 788                                                       const u8 *dev_id)
 789 {
 790         struct p2p_group_member *m;
 791
 792         for (m = group->members; m; m = m->next) {
 793                 if (os_memcmp(dev_id, m->dev_addr, ETH_ALEN) == 0)
 794                         return m;
 795         }
 796
 797         return NULL;
 798 }
 799
 800
 801 static struct p2p_group_member * p2p_group_get_client_iface(
 802         struct p2p_group *group, const u8 *interface_addr)
 803 {
 804         struct p2p_group_member *m;
 805
 806         for (m = group->members; m; m = m->next) {
 807                 if (os_memcmp(interface_addr, m->addr, ETH_ALEN) == 0)
 808                         return m;
 809         }
 810
 811         return NULL;
 812 }
 813
 814
 815 const u8 * p2p_group_get_dev_addr(struct p2p_group *group, const u8 *addr)
 816 {
 817         struct p2p_group_member *m;
 818
 819         if (group == NULL)
 820                 return NULL;
 821         m = p2p_group_get_client_iface(group, addr);
 822         if (m && !is_zero_ether_addr(m->dev_addr))
 823                 return m->dev_addr;
 824         return NULL;
 825 }
 826
 827
 828 static struct wpabuf * p2p_build_go_disc_req(void)
 829 {
 830         struct wpabuf *buf;
 831
 832         buf = wpabuf_alloc(100);
 833         if (buf == NULL)
 834                 return NULL;
 835
 836         p2p_buf_add_action_hdr(buf, P2P_GO_DISC_REQ, 0);
 837
 838         return buf;
 839 }
 840
 841
 842 int p2p_group_go_discover(struct p2p_group *group, const u8 *dev_id,
 843                           const u8 *searching_dev, int rx_freq)
 844 {
 845         struct p2p_group_member *m;
 846         struct wpabuf *req;
 847         struct p2p_data *p2p = group->p2p;
 848         int freq;
 849
 850         m = p2p_group_get_client(group, dev_id);
 851         if (m == NULL || m->client_info == NULL) {
 852                 wpa_printf(MSG_DEBUG, "P2P: Requested client was not in this "
 853                            "group " MACSTR,
 854                            MAC2STR(group->cfg->interface_addr));
 855                 return -1;
 856         }
 857
 858         if (!(m->dev_capab & P2P_DEV_CAPAB_CLIENT_DISCOVERABILITY)) {
 859                 wpa_printf(MSG_DEBUG, "P2P: Requested client does not support "
 860                            "client discoverability");
 861                 return -1;
 862         }
 863
 864         wpa_printf(MSG_DEBUG, "P2P: Schedule GO Discoverability Request to be "
 865                    "sent to " MACSTR, MAC2STR(dev_id));
 866
 867         req = p2p_build_go_disc_req();
 868         if (req == NULL)
 869                 return -1;
 870
 871         /* TODO: Should really use group operating frequency here */
 872         freq = rx_freq;
 873
 874         p2p->pending_action_state = P2P_PENDING_GO_DISC_REQ;
 875         if (p2p->cfg->send_action(p2p->cfg->cb_ctx, freq, m->addr,
 876                                   group->cfg->interface_addr,
 877                                   group->cfg->interface_addr,
 878                                   wpabuf_head(req), wpabuf_len(req), 200) < 0)
 879         {
 880                 wpa_msg(p2p->cfg->msg_ctx, MSG_DEBUG,
 881                         "P2P: Failed to send Action frame");
 882         }
 883
 884         wpabuf_free(req);
 885
 886         return 0;
 887 }
 888
 889
 890 const u8 * p2p_group_get_interface_addr(struct p2p_group *group)
 891 {
 892         return group->cfg->interface_addr;
 893 }
 894
 895
 896 u8 p2p_group_presence_req(struct p2p_group *group,
 897                           const u8 *client_interface_addr,
 898                           const u8 *noa, size_t noa_len)
 899 {
 900         struct p2p_group_member *m;
 901         u8 curr_noa[50];
 902         int curr_noa_len;
 903
 904         m = p2p_group_get_client_iface(group, client_interface_addr);
 905         if (m == NULL || m->client_info == NULL) {
 906                 wpa_printf(MSG_DEBUG, "P2P: Client was not in this group");
 907                 return P2P_SC_FAIL_UNABLE_TO_ACCOMMODATE;
 908         }
 909
 910         wpa_hexdump(MSG_DEBUG, "P2P: Presence Request NoA", noa, noa_len);
 911
 912         if (group->p2p->cfg->get_noa)
 913                 curr_noa_len = group->p2p->cfg->get_noa(
 914                         group->p2p->cfg->cb_ctx, group->cfg->interface_addr,
 915                         curr_noa, sizeof(curr_noa));
 916         else
 917                 curr_noa_len = -1;
 918         if (curr_noa_len < 0)
 919                 wpa_printf(MSG_DEBUG, "P2P: Failed to fetch current NoA");
 920         else if (curr_noa_len == 0)
 921                 wpa_printf(MSG_DEBUG, "P2P: No NoA being advertized");
 922         else
 923                 wpa_hexdump(MSG_DEBUG, "P2P: Current NoA", curr_noa,
 924                             curr_noa_len);
 925
 926         /* TODO: properly process request and store copy */
 927         if (curr_noa_len > 0 || curr_noa_len == -1)
 928                 return P2P_SC_FAIL_UNABLE_TO_ACCOMMODATE;
 929
 930         return P2P_SC_SUCCESS;
 931 }
 932
 933
 934 unsigned int p2p_get_group_num_members(struct p2p_group *group)
 935 {
 936         return group->num_members;
 937 }
 938
 939
 940 const u8 * p2p_iterate_group_members(struct p2p_group *group, void **next)
 941 {
 942         struct p2p_group_member *iter = *next;
 943
 944         if (!iter)
 945                 iter = group->members;
 946         else
 947                 iter = iter->next;
 948
 949         *next = iter;
 950
 951         if (!iter)
 952                 return NULL;
 953
 954         return iter->addr;
 955 }
 956
 957
 958 int p2p_group_is_client_connected(struct p2p_group *group, const u8 *dev_addr)
 959 {
 960         struct p2p_group_member *m;
 961
 962         for (m = group->members; m; m = m->next) {
 963                 if (os_memcmp(m->dev_addr, dev_addr, ETH_ALEN) == 0)
 964                         return 1;
 965         }
 966
 967         return 0;
 968 }
 969
 970
 971 int p2p_group_is_group_id_match(struct p2p_group *group, const u8 *group_id,
 972                                 size_t group_id_len)
 973 {
 974         if (group_id_len != ETH_ALEN + group->cfg->ssid_len)
 975                 return 0;
 976         if (os_memcmp(group_id, group->p2p->cfg->dev_addr, ETH_ALEN) != 0)
 977                 return 0;
 978         return os_memcmp(group_id + ETH_ALEN, group->cfg->ssid,
 979                          group->cfg->ssid_len) == 0;
 980 }