tests/hwsim/test_p2p_grpform.py

   1 #!/usr/bin/python
   2 #
   3 # P2P group formation test cases
   4 # Copyright (c) 2013-2014, Jouni Malinen <j@w1.fi>
   5 #
   6 # This software may be distributed under the terms of the BSD license.
   7 # See README for more details.
   8
   9 import logging
  10 logger = logging.getLogger()
  11 import time
  12 import threading
  13 import Queue
  14
  15 import hwsim_utils
  16 import utils
  17
  18 def check_grpform_results(i_res, r_res):
  19     if i_res['result'] != 'success' or r_res['result'] != 'success':
  20         raise Exception("Failed group formation")
  21     if i_res['ssid'] != r_res['ssid']:
  22         raise Exception("SSID mismatch")
  23     if i_res['freq'] != r_res['freq']:
  24         raise Exception("freq mismatch")
  25     if 'go_neg_freq' in r_res and i_res['go_neg_freq'] != r_res['go_neg_freq']:
  26         raise Exception("go_neg_freq mismatch")
  27     if i_res['freq'] != i_res['go_neg_freq']:
  28         raise Exception("freq/go_neg_freq mismatch")
  29     if i_res['role'] != i_res['go_neg_role']:
  30         raise Exception("role/go_neg_role mismatch")
  31     if 'go_neg_role' in r_res and r_res['role'] != r_res['go_neg_role']:
  32         raise Exception("role/go_neg_role mismatch")
  33     if i_res['go_dev_addr'] != r_res['go_dev_addr']:
  34         raise Exception("GO Device Address mismatch")
  35
  36 def go_neg_init(i_dev, r_dev, pin, i_method, i_intent, res):
  37     logger.debug("Initiate GO Negotiation from i_dev")
  38     try:
  39         i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), pin, i_method, timeout=20, go_intent=i_intent)
  40         logger.debug("i_res: " + str(i_res))
  41     except Exception, e:
  42         i_res = None
  43         logger.info("go_neg_init thread caught an exception from p2p_go_neg_init: " + str(e))
  44     res.put(i_res)
  45
  46 def go_neg_pin(i_dev, r_dev, i_intent=None, r_intent=None, i_method='enter', r_method='display'):
  47     r_dev.p2p_listen()
  48     i_dev.p2p_listen()
  49     pin = r_dev.wps_read_pin()
  50     logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  51     r_dev.dump_monitor()
  52     res = Queue.Queue()
  53     t = threading.Thread(target=go_neg_init, args=(i_dev, r_dev, pin, i_method, i_intent, res))
  54     t.start()
  55     logger.debug("Wait for GO Negotiation Request on r_dev")
  56     ev = r_dev.wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=15)
  57     if ev is None:
  58         raise Exception("GO Negotiation timed out")
  59     r_dev.dump_monitor()
  60     logger.debug("Re-initiate GO Negotiation from r_dev")
  61     r_res = r_dev.p2p_go_neg_init(i_dev.p2p_dev_addr(), pin, r_method, go_intent=r_intent, timeout=20)
  62     logger.debug("r_res: " + str(r_res))
  63     r_dev.dump_monitor()
  64     t.join()
  65     i_res = res.get()
  66     if i_res is None:
  67         raise Exception("go_neg_init thread failed")
  68     logger.debug("i_res: " + str(i_res))
  69     logger.info("Group formed")
  70     hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
  71     i_dev.dump_monitor()
  72     return [i_res, r_res]
  73
  74 def go_neg_pin_authorized(i_dev, r_dev, i_intent=None, r_intent=None, expect_failure=False, i_go_neg_status=None, i_method='enter', r_method='display', test_data=True, i_freq=None, r_freq=None):
  75     r_dev.p2p_listen()
  76     i_dev.p2p_listen()
  77     pin = r_dev.wps_read_pin()
  78     logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  79     r_dev.p2p_go_neg_auth(i_dev.p2p_dev_addr(), pin, r_method, go_intent=r_intent, freq=r_freq)
  80     i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), pin, i_method, timeout=20, go_intent=i_intent, expect_failure=expect_failure, freq=i_freq)
  81     r_res = r_dev.p2p_go_neg_auth_result(expect_failure=expect_failure)
  82     logger.debug("i_res: " + str(i_res))
  83     logger.debug("r_res: " + str(r_res))
  84     r_dev.dump_monitor()
  85     i_dev.dump_monitor()
  86     if i_go_neg_status:
  87         if i_res['result'] != 'go-neg-failed':
  88             raise Exception("Expected GO Negotiation failure not reported")
  89         if i_res['status'] != i_go_neg_status:
  90             raise Exception("Expected GO Negotiation status not seen")
  91     if expect_failure:
  92         return
  93     logger.info("Group formed")
  94     if test_data:
  95         hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
  96     return [i_res, r_res]
  97
  98 def go_neg_init_pbc(i_dev, r_dev, i_intent, res, freq):
  99     logger.debug("Initiate GO Negotiation from i_dev")
 100     try:
 101         i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), None, "pbc",
 102                                       timeout=20, go_intent=i_intent, freq=freq)
 103         logger.debug("i_res: " + str(i_res))
 104     except Exception, e:
 105         i_res = None
 106         logger.info("go_neg_init_pbc thread caught an exception from p2p_go_neg_init: " + str(e))
 107     res.put(i_res)
 108
 109 def go_neg_pbc(i_dev, r_dev, i_intent=None, r_intent=None, i_freq=None, r_freq=None):
 110     r_dev.p2p_find(social=True)
 111     i_dev.p2p_find(social=True)
 112     logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
 113     r_dev.dump_monitor()
 114     res = Queue.Queue()
 115     t = threading.Thread(target=go_neg_init_pbc, args=(i_dev, r_dev, i_intent, res, i_freq))
 116     t.start()
 117     logger.debug("Wait for GO Negotiation Request on r_dev")
 118     ev = r_dev.wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=15)
 119     if ev is None:
 120         raise Exception("GO Negotiation timed out")
 121     r_dev.dump_monitor()
 122     logger.debug("Re-initiate GO Negotiation from r_dev")
 123     r_res = r_dev.p2p_go_neg_init(i_dev.p2p_dev_addr(), None, "pbc",
 124                                   go_intent=r_intent, timeout=20, freq=r_freq)
 125     logger.debug("r_res: " + str(r_res))
 126     r_dev.dump_monitor()
 127     t.join()
 128     i_res = res.get()
 129     if i_res is None:
 130         raise Exception("go_neg_init_pbc thread failed")
 131     logger.debug("i_res: " + str(i_res))
 132     logger.info("Group formed")
 133     hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
 134     i_dev.dump_monitor()
 135     return [i_res, r_res]
 136
 137 def remove_group(dev1, dev2):
 138     dev1.remove_group()
 139     try:
 140         dev2.remove_group()
 141     except:
 142         pass
 143
 144 def test_grpform(dev):
 145     """P2P group formation using PIN and authorized connection (init -> GO)"""
 146     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 147                                            r_dev=dev[1], r_intent=0)
 148     check_grpform_results(i_res, r_res)
 149     remove_group(dev[0], dev[1])
 150
 151 def test_grpform_a(dev):
 152     """P2P group formation using PIN and authorized connection (init -> GO) (init: group iface)"""
 153     dev[0].request("SET p2p_no_group_iface 0")
 154     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 155                                            r_dev=dev[1], r_intent=0)
 156     if "p2p-wlan" not in i_res['ifname']:
 157         raise Exception("Unexpected group interface name")
 158     check_grpform_results(i_res, r_res)
 159     remove_group(dev[0], dev[1])
 160     if i_res['ifname'] in utils.get_ifnames():
 161         raise Exception("Group interface netdev was not removed")
 162
 163 def test_grpform_b(dev):
 164     """P2P group formation using PIN and authorized connection (init -> GO) (resp: group iface)"""
 165     dev[1].request("SET p2p_no_group_iface 0")
 166     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 167                                            r_dev=dev[1], r_intent=0)
 168     if "p2p-wlan" not in r_res['ifname']:
 169         raise Exception("Unexpected group interface name")
 170     check_grpform_results(i_res, r_res)
 171     remove_group(dev[0], dev[1])
 172     if r_res['ifname'] in utils.get_ifnames():
 173         raise Exception("Group interface netdev was not removed")
 174
 175 def test_grpform_c(dev):
 176     """P2P group formation using PIN and authorized connection (init -> GO) (group iface)"""
 177     dev[0].request("SET p2p_no_group_iface 0")
 178     dev[1].request("SET p2p_no_group_iface 0")
 179     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 180                                            r_dev=dev[1], r_intent=0)
 181     if "p2p-wlan" not in i_res['ifname']:
 182         raise Exception("Unexpected group interface name")
 183     if "p2p-wlan" not in r_res['ifname']:
 184         raise Exception("Unexpected group interface name")
 185     check_grpform_results(i_res, r_res)
 186     remove_group(dev[0], dev[1])
 187     if i_res['ifname'] in utils.get_ifnames():
 188         raise Exception("Group interface netdev was not removed")
 189     if r_res['ifname'] in utils.get_ifnames():
 190         raise Exception("Group interface netdev was not removed")
 191
 192 def test_grpform2(dev):
 193     """P2P group formation using PIN and authorized connection (resp -> GO)"""
 194     go_neg_pin_authorized(i_dev=dev[0], i_intent=0, r_dev=dev[1], r_intent=15)
 195     remove_group(dev[0], dev[1])
 196
 197 def test_grpform2_c(dev):
 198     """P2P group formation using PIN and authorized connection (resp -> GO) (group iface)"""
 199     dev[0].request("SET p2p_no_group_iface 0")
 200     dev[1].request("SET p2p_no_group_iface 0")
 201     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0, r_dev=dev[1], r_intent=15)
 202     remove_group(dev[0], dev[1])
 203     if i_res['ifname'] in utils.get_ifnames():
 204         raise Exception("Group interface netdev was not removed")
 205     if r_res['ifname'] in utils.get_ifnames():
 206         raise Exception("Group interface netdev was not removed")
 207
 208 def test_grpform3(dev):
 209     """P2P group formation using PIN and re-init GO Negotiation"""
 210     go_neg_pin(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
 211     remove_group(dev[0], dev[1])
 212
 213 def test_grpform3_c(dev):
 214     """P2P group formation using PIN and re-init GO Negotiation (group iface)"""
 215     dev[0].request("SET p2p_no_group_iface 0")
 216     dev[1].request("SET p2p_no_group_iface 0")
 217     [i_res, r_res] = go_neg_pin(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
 218     remove_group(dev[0], dev[1])
 219     if i_res['ifname'] in utils.get_ifnames():
 220         raise Exception("Group interface netdev was not removed")
 221     if r_res['ifname'] in utils.get_ifnames():
 222         raise Exception("Group interface netdev was not removed")
 223
 224 def test_grpform_pbc(dev):
 225     """P2P group formation using PBC and re-init GO Negotiation"""
 226     [i_res, r_res] = go_neg_pbc(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
 227     check_grpform_results(i_res, r_res)
 228     if i_res['role'] != 'GO' or r_res['role'] != 'client':
 229         raise Exception("Unexpected device roles")
 230     remove_group(dev[0], dev[1])
 231
 232 def test_both_go_intent_15(dev):
 233     """P2P GO Negotiation with both devices using GO intent 15"""
 234     go_neg_pin_authorized(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=15, expect_failure=True, i_go_neg_status=9)
 235
 236 def test_both_go_neg_display(dev):
 237     """P2P GO Negotiation with both devices trying to display PIN"""
 238     go_neg_pin_authorized(i_dev=dev[0], r_dev=dev[1], expect_failure=True, i_go_neg_status=10, i_method='display', r_method='display')
 239
 240 def test_both_go_neg_enter(dev):
 241     """P2P GO Negotiation with both devices trying to enter PIN"""
 242     go_neg_pin_authorized(i_dev=dev[0], r_dev=dev[1], expect_failure=True, i_go_neg_status=10, i_method='enter', r_method='enter')
 243
 244 def test_grpform_per_sta_psk(dev):
 245     """P2P group formation with per-STA PSKs"""
 246     dev[0].request("P2P_SET per_sta_psk 1")
 247     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
 248     check_grpform_results(i_res, r_res)
 249
 250     pin = dev[2].wps_read_pin()
 251     dev[0].p2p_go_authorize_client(pin)
 252     c_res = dev[2].p2p_connect_group(dev[0].p2p_dev_addr(), pin, timeout=60)
 253     check_grpform_results(i_res, c_res)
 254
 255     if r_res['psk'] == c_res['psk']:
 256         raise Exception("Same PSK assigned for both clients")
 257
 258     hwsim_utils.test_connectivity_p2p(dev[1], dev[2])
 259
 260     dev[0].remove_group()
 261     dev[1].wait_go_ending_session()
 262     dev[2].wait_go_ending_session()
 263
 264 def test_grpform_per_sta_psk_wps(dev):
 265     """P2P group formation with per-STA PSKs with non-P2P WPS STA"""
 266     dev[0].request("P2P_SET per_sta_psk 1")
 267     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
 268     check_grpform_results(i_res, r_res)
 269
 270     dev[0].p2p_go_authorize_client_pbc()
 271     dev[2].request("WPS_PBC")
 272     ev = dev[2].wait_event(["CTRL-EVENT-CONNECTED"], timeout=30)
 273     if ev is None:
 274         raise Exception("Association with the GO timed out")
 275
 276     hwsim_utils.test_connectivity_p2p_sta(dev[1], dev[2])
 277
 278     dev[0].remove_group()
 279     dev[2].request("DISCONNECT")
 280     dev[1].wait_go_ending_session()
 281
 282 def test_grpform_force_chan_go(dev):
 283     """P2P group formation forced channel selection by GO"""
 284     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 285                                            i_freq=2432,
 286                                            r_dev=dev[1], r_intent=0,
 287                                            test_data=False)
 288     check_grpform_results(i_res, r_res)
 289     if i_res['freq'] != "2432":
 290         raise Exception("Unexpected channel - did not follow GO's forced channel")
 291     remove_group(dev[0], dev[1])
 292
 293 def test_grpform_force_chan_cli(dev):
 294     """P2P group formation forced channel selection by client"""
 295     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
 296                                            i_freq=2417,
 297                                            r_dev=dev[1], r_intent=15,
 298                                            test_data=False)
 299     check_grpform_results(i_res, r_res)
 300     if i_res['freq'] != "2417":
 301         raise Exception("Unexpected channel - did not follow GO's forced channel")
 302     remove_group(dev[0], dev[1])
 303
 304 def test_grpform_force_chan_conflict(dev):
 305     """P2P group formation fails due to forced channel mismatch"""
 306     go_neg_pin_authorized(i_dev=dev[0], i_intent=0, i_freq=2422,
 307                           r_dev=dev[1], r_intent=15, r_freq=2427,
 308                           expect_failure=True, i_go_neg_status=7)
 309
 310 def test_grpform_pref_chan_go(dev):
 311     """P2P group formation preferred channel selection by GO"""
 312     dev[0].request("SET p2p_pref_chan 81:7")
 313     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 314                                            r_dev=dev[1], r_intent=0,
 315                                            test_data=False)
 316     check_grpform_results(i_res, r_res)
 317     if i_res['freq'] != "2442":
 318         raise Exception("Unexpected channel - did not follow GO's p2p_pref_chan")
 319     remove_group(dev[0], dev[1])
 320
 321 def test_grpform_pref_chan_go_overridden(dev):
 322     """P2P group formation preferred channel selection by GO overridden by client"""
 323     dev[1].request("SET p2p_pref_chan 81:7")
 324     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
 325                                            i_freq=2422,
 326                                            r_dev=dev[1], r_intent=15,
 327                                            test_data=False)
 328     check_grpform_results(i_res, r_res)
 329     if i_res['freq'] != "2422":
 330         raise Exception("Unexpected channel - did not follow client's forced channel")
 331     remove_group(dev[0], dev[1])
 332
 333 def test_grpform_no_go_freq_forcing_chan(dev):
 334     """P2P group formation with no-GO freq forcing channel"""
 335     dev[1].request("SET p2p_no_go_freq 100-200,300,4000-6000")
 336     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
 337                                            r_dev=dev[1], r_intent=15,
 338                                            test_data=False)
 339     check_grpform_results(i_res, r_res)
 340     if int(i_res['freq']) > 4000:
 341         raise Exception("Unexpected channel - did not follow no-GO freq")
 342     remove_group(dev[0], dev[1])
 343
 344 def test_grpform_no_go_freq_conflict(dev):
 345     """P2P group formation fails due to no-GO range forced by client"""
 346     dev[1].request("SET p2p_no_go_freq 2000-3000")
 347     go_neg_pin_authorized(i_dev=dev[0], i_intent=0, i_freq=2422,
 348                           r_dev=dev[1], r_intent=15,
 349                           expect_failure=True, i_go_neg_status=7)
 350
 351 def test_grpform_no_5ghz_world_roaming(dev):
 352     """P2P group formation with world roaming regulatory"""
 353     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
 354                                            r_dev=dev[1], r_intent=15,
 355                                            test_data=False)
 356     check_grpform_results(i_res, r_res)
 357     if int(i_res['freq']) > 4000:
 358         raise Exception("Unexpected channel - did not follow world roaming rules")
 359     remove_group(dev[0], dev[1])
 360
 361 def test_grpform_no_5ghz_add_cli(dev):
 362     """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1"""
 363     dev[0].request("SET p2p_add_cli_chan 1")
 364     dev[1].request("SET p2p_add_cli_chan 1")
 365     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
 366                                            r_dev=dev[1], r_intent=14,
 367                                            test_data=False)
 368     check_grpform_results(i_res, r_res)
 369     if int(i_res['freq']) > 4000:
 370         raise Exception("Unexpected channel - did not follow world roaming rules")
 371     remove_group(dev[0], dev[1])
 372
 373 def test_grpform_no_5ghz_add_cli2(dev):
 374     """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1 (reverse)"""
 375     dev[0].request("SET p2p_add_cli_chan 1")
 376     dev[1].request("SET p2p_add_cli_chan 1")
 377     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=14,
 378                                            r_dev=dev[1], r_intent=0,
 379                                            test_data=False)
 380     check_grpform_results(i_res, r_res)
 381     if int(i_res['freq']) > 4000:
 382         raise Exception("Unexpected channel - did not follow world roaming rules")
 383     remove_group(dev[0], dev[1])
 384
 385 def test_grpform_no_5ghz_add_cli3(dev):
 386     """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1 (intent 15)"""
 387     dev[0].request("SET p2p_add_cli_chan 1")
 388     dev[1].request("SET p2p_add_cli_chan 1")
 389     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
 390                                            r_dev=dev[1], r_intent=15,
 391                                            test_data=False)
 392     check_grpform_results(i_res, r_res)
 393     if int(i_res['freq']) > 4000:
 394         raise Exception("Unexpected channel - did not follow world roaming rules")
 395     remove_group(dev[0], dev[1])
 396
 397 def test_grpform_no_5ghz_add_cli4(dev):
 398     """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1 (reverse; intent 15)"""
 399     dev[0].request("SET p2p_add_cli_chan 1")
 400     dev[1].request("SET p2p_add_cli_chan 1")
 401     [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
 402                                            r_dev=dev[1], r_intent=0,
 403                                            test_data=False)
 404     check_grpform_results(i_res, r_res)
 405     if int(i_res['freq']) > 4000:
 406         raise Exception("Unexpected channel - did not follow world roaming rules")
 407     remove_group(dev[0], dev[1])
 408
 409 def test_grpform_incorrect_pin(dev):
 410     """P2P GO Negotiation with incorrect PIN"""
 411     dev[1].p2p_listen()
 412     pin = dev[1].wps_read_pin()
 413     addr1 = dev[1].p2p_dev_addr()
 414     if not dev[0].discover_peer(addr1):
 415         raise Exception("Peer not found")
 416     dev[1].p2p_go_neg_auth(dev[0].p2p_dev_addr(), pin, 'display', go_intent=0)
 417     dev[0].request("P2P_CONNECT " + addr1 + " 00000000 enter go_intent=15")
 418     ev = dev[1].wait_event(["P2P-GROUP-FORMATION-FAILURE"], timeout=10)
 419     if ev is None:
 420         raise Exception("Group formation failure timed out")
 421     ev = dev[0].wait_event(["P2P-GROUP-FORMATION-FAILURE"], timeout=5)
 422     if ev is None:
 423         raise Exception("Group formation failure timed out")
 424
 425 def test_grpform_reject(dev):
 426     """User rejecting group formation attempt by a P2P peer"""
 427     addr0 = dev[0].p2p_dev_addr()
 428     dev[0].p2p_listen()
 429     dev[1].p2p_go_neg_init(addr0, None, "pbc")
 430     ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=15)
 431     if ev is None:
 432         raise Exception("GO Negotiation timed out")
 433     if "FAIL" in dev[0].global_request("P2P_REJECT " + ev.split(' ')[1]):
 434         raise Exception("P2P_REJECT failed")
 435     dev[1].request("P2P_STOP_FIND")
 436     dev[1].p2p_go_neg_init(addr0, None, "pbc")
 437     ev = dev[1].wait_global_event(["GO-NEG-FAILURE"], timeout=10)
 438     if ev is None:
 439         raise Exception("Rejection not reported")
 440     if "status=11" not in ev:
 441         raise Exception("Unexpected status code in rejection")
 442
 443 def test_grpform_pd_no_probe_resp(dev):
 444     """GO Negotiation after PD, but no Probe Response"""
 445     addr0 = dev[0].p2p_dev_addr()
 446     addr1 = dev[1].p2p_dev_addr()
 447     dev[0].p2p_listen()
 448     if not dev[1].discover_peer(addr0):
 449         raise Exception("Peer not found")
 450     dev[1].p2p_stop_find()
 451     dev[0].p2p_stop_find()
 452     peer = dev[0].get_peer(addr1)
 453     if peer['listen_freq'] == '0':
 454         raise Exception("Peer listen frequency not learned from Probe Request")
 455     time.sleep(0.3)
 456     dev[0].request("P2P_FLUSH")
 457     dev[0].p2p_listen()
 458     dev[1].global_request("P2P_PROV_DISC " + addr0 + " display")
 459     ev = dev[0].wait_global_event(["P2P-PROV-DISC-SHOW-PIN"], timeout=5)
 460     if ev is None:
 461         raise Exception("PD Request timed out")
 462     ev = dev[1].wait_global_event(["P2P-PROV-DISC-ENTER-PIN"], timeout=5)
 463     if ev is None:
 464         raise Exception("PD Response timed out")
 465     peer = dev[0].get_peer(addr1)
 466     if peer['listen_freq'] != '0':
 467         raise Exception("Peer listen frequency learned unexpectedly from PD Request")
 468
 469     pin = dev[0].wps_read_pin()
 470     if "FAIL" in dev[1].request("P2P_CONNECT " + addr0 + " " + pin + " enter"):
 471         raise Exception("P2P_CONNECT on initiator failed")
 472     ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=5)
 473     if ev is None:
 474         raise Exception("GO Negotiation start timed out")
 475     peer = dev[0].get_peer(addr1)
 476     if peer['listen_freq'] == '0':
 477         raise Exception("Peer listen frequency not learned from PD followed by GO Neg Req")
 478     if "FAIL" in dev[0].request("P2P_CONNECT " + addr1 + " " + pin + " display"):
 479         raise Exception("P2P_CONNECT on responder failed")
 480     ev = dev[0].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
 481     if ev is None:
 482         raise Exception("Group formation timed out")
 483     ev = dev[1].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
 484     if ev is None:
 485         raise Exception("Group formation timed out")