tests/hwsim/test_p2p_persistent.py

   1 # P2P persistent group test cases
   2 # Copyright (c) 2013-2014, Jouni Malinen <j@w1.fi>
   3 #
   4 # This software may be distributed under the terms of the BSD license.
   5 # See README for more details.
   6
   7 import logging
   8 logger = logging.getLogger()
   9 import re
  10 import time
  11
  12 import hwsim_utils
  13 from test_p2p_autogo import connect_cli
  14
  15 def go_neg_pin_authorized_persistent(i_dev, r_dev, i_intent=None, r_intent=None, i_method='enter', r_method='display', test_data=True):
  16     r_dev.p2p_listen()
  17     i_dev.p2p_listen()
  18     pin = r_dev.wps_read_pin()
  19     logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  20     r_dev.p2p_go_neg_auth(i_dev.p2p_dev_addr(), pin, r_method,
  21                           go_intent=r_intent, persistent=True)
  22     r_dev.p2p_listen()
  23     i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), pin, i_method,
  24                                   timeout=20, go_intent=i_intent,
  25                                   persistent=True)
  26     r_res = r_dev.p2p_go_neg_auth_result()
  27     logger.debug("i_res: " + str(i_res))
  28     logger.debug("r_res: " + str(r_res))
  29     r_dev.dump_monitor()
  30     i_dev.dump_monitor()
  31     logger.info("Group formed")
  32     if test_data:
  33         hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
  34     return [i_res, r_res]
  35
  36 def terminate_group(go, cli):
  37     logger.info("Terminate persistent group")
  38     go.remove_group()
  39     cli.wait_go_ending_session()
  40
  41 def invite(inv, resp, extra=None, persistent_reconnect=True):
  42     addr = resp.p2p_dev_addr()
  43     if persistent_reconnect:
  44         resp.global_request("SET persistent_reconnect 1")
  45     else:
  46         resp.global_request("SET persistent_reconnect 0")
  47     resp.p2p_listen()
  48     if not inv.discover_peer(addr, social=True):
  49         raise Exception("Peer " + addr + " not found")
  50     inv.dump_monitor()
  51     peer = inv.get_peer(addr)
  52     cmd = "P2P_INVITE persistent=" + peer['persistent'] + " peer=" + addr
  53     if extra:
  54         cmd = cmd + " " + extra;
  55     inv.global_request(cmd)
  56
  57 def check_result(go, cli):
  58     ev = go.wait_global_event(["P2P-GROUP-STARTED"], timeout=30)
  59     if ev is None:
  60         raise Exception("Timeout on group re-invocation (on GO)")
  61     if "[PERSISTENT]" not in ev:
  62         raise Exception("Re-invoked group not marked persistent")
  63     go_res = go.group_form_result(ev)
  64     if go_res['role'] != 'GO':
  65         raise Exception("Persistent group GO did not become GO")
  66     if not go_res['persistent']:
  67         raise Exception("Persistent group not re-invoked as persistent (GO)")
  68     ev = cli.wait_global_event(["P2P-GROUP-STARTED"], timeout=30)
  69     if ev is None:
  70         raise Exception("Timeout on group re-invocation (on client)")
  71     if "[PERSISTENT]" not in ev:
  72         raise Exception("Re-invoked group not marked persistent")
  73     cli_res = cli.group_form_result(ev)
  74     if cli_res['role'] != 'client':
  75         raise Exception("Persistent group client did not become client")
  76     if not cli_res['persistent']:
  77         raise Exception("Persistent group not re-invoked as persistent (cli)")
  78     return [go_res, cli_res]
  79
  80 def form(go, cli, test_data=True, reverse_init=False):
  81     logger.info("Form a persistent group")
  82     if reverse_init:
  83         [i_res, r_res] = go_neg_pin_authorized_persistent(i_dev=cli, i_intent=0,
  84                                                           r_dev=go, r_intent=15,
  85                                                           test_data=test_data)
  86     else:
  87         [i_res, r_res] = go_neg_pin_authorized_persistent(i_dev=go, i_intent=15,
  88                                                           r_dev=cli, r_intent=0,
  89                                                           test_data=test_data)
  90     if not i_res['persistent'] or not r_res['persistent']:
  91         raise Exception("Formed group was not persistent")
  92     terminate_group(go, cli)
  93     if reverse_init:
  94         return r_res
  95     else:
  96         return i_res
  97
  98 def invite_from_cli(go, cli):
  99     logger.info("Re-invoke persistent group from client")
 100     invite(cli, go)
 101     [go_res, cli_res] = check_result(go, cli)
 102     hwsim_utils.test_connectivity_p2p(go, cli)
 103     terminate_group(go, cli)
 104     return [go_res, cli_res]
 105
 106 def invite_from_go(go, cli):
 107     logger.info("Re-invoke persistent group from GO")
 108     invite(go, cli)
 109     [go_res, cli_res] = check_result(go, cli)
 110     hwsim_utils.test_connectivity_p2p(go, cli)
 111     terminate_group(go, cli)
 112     return [go_res, cli_res]
 113
 114 def test_persistent_group(dev):
 115     """P2P persistent group formation and re-invocation"""
 116     form(dev[0], dev[1])
 117     invite_from_cli(dev[0], dev[1])
 118     invite_from_go(dev[0], dev[1])
 119
 120     logger.info("Remove group on the client and try to invite from GO")
 121     id = None
 122     for n in dev[0].list_networks():
 123         if "[P2P-PERSISTENT]" in n['flags']:
 124             id = n['id']
 125             break
 126     if id is None:
 127         raise Exception("Could not find persistent group entry")
 128     clients = dev[0].request("GET_NETWORK " + id + " p2p_client_list").rstrip()
 129     if dev[1].p2p_dev_addr() not in clients:
 130         raise Exception("Peer missing from client list")
 131     if "FAIL" not in dev[1].request("SELECT_NETWORK " + str(id)):
 132         raise Exception("SELECT_NETWORK succeeded unexpectedly")
 133     if "FAIL" not in dev[1].request("SELECT_NETWORK 1234567"):
 134         raise Exception("SELECT_NETWORK succeeded unexpectedly(2)")
 135     if "FAIL" not in dev[1].request("ENABLE_NETWORK " + str(id)):
 136         raise Exception("ENABLE_NETWORK succeeded unexpectedly")
 137     if "FAIL" not in dev[1].request("ENABLE_NETWORK 1234567"):
 138         raise Exception("ENABLE_NETWORK succeeded unexpectedly(2)")
 139     if "FAIL" not in dev[1].request("DISABLE_NETWORK " + str(id)):
 140         raise Exception("DISABLE_NETWORK succeeded unexpectedly")
 141     if "FAIL" not in dev[1].request("DISABLE_NETWORK 1234567"):
 142         raise Exception("DISABLE_NETWORK succeeded unexpectedly(2)")
 143     if "FAIL" not in dev[1].request("REMOVE_NETWORK 1234567"):
 144         raise Exception("REMOVE_NETWORK succeeded unexpectedly")
 145     dev[1].request("REMOVE_NETWORK all")
 146     if len(dev[1].list_networks()) > 0:
 147         raise Exception("Unexpected network block remaining")
 148     invite(dev[0], dev[1])
 149     ev = dev[0].wait_global_event(["P2P-INVITATION-RESULT"], timeout=10)
 150     if ev is None:
 151         raise Exception("No invitation result seen")
 152     if "status=8" not in ev:
 153         raise Exception("Unexpected invitation result: " + ev)
 154     clients = dev[0].request("GET_NETWORK " + id + " p2p_client_list").rstrip()
 155     if dev[1].p2p_dev_addr() in clients:
 156         raise Exception("Peer was still in client list")
 157
 158 def test_persistent_group2(dev):
 159     """P2P persistent group formation with reverse roles"""
 160     form(dev[0], dev[1], reverse_init=True)
 161     invite_from_cli(dev[0], dev[1])
 162     invite_from_go(dev[0], dev[1])
 163
 164 def test_persistent_group3(dev):
 165     """P2P persistent group formation and re-invocation with empty BSS table"""
 166     form(dev[0], dev[1])
 167     dev[1].request("BSS_FLUSH 0")
 168     invite_from_cli(dev[0], dev[1])
 169     dev[1].request("BSS_FLUSH 0")
 170     invite_from_go(dev[0], dev[1])
 171
 172 def test_persistent_group_per_sta_psk(dev):
 173     """P2P persistent group formation and re-invocation using per-client PSK"""
 174     addr0 = dev[0].p2p_dev_addr()
 175     addr1 = dev[1].p2p_dev_addr()
 176     addr2 = dev[2].p2p_dev_addr()
 177     dev[0].request("P2P_SET per_sta_psk 1")
 178     logger.info("Form a persistent group")
 179     [i_res, r_res] = go_neg_pin_authorized_persistent(i_dev=dev[0], i_intent=15,
 180                                                       r_dev=dev[1], r_intent=0)
 181     if not i_res['persistent'] or not r_res['persistent']:
 182         raise Exception("Formed group was not persistent")
 183
 184     logger.info("Join another client to the group")
 185     pin = dev[2].wps_read_pin()
 186     dev[0].p2p_go_authorize_client(pin)
 187     c_res = dev[2].p2p_connect_group(addr0, pin, timeout=60, social=True,
 188                                      freq=i_res['freq'])
 189     if not c_res['persistent']:
 190         raise Exception("Joining client did not recognize persistent group")
 191     if r_res['psk'] == c_res['psk']:
 192         raise Exception("Same PSK assigned for both clients")
 193     hwsim_utils.test_connectivity_p2p_sta(dev[1], dev[2])
 194
 195     logger.info("Remove persistent group and re-start it manually")
 196     dev[0].remove_group()
 197     dev[1].wait_go_ending_session()
 198     dev[2].wait_go_ending_session()
 199     dev[0].dump_monitor()
 200     dev[1].dump_monitor()
 201     dev[2].dump_monitor()
 202
 203     for i in range(0, 3):
 204         networks = dev[i].list_networks()
 205         if len(networks) != 1:
 206             raise Exception("Unexpected number of networks")
 207         if "[P2P-PERSISTENT]" not in networks[0]['flags']:
 208             raise Exception("Not the persistent group data")
 209         if i > 0:
 210             # speed up testing by avoiding use of the old BSS entry since the
 211             # GO may have changed channels
 212             dev[i].request("BSS_FLUSH 0")
 213             dev[i].scan(freq="2412", only_new=True)
 214         if "OK" not in dev[i].global_request("P2P_GROUP_ADD persistent=" + networks[0]['id'] + " freq=2412"):
 215             raise Exception("Could not re-start persistent group")
 216         ev = dev[i].wait_global_event(["P2P-GROUP-STARTED"], timeout=30)
 217         if ev is None:
 218             raise Exception("Timeout on group restart")
 219
 220     logger.info("Leave persistent group and rejoin it")
 221     dev[2].remove_group()
 222     ev = dev[2].wait_event(["P2P-GROUP-REMOVED"], timeout=3)
 223     if ev is None:
 224         raise Exception("Group removal event timed out")
 225     if not dev[2].discover_peer(addr0, social=True):
 226         raise Exception("Peer " + peer + " not found")
 227     dev[2].dump_monitor()
 228     peer = dev[2].get_peer(addr0)
 229     dev[2].global_request("P2P_GROUP_ADD persistent=" + peer['persistent'] + " freq=2412")
 230     ev = dev[2].wait_global_event(["P2P-GROUP-STARTED"], timeout=30)
 231     if ev is None:
 232         raise Exception("Timeout on group restart (on client)")
 233     cli_res = dev[2].group_form_result(ev)
 234     if not cli_res['persistent']:
 235         raise Exception("Persistent group not restarted as persistent (cli)")
 236     hwsim_utils.test_connectivity_p2p(dev[1], dev[2])
 237
 238     logger.info("Remove one of the clients from the group without removing persistent group information for the client")
 239     dev[0].global_request("P2P_REMOVE_CLIENT iface=" + dev[2].p2p_interface_addr())
 240     dev[2].wait_go_ending_session()
 241
 242     logger.info("Try to reconnect after having been removed from group (but persistent group info still present)")
 243     if not dev[2].discover_peer(addr0, social=True):
 244         raise Exception("Peer " + peer + " not found")
 245     dev[2].dump_monitor()
 246     peer = dev[2].get_peer(addr0)
 247     dev[2].global_request("P2P_GROUP_ADD persistent=" + peer['persistent'] + " freq=2412")
 248     ev = dev[2].wait_global_event(["P2P-GROUP-STARTED","WPA: 4-Way Handshake failed"], timeout=30)
 249     if ev is None:
 250         raise Exception("Timeout on group restart (on client)")
 251     if "P2P-GROUP-STARTED" not in ev:
 252         raise Exception("Connection failed")
 253
 254     logger.info("Remove one of the clients from the group")
 255     dev[0].global_request("P2P_REMOVE_CLIENT " + addr2)
 256     dev[2].wait_go_ending_session()
 257
 258     logger.info("Try to reconnect after having been removed from group")
 259     if not dev[2].discover_peer(addr0, social=True):
 260         raise Exception("Peer " + peer + " not found")
 261     dev[2].dump_monitor()
 262     peer = dev[2].get_peer(addr0)
 263     dev[2].global_request("P2P_GROUP_ADD persistent=" + peer['persistent'] + " freq=2412")
 264     ev = dev[2].wait_global_event(["P2P-GROUP-STARTED","WPA: 4-Way Handshake failed"], timeout=30)
 265     if ev is None:
 266         raise Exception("Timeout on group restart (on client)")
 267     if "P2P-GROUP-STARTED" in ev:
 268         raise Exception("Client managed to connect after being removed")
 269
 270     logger.info("Remove the remaining client from the group")
 271     dev[0].global_request("P2P_REMOVE_CLIENT " + addr1)
 272     dev[1].wait_go_ending_session()
 273
 274     logger.info("Terminate persistent group")
 275     dev[0].remove_group()
 276     dev[0].dump_monitor()
 277
 278     logger.info("Try to re-invoke persistent group from client")
 279     dev[0].global_request("SET persistent_reconnect 1")
 280     dev[0].p2p_listen()
 281     if not dev[1].discover_peer(addr0, social=True):
 282         raise Exception("Peer " + peer + " not found")
 283     dev[1].dump_monitor()
 284     peer = dev[1].get_peer(addr0)
 285     dev[1].global_request("P2P_INVITE persistent=" + peer['persistent'] + " peer=" + addr0)
 286     ev = dev[1].wait_global_event(["P2P-GROUP-STARTED","WPA: 4-Way Handshake failed"], timeout=30)
 287     if ev is None:
 288         raise Exception("Timeout on group restart (on client)")
 289     if "P2P-GROUP-STARTED" in ev:
 290         raise Exception("Client managed to re-invoke after being removed")
 291     dev[0].dump_monitor()
 292
 293     logger.info("Terminate persistent group")
 294     dev[0].remove_group()
 295     dev[0].dump_monitor()
 296
 297 def test_persistent_group_invite_removed_client(dev):
 298     """P2P persistent group client removal and re-invitation"""
 299     addr0 = dev[0].p2p_dev_addr()
 300     addr1 = dev[1].p2p_dev_addr()
 301     dev[0].request("P2P_SET per_sta_psk 1")
 302     logger.info("Form a persistent group")
 303     [i_res, r_res] = go_neg_pin_authorized_persistent(i_dev=dev[0], i_intent=15,
 304                                                       r_dev=dev[1], r_intent=0)
 305     if not i_res['persistent'] or not r_res['persistent']:
 306         raise Exception("Formed group was not persistent")
 307
 308     logger.info("Remove client from the group")
 309     dev[0].global_request("P2P_REMOVE_CLIENT " + addr1)
 310     dev[1].wait_go_ending_session()
 311
 312     logger.info("Re-invite the removed client to join the group")
 313     dev[1].p2p_listen()
 314     if not dev[0].discover_peer(addr1, social=True):
 315         raise Exception("Peer " + peer + " not found")
 316     dev[0].global_request("P2P_INVITE group=" + dev[0].group_ifname + " peer=" + addr1)
 317     ev = dev[1].wait_global_event(["P2P-INVITATION-RECEIVED"], timeout=10)
 318     if ev is None:
 319         raise Exception("Timeout on invitation")
 320     if "sa=" + addr0 + " persistent=" not in ev:
 321         raise Exception("Unexpected invitation event")
 322     [event,addr,persistent] = ev.split(' ', 2)
 323     dev[1].global_request("P2P_GROUP_ADD " + persistent)
 324     ev = dev[1].wait_global_event(["P2P-PERSISTENT-PSK-FAIL"], timeout=30)
 325     if ev is None:
 326         raise Exception("Did not receive PSK failure report")
 327     [tmp,id] = ev.split('=', 1)
 328     ev = dev[1].wait_global_event(["P2P-GROUP-REMOVED"], timeout=10)
 329     if ev is None:
 330         raise Exception("Group removal event timed out")
 331     if "reason=PSK_FAILURE" not in ev:
 332         raise Exception("Unexpected group removal reason")
 333     dev[1].request("REMOVE_NETWORK " + id)
 334
 335     logger.info("Re-invite after client removed persistent group info")
 336     dev[1].p2p_listen()
 337     if not dev[0].discover_peer(addr1, social=True):
 338         raise Exception("Peer " + peer + " not found")
 339     dev[0].global_request("P2P_INVITE group=" + dev[0].group_ifname + " peer=" + addr1)
 340     ev = dev[1].wait_global_event(["P2P-INVITATION-RECEIVED"], timeout=10)
 341     if ev is None:
 342         raise Exception("Timeout on invitation")
 343     if " persistent=" in ev:
 344         raise Exception("Unexpected invitation event")
 345     pin = dev[1].wps_read_pin()
 346     dev[0].p2p_go_authorize_client(pin)
 347     c_res = dev[1].p2p_connect_group(addr0, pin, timeout=60, social=True,
 348                                      freq=i_res['freq'])
 349     if not c_res['persistent']:
 350         raise Exception("Joining client did not recognize persistent group")
 351     if r_res['psk'] == c_res['psk']:
 352         raise Exception("Same PSK assigned on both times")
 353     hwsim_utils.test_connectivity_p2p(dev[0], dev[1])
 354
 355     terminate_group(dev[0], dev[1])
 356
 357 def test_persistent_group_channel(dev):
 358     """P2P persistent group re-invocation with channel selection"""
 359     form(dev[0], dev[1], test_data=False)
 360
 361     logger.info("Re-invoke persistent group from client with forced channel")
 362     invite(dev[1], dev[0], "freq=2427")
 363     [go_res, cli_res] = check_result(dev[0], dev[1])
 364     if go_res['freq'] != "2427":
 365         raise Exception("Persistent group client forced channel not followed")
 366     terminate_group(dev[0], dev[1])
 367
 368     logger.info("Re-invoke persistent group from GO with forced channel")
 369     invite(dev[0], dev[1], "freq=2432")
 370     [go_res, cli_res] = check_result(dev[0], dev[1])
 371     if go_res['freq'] != "2432":
 372         raise Exception("Persistent group GO channel preference not followed")
 373     terminate_group(dev[0], dev[1])
 374
 375     logger.info("Re-invoke persistent group from client with channel preference")
 376     invite(dev[1], dev[0], "pref=2417")
 377     [go_res, cli_res] = check_result(dev[0], dev[1])
 378     if go_res['freq'] != "2417":
 379         raise Exception("Persistent group client channel preference not followed")
 380     terminate_group(dev[0], dev[1])
 381
 382 def test_persistent_group_and_role_change(dev):
 383     """P2P persistent group, auto GO in another role, and re-invocation"""
 384     form(dev[0], dev[1])
 385
 386     logger.info("Start and stop autonomous GO on previous P2P client device")
 387     dev[1].p2p_start_go()
 388     dev[1].remove_group()
 389     dev[1].dump_monitor()
 390
 391     logger.info("Re-invoke the persistent group")
 392     invite_from_go(dev[0], dev[1])
 393
 394 def test_persistent_go_client_list(dev):
 395     """P2P GO and list of clients in persistent group"""
 396     addr0 = dev[0].p2p_dev_addr()
 397     addr1 = dev[1].p2p_dev_addr()
 398     addr2 = dev[2].p2p_dev_addr()
 399
 400     res = dev[0].p2p_start_go(persistent=True)
 401     id = None
 402     for n in dev[0].list_networks():
 403         if "[P2P-PERSISTENT]" in n['flags']:
 404             id = n['id']
 405             break
 406     if id is None:
 407         raise Exception("Could not find persistent group entry")
 408
 409     connect_cli(dev[0], dev[1], social=True, freq=res['freq'])
 410     clients = dev[0].request("GET_NETWORK " + id + " p2p_client_list").rstrip()
 411     if clients != addr1:
 412         raise Exception("Unexpected p2p_client_list entry(2): " + clients)
 413     connect_cli(dev[0], dev[2], social=True, freq=res['freq'])
 414     clients = dev[0].request("GET_NETWORK " + id + " p2p_client_list").rstrip()
 415     if clients != addr2 + " " + addr1:
 416         raise Exception("Unexpected p2p_client_list entry(3): " + clients)
 417
 418     peer = dev[1].get_peer(res['go_dev_addr'])
 419     dev[1].remove_group()
 420     dev[1].request("P2P_GROUP_ADD persistent=" + peer['persistent'])
 421     ev = dev[1].wait_global_event(["P2P-GROUP-STARTED"], timeout=30)
 422     if ev is None:
 423         raise Exception("Timeout on group restart (on client)")
 424     clients = dev[0].request("GET_NETWORK " + id + " p2p_client_list").rstrip()
 425     if clients != addr1 + " " + addr2:
 426         raise Exception("Unexpected p2p_client_list entry(4): " + clients)
 427
 428     dev[2].remove_group()
 429     dev[1].remove_group()
 430     dev[0].remove_group()
 431
 432     clients = dev[0].request("GET_NETWORK " + id + " p2p_client_list").rstrip()
 433     if clients != addr1 + " " + addr2:
 434         raise Exception("Unexpected p2p_client_list entry(5): " + clients)
 435
 436     dev[1].p2p_listen()
 437     dev[2].p2p_listen()
 438     dev[0].request("P2P_FLUSH")
 439     dev[0].discover_peer(addr1, social=True)
 440     peer = dev[0].get_peer(addr1)
 441     if 'persistent' not in peer or peer['persistent'] != id:
 442         raise Exception("Persistent group client not recognized(1)")
 443
 444     dev[0].discover_peer(addr2, social=True)
 445     peer = dev[0].get_peer(addr2)
 446     if 'persistent' not in peer or peer['persistent'] != id:
 447         raise Exception("Persistent group client not recognized(2)")
 448
 449 def test_persistent_group_in_grpform(dev):
 450     """P2P persistent group parameters re-used in group formation"""
 451     addr0 = dev[0].p2p_dev_addr()
 452     addr1 = dev[1].p2p_dev_addr()
 453     form(dev[0], dev[1])
 454     dev[1].p2p_listen()
 455     if not dev[0].discover_peer(addr1, social=True):
 456         raise Exception("Could not discover peer")
 457     peer = dev[0].get_peer(addr1)
 458     if "persistent" not in peer:
 459         raise Exception("Could not map peer to a persistent group")
 460
 461     pin = dev[1].wps_read_pin()
 462     dev[1].p2p_go_neg_auth(addr0, pin, "display", go_intent=0)
 463     i_res = dev[0].p2p_go_neg_init(addr1, pin, "enter", timeout=20,
 464                                    go_intent=15,
 465                                    persistent_id=peer['persistent'])
 466     r_res = dev[1].p2p_go_neg_auth_result()
 467     logger.debug("i_res: " + str(i_res))
 468     logger.debug("r_res: " + str(r_res))
 469
 470 def test_persistent_group_without_persistent_reconnect(dev):
 471     """P2P persistent group re-invocation without persistent reconnect"""
 472     form(dev[0], dev[1])
 473     dev[0].dump_monitor()
 474     dev[1].dump_monitor()
 475
 476     logger.info("Re-invoke persistent group from client")
 477     invite(dev[1], dev[0], persistent_reconnect=False)
 478
 479     ev = dev[0].wait_global_event(["P2P-INVITATION-RECEIVED"], timeout=15)
 480     if ev is None:
 481         raise Exception("No invitation request reported");
 482     if "persistent=" not in ev:
 483         raise Exception("Invalid invitation type reported: " + ev)
 484
 485     ev2 = dev[1].wait_global_event(["P2P-INVITATION-RESULT"], timeout=15)
 486     if ev2 is None:
 487         raise Exception("No invitation response reported");
 488     if "status=1" not in ev2:
 489         raise Exception("Unexpected status: " + ev2)
 490     dev[1].p2p_listen()
 491
 492     exp = r'<.>(P2P-INVITATION-RECEIVED) sa=([0-9a-f:]*) persistent=([0-9]*) freq=([0-9]*)'
 493     s = re.split(exp, ev)
 494     if len(s) < 5:
 495         raise Exception("Could not parse invitation event")
 496     sa = s[2]
 497     id = s[3]
 498     freq = s[4]
 499     logger.info("Invalid P2P_INVITE test coverage")
 500     if "FAIL" not in dev[0].global_request("P2P_INVITE persistent=" + id + " peer=" + sa + " freq=0"):
 501         raise Exception("Invalid P2P_INVITE accepted")
 502     if "FAIL" not in dev[0].global_request("P2P_INVITE persistent=" + id + " peer=" + sa + " pref=0"):
 503         raise Exception("Invalid P2P_INVITE accepted")
 504     logger.info("Re-initiate invitation based on upper layer acceptance")
 505     if "OK" not in dev[0].global_request("P2P_INVITE persistent=" + id + " peer=" + sa + " freq=" + freq):
 506         raise Exception("Invitation command failed")
 507     [go_res, cli_res] = check_result(dev[0], dev[1])
 508     if go_res['freq'] != freq:
 509         raise Exception("Unexpected channel on GO: {} MHz, expected {} MHz".format(go_res['freq'], freq))
 510     if cli_res['freq'] != freq:
 511         raise Exception("Unexpected channel on CLI: {} MHz, expected {} MHz".format(cli_res['freq'], freq))
 512     terminate_group(dev[0], dev[1])
 513     dev[0].dump_monitor()
 514     dev[1].dump_monitor()
 515
 516     logger.info("Re-invoke persistent group from GO")
 517     invite(dev[0], dev[1], persistent_reconnect=False)
 518
 519     ev = dev[1].wait_global_event(["P2P-INVITATION-RECEIVED"], timeout=15)
 520     if ev is None:
 521         raise Exception("No invitation request reported");
 522     if "persistent=" not in ev:
 523         raise Exception("Invalid invitation type reported: " + ev)
 524
 525     ev2 = dev[0].wait_global_event(["P2P-INVITATION-RESULT"], timeout=15)
 526     if ev2 is None:
 527         raise Exception("No invitation response reported");
 528     if "status=1" not in ev2:
 529         raise Exception("Unexpected status: " + ev2)
 530     dev[0].p2p_listen()
 531
 532     exp = r'<.>(P2P-INVITATION-RECEIVED) sa=([0-9a-f:]*) persistent=([0-9]*)'
 533     s = re.split(exp, ev)
 534     if len(s) < 4:
 535         raise Exception("Could not parse invitation event")
 536     sa = s[2]
 537     id = s[3]
 538     logger.info("Re-initiate invitation based on upper layer acceptance")
 539     if "OK" not in dev[1].global_request("P2P_INVITE persistent=" + id + " peer=" + sa + " freq=" + freq):
 540         raise Exception("Invitation command failed")
 541     [go_res, cli_res] = check_result(dev[0], dev[1])
 542     terminate_group(dev[0], dev[1])
 543
 544 def test_persistent_group_already_running(dev):
 545     """P2P persistent group formation and invitation while GO already running"""
 546     form(dev[0], dev[1])
 547     peer = dev[1].get_peer(dev[0].p2p_dev_addr())
 548     listen_freq = peer['listen_freq']
 549     dev[0].dump_monitor()
 550     dev[1].dump_monitor()
 551     networks = dev[0].list_networks()
 552     if len(networks) != 1:
 553         raise Exception("Unexpected number of networks")
 554     if "[P2P-PERSISTENT]" not in networks[0]['flags']:
 555         raise Exception("Not the persistent group data")
 556     if "OK" not in dev[0].global_request("P2P_GROUP_ADD persistent=" + networks[0]['id'] + " freq=" + listen_freq):
 557         raise Exception("Could not state GO")
 558     invite_from_cli(dev[0], dev[1])
 559
 560 def test_persistent_group_add_cli_chan(dev):
 561     """P2P persistent group formation and re-invocation with p2p_add_cli_chan=1"""
 562     dev[0].request("SET p2p_add_cli_chan 1")
 563     dev[1].request("SET p2p_add_cli_chan 1")
 564     form(dev[0], dev[1])
 565     dev[1].request("BSS_FLUSH 0")
 566     dev[1].scan(freq="2412", only_new=True)
 567     dev[1].scan(freq="2437", only_new=True)
 568     dev[1].scan(freq="2462", only_new=True)
 569     dev[1].request("BSS_FLUSH 0")
 570     invite_from_cli(dev[0], dev[1])
 571     invite_from_go(dev[0], dev[1])
 572
 573 def test_persistent_invalid_group_add(dev):
 574     """Invalid P2P_GROUP_ADD command"""
 575     id = dev[0].add_network()
 576     if "FAIL" not in dev[0].global_request("P2P_GROUP_ADD persistent=12345"):
 577         raise Exception("Invalid P2P_GROUP_ADD accepted")
 578     if "FAIL" not in dev[0].global_request("P2P_GROUP_ADD persistent=%d" % id):
 579         raise Exception("Invalid P2P_GROUP_ADD accepted")
 580     if "FAIL" not in dev[0].global_request("P2P_GROUP_ADD foo"):
 581         raise Exception("Invalid P2P_GROUP_ADD accepted")