test_p2p_grpform.py 43 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978
  1. # P2P group formation 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. import logging
  7. logger = logging.getLogger()
  8. import time
  9. import threading
  10. import Queue
  11. import os
  12. import hostapd
  13. import hwsim_utils
  14. import utils
  15. from utils import HwsimSkip
  16. from wpasupplicant import WpaSupplicant
  17. def check_grpform_results(i_res, r_res):
  18. if i_res['result'] != 'success' or r_res['result'] != 'success':
  19. raise Exception("Failed group formation")
  20. if i_res['ssid'] != r_res['ssid']:
  21. raise Exception("SSID mismatch")
  22. if i_res['freq'] != r_res['freq']:
  23. raise Exception("freq mismatch")
  24. if 'go_neg_freq' in r_res and i_res['go_neg_freq'] != r_res['go_neg_freq']:
  25. raise Exception("go_neg_freq mismatch")
  26. if i_res['freq'] != i_res['go_neg_freq']:
  27. raise Exception("freq/go_neg_freq mismatch")
  28. if i_res['role'] != i_res['go_neg_role']:
  29. raise Exception("role/go_neg_role mismatch")
  30. if 'go_neg_role' in r_res and r_res['role'] != r_res['go_neg_role']:
  31. raise Exception("role/go_neg_role mismatch")
  32. if i_res['go_dev_addr'] != r_res['go_dev_addr']:
  33. raise Exception("GO Device Address mismatch")
  34. def go_neg_init(i_dev, r_dev, pin, i_method, i_intent, res):
  35. logger.debug("Initiate GO Negotiation from i_dev")
  36. try:
  37. i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), pin, i_method, timeout=20, go_intent=i_intent)
  38. logger.debug("i_res: " + str(i_res))
  39. except Exception, e:
  40. i_res = None
  41. logger.info("go_neg_init thread caught an exception from p2p_go_neg_init: " + str(e))
  42. res.put(i_res)
  43. def go_neg_pin(i_dev, r_dev, i_intent=None, r_intent=None, i_method='enter', r_method='display'):
  44. r_dev.p2p_listen()
  45. i_dev.p2p_listen()
  46. pin = r_dev.wps_read_pin()
  47. logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  48. r_dev.dump_monitor()
  49. res = Queue.Queue()
  50. t = threading.Thread(target=go_neg_init, args=(i_dev, r_dev, pin, i_method, i_intent, res))
  51. t.start()
  52. logger.debug("Wait for GO Negotiation Request on r_dev")
  53. ev = r_dev.wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=15)
  54. if ev is None:
  55. raise Exception("GO Negotiation timed out")
  56. r_dev.dump_monitor()
  57. logger.debug("Re-initiate GO Negotiation from r_dev")
  58. r_res = r_dev.p2p_go_neg_init(i_dev.p2p_dev_addr(), pin, r_method, go_intent=r_intent, timeout=20)
  59. logger.debug("r_res: " + str(r_res))
  60. r_dev.dump_monitor()
  61. t.join()
  62. i_res = res.get()
  63. if i_res is None:
  64. raise Exception("go_neg_init thread failed")
  65. logger.debug("i_res: " + str(i_res))
  66. logger.info("Group formed")
  67. hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
  68. i_dev.dump_monitor()
  69. return [i_res, r_res]
  70. 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):
  71. i_dev.p2p_listen()
  72. pin = r_dev.wps_read_pin()
  73. logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  74. r_dev.p2p_go_neg_auth(i_dev.p2p_dev_addr(), pin, r_method, go_intent=r_intent, freq=r_freq)
  75. r_dev.p2p_listen()
  76. 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)
  77. r_res = r_dev.p2p_go_neg_auth_result(expect_failure=expect_failure)
  78. logger.debug("i_res: " + str(i_res))
  79. logger.debug("r_res: " + str(r_res))
  80. r_dev.dump_monitor()
  81. i_dev.dump_monitor()
  82. if i_go_neg_status:
  83. if i_res['result'] != 'go-neg-failed':
  84. raise Exception("Expected GO Negotiation failure not reported")
  85. if i_res['status'] != i_go_neg_status:
  86. raise Exception("Expected GO Negotiation status not seen")
  87. if expect_failure:
  88. return
  89. logger.info("Group formed")
  90. if test_data:
  91. hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
  92. return [i_res, r_res]
  93. def go_neg_init_pbc(i_dev, r_dev, i_intent, res, freq, provdisc):
  94. logger.debug("Initiate GO Negotiation from i_dev")
  95. try:
  96. i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), None, "pbc",
  97. timeout=20, go_intent=i_intent, freq=freq,
  98. provdisc=provdisc)
  99. logger.debug("i_res: " + str(i_res))
  100. except Exception, e:
  101. i_res = None
  102. logger.info("go_neg_init_pbc thread caught an exception from p2p_go_neg_init: " + str(e))
  103. res.put(i_res)
  104. def go_neg_pbc(i_dev, r_dev, i_intent=None, r_intent=None, i_freq=None, r_freq=None, provdisc=False, r_listen=False):
  105. if r_listen:
  106. r_dev.p2p_listen()
  107. else:
  108. r_dev.p2p_find(social=True)
  109. i_dev.p2p_find(social=True)
  110. logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  111. r_dev.dump_monitor()
  112. res = Queue.Queue()
  113. t = threading.Thread(target=go_neg_init_pbc, args=(i_dev, r_dev, i_intent, res, i_freq, provdisc))
  114. t.start()
  115. logger.debug("Wait for GO Negotiation Request on r_dev")
  116. ev = r_dev.wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=15)
  117. if ev is None:
  118. raise Exception("GO Negotiation timed out")
  119. r_dev.dump_monitor()
  120. # Allow some time for the GO Neg Resp to go out before initializing new
  121. # GO Negotiation.
  122. time.sleep(0.2)
  123. logger.debug("Re-initiate GO Negotiation from r_dev")
  124. r_res = r_dev.p2p_go_neg_init(i_dev.p2p_dev_addr(), None, "pbc",
  125. go_intent=r_intent, timeout=20, freq=r_freq)
  126. logger.debug("r_res: " + str(r_res))
  127. r_dev.dump_monitor()
  128. t.join()
  129. i_res = res.get()
  130. if i_res is None:
  131. raise Exception("go_neg_init_pbc thread failed")
  132. logger.debug("i_res: " + str(i_res))
  133. logger.info("Group formed")
  134. hwsim_utils.test_connectivity_p2p(r_dev, i_dev)
  135. i_dev.dump_monitor()
  136. return [i_res, r_res]
  137. def go_neg_pbc_authorized(i_dev, r_dev, i_intent=None, r_intent=None,
  138. expect_failure=False, i_freq=None, r_freq=None):
  139. i_dev.p2p_listen()
  140. logger.info("Start GO negotiation " + i_dev.ifname + " -> " + r_dev.ifname)
  141. r_dev.p2p_go_neg_auth(i_dev.p2p_dev_addr(), None, "pbc",
  142. go_intent=r_intent, freq=r_freq)
  143. r_dev.p2p_listen()
  144. i_res = i_dev.p2p_go_neg_init(r_dev.p2p_dev_addr(), None, "pbc", timeout=20,
  145. go_intent=i_intent,
  146. expect_failure=expect_failure, freq=i_freq)
  147. r_res = r_dev.p2p_go_neg_auth_result(expect_failure=expect_failure)
  148. logger.debug("i_res: " + str(i_res))
  149. logger.debug("r_res: " + str(r_res))
  150. r_dev.dump_monitor()
  151. i_dev.dump_monitor()
  152. if expect_failure:
  153. return
  154. logger.info("Group formed")
  155. return [i_res, r_res]
  156. def remove_group(dev1, dev2):
  157. dev1.remove_group()
  158. try:
  159. dev2.remove_group()
  160. except:
  161. pass
  162. def test_grpform(dev):
  163. """P2P group formation using PIN and authorized connection (init -> GO)"""
  164. try:
  165. dev[0].global_request("SET p2p_group_idle 2")
  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. check_grpform_results(i_res, r_res)
  169. dev[1].remove_group()
  170. ev = dev[0].wait_global_event(["P2P-GROUP-REMOVED"], timeout=10)
  171. if ev is None:
  172. raise Exception("GO did not remove group on idle timeout")
  173. if "GO reason=IDLE" not in ev:
  174. raise Exception("Unexpected group removal event: " + ev)
  175. finally:
  176. dev[0].global_request("SET p2p_group_idle 0")
  177. def test_grpform_a(dev):
  178. """P2P group formation using PIN and authorized connection (init -> GO) (init: group iface)"""
  179. dev[0].global_request("SET p2p_no_group_iface 0")
  180. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
  181. r_dev=dev[1], r_intent=0)
  182. if "p2p-wlan" not in i_res['ifname']:
  183. raise Exception("Unexpected group interface name")
  184. check_grpform_results(i_res, r_res)
  185. remove_group(dev[0], dev[1])
  186. if i_res['ifname'] in utils.get_ifnames():
  187. raise Exception("Group interface netdev was not removed")
  188. def test_grpform_b(dev):
  189. """P2P group formation using PIN and authorized connection (init -> GO) (resp: group iface)"""
  190. dev[1].global_request("SET p2p_no_group_iface 0")
  191. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
  192. r_dev=dev[1], r_intent=0)
  193. if "p2p-wlan" not in r_res['ifname']:
  194. raise Exception("Unexpected group interface name")
  195. check_grpform_results(i_res, r_res)
  196. remove_group(dev[0], dev[1])
  197. if r_res['ifname'] in utils.get_ifnames():
  198. raise Exception("Group interface netdev was not removed")
  199. def test_grpform_c(dev):
  200. """P2P group formation using PIN and authorized connection (init -> GO) (group iface)"""
  201. dev[0].global_request("SET p2p_no_group_iface 0")
  202. dev[1].global_request("SET p2p_no_group_iface 0")
  203. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
  204. r_dev=dev[1], r_intent=0)
  205. if "p2p-wlan" not in i_res['ifname']:
  206. raise Exception("Unexpected group interface name")
  207. if "p2p-wlan" not in r_res['ifname']:
  208. raise Exception("Unexpected group interface name")
  209. check_grpform_results(i_res, r_res)
  210. remove_group(dev[0], dev[1])
  211. if i_res['ifname'] in utils.get_ifnames():
  212. raise Exception("Group interface netdev was not removed")
  213. if r_res['ifname'] in utils.get_ifnames():
  214. raise Exception("Group interface netdev was not removed")
  215. def test_grpform2(dev):
  216. """P2P group formation using PIN and authorized connection (resp -> GO)"""
  217. go_neg_pin_authorized(i_dev=dev[0], i_intent=0, r_dev=dev[1], r_intent=15)
  218. remove_group(dev[0], dev[1])
  219. def test_grpform2_c(dev):
  220. """P2P group formation using PIN and authorized connection (resp -> GO) (group iface)"""
  221. dev[0].global_request("SET p2p_no_group_iface 0")
  222. dev[1].global_request("SET p2p_no_group_iface 0")
  223. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0, r_dev=dev[1], r_intent=15)
  224. remove_group(dev[0], dev[1])
  225. if i_res['ifname'] in utils.get_ifnames():
  226. raise Exception("Group interface netdev was not removed")
  227. if r_res['ifname'] in utils.get_ifnames():
  228. raise Exception("Group interface netdev was not removed")
  229. def test_grpform3(dev):
  230. """P2P group formation using PIN and re-init GO Negotiation"""
  231. go_neg_pin(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
  232. remove_group(dev[0], dev[1])
  233. def test_grpform3_c(dev):
  234. """P2P group formation using PIN and re-init GO Negotiation (group iface)"""
  235. dev[0].global_request("SET p2p_no_group_iface 0")
  236. dev[1].global_request("SET p2p_no_group_iface 0")
  237. [i_res, r_res] = go_neg_pin(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
  238. remove_group(dev[0], dev[1])
  239. if i_res['ifname'] in utils.get_ifnames():
  240. raise Exception("Group interface netdev was not removed")
  241. if r_res['ifname'] in utils.get_ifnames():
  242. raise Exception("Group interface netdev was not removed")
  243. def test_grpform_pbc(dev):
  244. """P2P group formation using PBC and re-init GO Negotiation"""
  245. [i_res, r_res] = go_neg_pbc(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
  246. check_grpform_results(i_res, r_res)
  247. if i_res['role'] != 'GO' or r_res['role'] != 'client':
  248. raise Exception("Unexpected device roles")
  249. remove_group(dev[0], dev[1])
  250. def test_grpform_pd(dev):
  251. """P2P group formation with PD-before-GO-Neg workaround"""
  252. [i_res, r_res] = go_neg_pbc(i_dev=dev[0], provdisc=True, r_dev=dev[1], r_listen=True)
  253. check_grpform_results(i_res, r_res)
  254. remove_group(dev[0], dev[1])
  255. def test_grpform_ext_listen(dev):
  256. """P2P group formation with extended listen timing enabled"""
  257. addr0 = dev[0].p2p_dev_addr()
  258. try:
  259. if "FAIL" not in dev[0].global_request("P2P_EXT_LISTEN 100"):
  260. raise Exception("Invalid P2P_EXT_LISTEN accepted")
  261. if "OK" not in dev[0].global_request("P2P_EXT_LISTEN 300 1000"):
  262. raise Exception("Failed to set extended listen timing")
  263. if "OK" not in dev[1].global_request("P2P_EXT_LISTEN 200 40000"):
  264. raise Exception("Failed to set extended listen timing")
  265. [i_res, r_res] = go_neg_pbc(i_dev=dev[0], provdisc=True, r_dev=dev[1],
  266. r_listen=True, i_freq="2417", r_freq="2417",
  267. i_intent=1, r_intent=15)
  268. check_grpform_results(i_res, r_res)
  269. peer1 = dev[0].get_peer(dev[1].p2p_dev_addr())
  270. if peer1['ext_listen_interval'] != "40000":
  271. raise Exception("Extended listen interval not discovered correctly")
  272. if peer1['ext_listen_period'] != "200":
  273. raise Exception("Extended listen period not discovered correctly")
  274. peer0 = dev[1].get_peer(dev[0].p2p_dev_addr())
  275. if peer0['ext_listen_interval'] != "1000":
  276. raise Exception("Extended listen interval not discovered correctly")
  277. if peer0['ext_listen_period'] != "300":
  278. raise Exception("Extended listen period not discovered correctly")
  279. if not dev[2].discover_peer(addr0):
  280. raise Exception("Could not discover peer during ext listen")
  281. remove_group(dev[0], dev[1])
  282. finally:
  283. if "OK" not in dev[0].global_request("P2P_EXT_LISTEN"):
  284. raise Exception("Failed to clear extended listen timing")
  285. if "OK" not in dev[1].global_request("P2P_EXT_LISTEN"):
  286. raise Exception("Failed to clear extended listen timing")
  287. def test_both_go_intent_15(dev):
  288. """P2P GO Negotiation with both devices using GO intent 15"""
  289. 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)
  290. def test_both_go_neg_display(dev):
  291. """P2P GO Negotiation with both devices trying to display PIN"""
  292. 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')
  293. def test_both_go_neg_enter(dev):
  294. """P2P GO Negotiation with both devices trying to enter PIN"""
  295. 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')
  296. def test_go_neg_pbc_vs_pin(dev):
  297. """P2P GO Negotiation with one device using PBC and the other PIN"""
  298. addr0 = dev[0].p2p_dev_addr()
  299. addr1 = dev[1].p2p_dev_addr()
  300. dev[1].p2p_listen()
  301. if not dev[0].discover_peer(addr1):
  302. raise Exception("Could not discover peer")
  303. dev[0].p2p_listen()
  304. if "OK" not in dev[0].request("P2P_CONNECT " + addr1 + " pbc auth"):
  305. raise Exception("Failed to authorize GO Neg")
  306. if not dev[1].discover_peer(addr0):
  307. raise Exception("Could not discover peer")
  308. if "OK" not in dev[1].request("P2P_CONNECT " + addr0 + " 12345670 display"):
  309. raise Exception("Failed to initiate GO Neg")
  310. ev = dev[1].wait_global_event(["P2P-GO-NEG-FAILURE"], timeout=10)
  311. if ev is None:
  312. raise Exception("GO Negotiation failure timed out")
  313. if "status=10" not in ev:
  314. raise Exception("Unexpected failure reason: " + ev)
  315. def test_go_neg_pin_vs_pbc(dev):
  316. """P2P GO Negotiation with one device using PIN and the other PBC"""
  317. addr0 = dev[0].p2p_dev_addr()
  318. addr1 = dev[1].p2p_dev_addr()
  319. dev[1].p2p_listen()
  320. if not dev[0].discover_peer(addr1):
  321. raise Exception("Could not discover peer")
  322. dev[0].p2p_listen()
  323. if "OK" not in dev[0].request("P2P_CONNECT " + addr1 + " 12345670 display auth"):
  324. raise Exception("Failed to authorize GO Neg")
  325. if not dev[1].discover_peer(addr0):
  326. raise Exception("Could not discover peer")
  327. if "OK" not in dev[1].request("P2P_CONNECT " + addr0 + " pbc"):
  328. raise Exception("Failed to initiate GO Neg")
  329. ev = dev[1].wait_global_event(["P2P-GO-NEG-FAILURE"], timeout=10)
  330. if ev is None:
  331. raise Exception("GO Negotiation failure timed out")
  332. if "status=10" not in ev:
  333. raise Exception("Unexpected failure reason: " + ev)
  334. def test_grpform_per_sta_psk(dev):
  335. """P2P group formation with per-STA PSKs"""
  336. dev[0].global_request("P2P_SET per_sta_psk 1")
  337. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
  338. check_grpform_results(i_res, r_res)
  339. pin = dev[2].wps_read_pin()
  340. dev[0].p2p_go_authorize_client(pin)
  341. c_res = dev[2].p2p_connect_group(dev[0].p2p_dev_addr(), pin, timeout=60)
  342. check_grpform_results(i_res, c_res)
  343. if r_res['psk'] == c_res['psk']:
  344. raise Exception("Same PSK assigned for both clients")
  345. hwsim_utils.test_connectivity_p2p(dev[1], dev[2])
  346. dev[0].remove_group()
  347. dev[1].wait_go_ending_session()
  348. dev[2].wait_go_ending_session()
  349. def test_grpform_per_sta_psk_wps(dev):
  350. """P2P group formation with per-STA PSKs with non-P2P WPS STA"""
  351. dev[0].global_request("P2P_SET per_sta_psk 1")
  352. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15, r_dev=dev[1], r_intent=0)
  353. check_grpform_results(i_res, r_res)
  354. dev[0].p2p_go_authorize_client_pbc()
  355. dev[2].request("WPS_PBC")
  356. dev[2].wait_connected(timeout=30)
  357. hwsim_utils.test_connectivity_p2p_sta(dev[1], dev[2])
  358. dev[0].remove_group()
  359. dev[2].request("DISCONNECT")
  360. dev[1].wait_go_ending_session()
  361. def test_grpform_force_chan_go(dev):
  362. """P2P group formation forced channel selection by GO"""
  363. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
  364. i_freq=2432,
  365. r_dev=dev[1], r_intent=0,
  366. test_data=False)
  367. check_grpform_results(i_res, r_res)
  368. if i_res['freq'] != "2432":
  369. raise Exception("Unexpected channel - did not follow GO's forced channel")
  370. remove_group(dev[0], dev[1])
  371. def test_grpform_force_chan_cli(dev):
  372. """P2P group formation forced channel selection by client"""
  373. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
  374. i_freq=2417,
  375. r_dev=dev[1], r_intent=15,
  376. test_data=False)
  377. check_grpform_results(i_res, r_res)
  378. if i_res['freq'] != "2417":
  379. raise Exception("Unexpected channel - did not follow GO's forced channel")
  380. remove_group(dev[0], dev[1])
  381. def test_grpform_force_chan_conflict(dev):
  382. """P2P group formation fails due to forced channel mismatch"""
  383. go_neg_pin_authorized(i_dev=dev[0], i_intent=0, i_freq=2422,
  384. r_dev=dev[1], r_intent=15, r_freq=2427,
  385. expect_failure=True, i_go_neg_status=7)
  386. def test_grpform_pref_chan_go(dev):
  387. """P2P group formation preferred channel selection by GO"""
  388. dev[0].request("SET p2p_pref_chan 81:7")
  389. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
  390. r_dev=dev[1], r_intent=0,
  391. test_data=False)
  392. check_grpform_results(i_res, r_res)
  393. if i_res['freq'] != "2442":
  394. raise Exception("Unexpected channel - did not follow GO's p2p_pref_chan")
  395. remove_group(dev[0], dev[1])
  396. def test_grpform_pref_chan_go_overridden(dev):
  397. """P2P group formation preferred channel selection by GO overridden by client"""
  398. dev[1].request("SET p2p_pref_chan 81:7")
  399. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
  400. i_freq=2422,
  401. r_dev=dev[1], r_intent=15,
  402. test_data=False)
  403. check_grpform_results(i_res, r_res)
  404. if i_res['freq'] != "2422":
  405. raise Exception("Unexpected channel - did not follow client's forced channel")
  406. remove_group(dev[0], dev[1])
  407. def test_grpform_no_go_freq_forcing_chan(dev):
  408. """P2P group formation with no-GO freq forcing channel"""
  409. dev[1].request("SET p2p_no_go_freq 100-200,300,4000-6000")
  410. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
  411. r_dev=dev[1], r_intent=15,
  412. test_data=False)
  413. check_grpform_results(i_res, r_res)
  414. if int(i_res['freq']) > 4000:
  415. raise Exception("Unexpected channel - did not follow no-GO freq")
  416. remove_group(dev[0], dev[1])
  417. def test_grpform_no_go_freq_conflict(dev):
  418. """P2P group formation fails due to no-GO range forced by client"""
  419. dev[1].request("SET p2p_no_go_freq 2000-3000")
  420. go_neg_pin_authorized(i_dev=dev[0], i_intent=0, i_freq=2422,
  421. r_dev=dev[1], r_intent=15,
  422. expect_failure=True, i_go_neg_status=7)
  423. def test_grpform_no_5ghz_world_roaming(dev):
  424. """P2P group formation with world roaming regulatory"""
  425. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
  426. r_dev=dev[1], r_intent=15,
  427. test_data=False)
  428. check_grpform_results(i_res, r_res)
  429. if int(i_res['freq']) > 4000:
  430. raise Exception("Unexpected channel - did not follow world roaming rules")
  431. remove_group(dev[0], dev[1])
  432. def test_grpform_no_5ghz_add_cli(dev):
  433. """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1"""
  434. dev[0].request("SET p2p_add_cli_chan 1")
  435. dev[1].request("SET p2p_add_cli_chan 1")
  436. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
  437. r_dev=dev[1], r_intent=14,
  438. test_data=False)
  439. check_grpform_results(i_res, r_res)
  440. if int(i_res['freq']) > 4000:
  441. raise Exception("Unexpected channel - did not follow world roaming rules")
  442. remove_group(dev[0], dev[1])
  443. def test_grpform_no_5ghz_add_cli2(dev):
  444. """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1 (reverse)"""
  445. dev[0].request("SET p2p_add_cli_chan 1")
  446. dev[1].request("SET p2p_add_cli_chan 1")
  447. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=14,
  448. r_dev=dev[1], r_intent=0,
  449. test_data=False)
  450. check_grpform_results(i_res, r_res)
  451. if int(i_res['freq']) > 4000:
  452. raise Exception("Unexpected channel - did not follow world roaming rules")
  453. remove_group(dev[0], dev[1])
  454. def test_grpform_no_5ghz_add_cli3(dev):
  455. """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1 (intent 15)"""
  456. dev[0].request("SET p2p_add_cli_chan 1")
  457. dev[1].request("SET p2p_add_cli_chan 1")
  458. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=0,
  459. r_dev=dev[1], r_intent=15,
  460. test_data=False)
  461. check_grpform_results(i_res, r_res)
  462. if int(i_res['freq']) > 4000:
  463. raise Exception("Unexpected channel - did not follow world roaming rules")
  464. remove_group(dev[0], dev[1])
  465. def test_grpform_no_5ghz_add_cli4(dev):
  466. """P2P group formation with passive scan 5 GHz and p2p_add_cli_chan=1 (reverse; intent 15)"""
  467. dev[0].request("SET p2p_add_cli_chan 1")
  468. dev[1].request("SET p2p_add_cli_chan 1")
  469. [i_res, r_res] = go_neg_pin_authorized(i_dev=dev[0], i_intent=15,
  470. r_dev=dev[1], r_intent=0,
  471. test_data=False)
  472. check_grpform_results(i_res, r_res)
  473. if int(i_res['freq']) > 4000:
  474. raise Exception("Unexpected channel - did not follow world roaming rules")
  475. remove_group(dev[0], dev[1])
  476. def test_grpform_incorrect_pin(dev):
  477. """P2P GO Negotiation with incorrect PIN"""
  478. dev[1].p2p_listen()
  479. addr1 = dev[1].p2p_dev_addr()
  480. if not dev[0].discover_peer(addr1):
  481. raise Exception("Peer not found")
  482. res = dev[1].global_request("P2P_CONNECT " + dev[0].p2p_dev_addr() + " pin auth go_intent=0")
  483. if "FAIL" in res:
  484. raise Exception("P2P_CONNECT failed to generate PIN")
  485. logger.info("PIN from P2P_CONNECT: " + res)
  486. dev[0].global_request("P2P_CONNECT " + addr1 + " 00000000 enter go_intent=15")
  487. ev = dev[0].wait_global_event(["P2P-GO-NEG-SUCCESS"], timeout=15)
  488. if ev is None:
  489. raise Exception("GO Negotiation did not complete successfully(0)")
  490. ev = dev[1].wait_global_event(["P2P-GO-NEG-SUCCESS"], timeout=15)
  491. if ev is None:
  492. raise Exception("GO Negotiation did not complete successfully(1)")
  493. ev = dev[1].wait_global_event(["WPS-FAIL"], timeout=15)
  494. if ev is None:
  495. raise Exception("WPS failure not reported(1)")
  496. if "msg=8 config_error=18" not in ev:
  497. raise Exception("Unexpected WPS failure(1): " + ev)
  498. ev = dev[0].wait_global_event(["WPS-FAIL"], timeout=15)
  499. if ev is None:
  500. raise Exception("WPS failure not reported")
  501. if "msg=8 config_error=18" not in ev:
  502. raise Exception("Unexpected WPS failure: " + ev)
  503. ev = dev[1].wait_global_event(["P2P-GROUP-FORMATION-FAILURE"], timeout=10)
  504. if ev is None:
  505. raise Exception("Group formation failure timed out")
  506. ev = dev[0].wait_global_event(["P2P-GROUP-FORMATION-FAILURE"], timeout=5)
  507. if ev is None:
  508. raise Exception("Group formation failure timed out")
  509. def test_grpform_reject(dev):
  510. """User rejecting group formation attempt by a P2P peer"""
  511. addr0 = dev[0].p2p_dev_addr()
  512. dev[0].p2p_listen()
  513. dev[1].p2p_go_neg_init(addr0, None, "pbc")
  514. ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=15)
  515. if ev is None:
  516. raise Exception("GO Negotiation timed out")
  517. if "OK" in dev[0].global_request("P2P_REJECT foo"):
  518. raise Exception("Invalid P2P_REJECT accepted")
  519. if "FAIL" in dev[0].global_request("P2P_REJECT " + ev.split(' ')[1]):
  520. raise Exception("P2P_REJECT failed")
  521. dev[1].request("P2P_STOP_FIND")
  522. dev[1].p2p_go_neg_init(addr0, None, "pbc")
  523. ev = dev[1].wait_global_event(["GO-NEG-FAILURE"], timeout=10)
  524. if ev is None:
  525. raise Exception("Rejection not reported")
  526. if "status=11" not in ev:
  527. raise Exception("Unexpected status code in rejection")
  528. def test_grpform_pd_no_probe_resp(dev):
  529. """GO Negotiation after PD, but no Probe Response"""
  530. addr0 = dev[0].p2p_dev_addr()
  531. addr1 = dev[1].p2p_dev_addr()
  532. dev[0].p2p_listen()
  533. if not dev[1].discover_peer(addr0):
  534. raise Exception("Peer not found")
  535. dev[1].p2p_stop_find()
  536. dev[0].p2p_stop_find()
  537. peer = dev[0].get_peer(addr1)
  538. if peer['listen_freq'] == '0':
  539. raise Exception("Peer listen frequency not learned from Probe Request")
  540. time.sleep(0.3)
  541. dev[0].request("P2P_FLUSH")
  542. dev[0].p2p_listen()
  543. dev[1].global_request("P2P_PROV_DISC " + addr0 + " display")
  544. ev = dev[0].wait_global_event(["P2P-PROV-DISC-SHOW-PIN"], timeout=5)
  545. if ev is None:
  546. raise Exception("PD Request timed out")
  547. ev = dev[1].wait_global_event(["P2P-PROV-DISC-ENTER-PIN"], timeout=5)
  548. if ev is None:
  549. raise Exception("PD Response timed out")
  550. peer = dev[0].get_peer(addr1)
  551. if peer['listen_freq'] != '0':
  552. raise Exception("Peer listen frequency learned unexpectedly from PD Request")
  553. pin = dev[0].wps_read_pin()
  554. if "FAIL" in dev[1].global_request("P2P_CONNECT " + addr0 + " " + pin + " enter"):
  555. raise Exception("P2P_CONNECT on initiator failed")
  556. ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=5)
  557. if ev is None:
  558. raise Exception("GO Negotiation start timed out")
  559. peer = dev[0].get_peer(addr1)
  560. if peer['listen_freq'] == '0':
  561. raise Exception("Peer listen frequency not learned from PD followed by GO Neg Req")
  562. if "FAIL" in dev[0].global_request("P2P_CONNECT " + addr1 + " " + pin + " display"):
  563. raise Exception("P2P_CONNECT on responder failed")
  564. ev = dev[0].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
  565. if ev is None:
  566. raise Exception("Group formation timed out")
  567. ev = dev[1].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
  568. if ev is None:
  569. raise Exception("Group formation timed out")
  570. def test_go_neg_two_peers(dev):
  571. """P2P GO Negotiation rejected due to already started negotiation with another peer"""
  572. addr0 = dev[0].p2p_dev_addr()
  573. addr1 = dev[1].p2p_dev_addr()
  574. addr2 = dev[2].p2p_dev_addr()
  575. dev[1].p2p_listen()
  576. dev[2].p2p_listen()
  577. if not dev[0].discover_peer(addr1):
  578. raise Exception("Could not discover peer")
  579. if not dev[0].discover_peer(addr2):
  580. raise Exception("Could not discover peer")
  581. if "OK" not in dev[0].request("P2P_CONNECT " + addr2 + " pbc auth"):
  582. raise Exception("Failed to authorize GO Neg")
  583. dev[0].p2p_listen()
  584. if not dev[2].discover_peer(addr0):
  585. raise Exception("Could not discover peer")
  586. if "OK" not in dev[0].request("P2P_CONNECT " + addr1 + " pbc"):
  587. raise Exception("Failed to initiate GO Neg")
  588. ev = dev[1].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=5)
  589. if ev is None:
  590. raise Exception("timeout on GO Neg RX event")
  591. dev[2].request("P2P_CONNECT " + addr0 + " pbc")
  592. ev = dev[2].wait_global_event(["GO-NEG-FAILURE"], timeout=10)
  593. if ev is None:
  594. raise Exception("Rejection not reported")
  595. if "status=5" not in ev:
  596. raise Exception("Unexpected status code in rejection: " + ev)
  597. def clear_pbc_overlap(dev, ifname):
  598. hapd_global = hostapd.HostapdGlobal()
  599. hapd_global.remove(ifname)
  600. dev[0].request("P2P_CANCEL")
  601. dev[1].request("P2P_CANCEL")
  602. dev[0].p2p_stop_find()
  603. dev[1].p2p_stop_find()
  604. dev[0].dump_monitor()
  605. dev[1].dump_monitor()
  606. time.sleep(0.1)
  607. dev[0].flush_scan_cache()
  608. dev[1].flush_scan_cache()
  609. time.sleep(0.1)
  610. def test_grpform_pbc_overlap(dev, apdev):
  611. """P2P group formation during PBC overlap"""
  612. params = { "ssid": "wps", "eap_server": "1", "wps_state": "1" }
  613. hapd = hostapd.add_ap(apdev[0]['ifname'], params)
  614. hapd.request("WPS_PBC")
  615. time.sleep(0.1)
  616. # Since P2P Client scan case is now optimzied to use a specific SSID, the
  617. # WPS AP will not reply to that and the scan after GO Negotiation can quite
  618. # likely miss the AP due to dwell time being short enoguh to miss the Beacon
  619. # frame. This has made the test case somewhat pointless, but keep it here
  620. # for now with an additional scan to confirm that PBC detection works if
  621. # there is a BSS entry for a overlapping AP.
  622. for i in range(0, 5):
  623. dev[0].scan(freq="2412")
  624. if dev[0].get_bss(apdev[0]['bssid']) is not None:
  625. break
  626. addr0 = dev[0].p2p_dev_addr()
  627. addr1 = dev[1].p2p_dev_addr()
  628. dev[0].p2p_listen()
  629. if not dev[1].discover_peer(addr0):
  630. raise Exception("Could not discover peer")
  631. dev[1].p2p_listen()
  632. if not dev[0].discover_peer(addr1):
  633. raise Exception("Could not discover peer")
  634. dev[0].p2p_listen()
  635. if "OK" not in dev[0].global_request("P2P_CONNECT " + addr1 + " pbc auth go_intent=0"):
  636. raise Exception("Failed to authorize GO Neg")
  637. if "OK" not in dev[1].global_request("P2P_CONNECT " + addr0 + " pbc go_intent=15 freq=2412"):
  638. raise Exception("Failed to initiate GO Neg")
  639. ev = dev[0].wait_global_event(["WPS-OVERLAP-DETECTED"], timeout=15)
  640. if ev is None:
  641. raise Exception("PBC overlap not reported")
  642. clear_pbc_overlap(dev, apdev[0]['ifname'])
  643. def test_grpform_pbc_overlap_group_iface(dev, apdev):
  644. """P2P group formation during PBC overlap using group interfaces"""
  645. # Note: Need to include P2P IE from the AP to get the P2P interface BSS
  646. # update use this information.
  647. params = { "ssid": "wps", "eap_server": "1", "wps_state": "1",
  648. "beacon_int": "15", 'manage_p2p': '1' }
  649. hapd = hostapd.add_ap(apdev[0]['ifname'], params)
  650. hapd.request("WPS_PBC")
  651. dev[0].request("SET p2p_no_group_iface 0")
  652. dev[1].request("SET p2p_no_group_iface 0")
  653. addr0 = dev[0].p2p_dev_addr()
  654. addr1 = dev[1].p2p_dev_addr()
  655. dev[0].p2p_listen()
  656. if not dev[1].discover_peer(addr0):
  657. raise Exception("Could not discover peer")
  658. dev[1].p2p_listen()
  659. if not dev[0].discover_peer(addr1):
  660. raise Exception("Could not discover peer")
  661. dev[0].p2p_stop_find()
  662. dev[0].scan(freq="2412")
  663. dev[0].p2p_listen()
  664. if "OK" not in dev[0].global_request("P2P_CONNECT " + addr1 + " pbc auth go_intent=0"):
  665. raise Exception("Failed to authorize GO Neg")
  666. if "OK" not in dev[1].global_request("P2P_CONNECT " + addr0 + " pbc go_intent=15 freq=2412"):
  667. raise Exception("Failed to initiate GO Neg")
  668. ev = dev[0].wait_global_event(["WPS-OVERLAP-DETECTED",
  669. "P2P-GROUP-FORMATION-SUCCESS"], timeout=15)
  670. if ev is None or "WPS-OVERLAP-DETECTED" not in ev:
  671. # Do not report this as failure since the P2P group formation case
  672. # using a separate group interface has limited chances of "seeing" the
  673. # overlapping AP due to a per-SSID scan and no prior scan operations on
  674. # the group interface.
  675. logger.info("PBC overlap not reported")
  676. clear_pbc_overlap(dev, apdev[0]['ifname'])
  677. def test_grpform_goneg_fail_with_group_iface(dev):
  678. """P2P group formation fails while using group interface"""
  679. dev[0].request("SET p2p_no_group_iface 0")
  680. dev[1].p2p_listen()
  681. peer = dev[1].p2p_dev_addr()
  682. if not dev[0].discover_peer(peer):
  683. raise Exception("Peer " + peer + " not found")
  684. if "OK" not in dev[1].request("P2P_REJECT " + dev[0].p2p_dev_addr()):
  685. raise Exception("P2P_REJECT failed")
  686. if "OK" not in dev[0].request("P2P_CONNECT " + peer + " pbc"):
  687. raise Exception("P2P_CONNECT failed")
  688. ev = dev[0].wait_global_event(["P2P-GO-NEG-FAILURE"], timeout=10)
  689. if ev is None:
  690. raise Exception("GO Negotiation failure timed out")
  691. def test_grpform_cred_ready_timeout(dev, apdev, params):
  692. """P2P GO Negotiation wait for credentials to become ready [long]"""
  693. if not params['long']:
  694. raise HwsimSkip("Skip test case with long duration due to --long not specified")
  695. dev[1].p2p_listen()
  696. addr1 = dev[1].p2p_dev_addr()
  697. if not dev[0].discover_peer(addr1):
  698. raise Exception("Peer " + addr1 + " not found")
  699. if not dev[2].discover_peer(addr1):
  700. raise Exception("Peer " + addr1 + " not found(2)")
  701. start = os.times()[4]
  702. cmd = "P2P_CONNECT " + addr1 + " 12345670 display"
  703. if "OK" not in dev[0].global_request(cmd):
  704. raise Exception("Failed to initiate GO Neg")
  705. if "OK" not in dev[2].global_request(cmd):
  706. raise Exception("Failed to initiate GO Neg(2)")
  707. # First, check with p2p_find
  708. ev = dev[2].wait_global_event(["P2P-GO-NEG-FAILURE"], timeout=30)
  709. if ev is not None:
  710. raise Exception("Too early GO Negotiation timeout reported(2)")
  711. dev[2].dump_monitor()
  712. logger.info("Starting p2p_find to change state")
  713. dev[2].p2p_find()
  714. ev = dev[2].wait_global_event(["P2P-GO-NEG-FAILURE"], timeout=100)
  715. if ev is None:
  716. raise Exception("GO Negotiation failure timed out(2)")
  717. dev[2].dump_monitor()
  718. end = os.times()[4]
  719. logger.info("GO Negotiation wait time: {} seconds(2)".format(end - start))
  720. if end - start < 120:
  721. raise Exception("Too short GO Negotiation wait time(2): {}".format(end - start))
  722. wpas = WpaSupplicant(global_iface='/tmp/wpas-wlan5')
  723. wpas.interface_add("wlan5")
  724. wpas.p2p_listen()
  725. ev = dev[2].wait_global_event(["P2P-DEVICE-FOUND"], timeout=10)
  726. if ev is None:
  727. raise Exception("Did not discover new device after GO Negotiation failure")
  728. if wpas.p2p_dev_addr() not in ev:
  729. raise Exception("Unexpected device found: " + ev)
  730. dev[2].p2p_stop_find()
  731. wpas.p2p_stop_find()
  732. # Finally, verify without p2p_find
  733. ev = dev[0].wait_global_event(["P2P-GO-NEG-FAILURE"], timeout=120)
  734. if ev is None:
  735. raise Exception("GO Negotiation failure timed out")
  736. end = os.times()[4]
  737. logger.info("GO Negotiation wait time: {} seconds".format(end - start))
  738. if end - start < 120:
  739. raise Exception("Too short GO Negotiation wait time: {}".format(end - start))
  740. def test_grpform_no_wsc_done(dev):
  741. """P2P group formation with WSC-Done not sent"""
  742. addr0 = dev[0].p2p_dev_addr()
  743. addr1 = dev[1].p2p_dev_addr()
  744. for i in range(0, 2):
  745. dev[0].request("SET ext_eapol_frame_io 1")
  746. dev[1].request("SET ext_eapol_frame_io 1")
  747. dev[0].p2p_listen()
  748. dev[1].p2p_go_neg_auth(addr0, "12345670", "display", 0)
  749. dev[1].p2p_listen()
  750. dev[0].p2p_go_neg_init(addr1, "12345670", "enter", timeout=20,
  751. go_intent=15, wait_group=False)
  752. mode = None
  753. while True:
  754. ev = dev[0].wait_event(["EAPOL-TX"], timeout=15)
  755. if ev is None:
  756. raise Exception("Timeout on EAPOL-TX from GO")
  757. if not mode:
  758. mode = dev[0].get_status_field("mode")
  759. res = dev[1].request("EAPOL_RX " + addr0 + " " + ev.split(' ')[2])
  760. if "OK" not in res:
  761. raise Exception("EAPOL_RX failed")
  762. ev = dev[1].wait_event(["EAPOL-TX"], timeout=15)
  763. if ev is None:
  764. raise Exception("Timeout on EAPOL-TX from P2P Client")
  765. msg = ev.split(' ')[2]
  766. if msg[46:56] == "102200010f":
  767. logger.info("Drop WSC_Done")
  768. dev[0].request("SET ext_eapol_frame_io 0")
  769. dev[1].request("SET ext_eapol_frame_io 0")
  770. # Fake EAP-Failure to complete session on the client
  771. id = msg[10:12]
  772. dev[1].request("EAPOL_RX " + addr0 + " 0300000404" + id + "0004")
  773. break
  774. res = dev[0].request("EAPOL_RX " + addr1 + " " + msg)
  775. if "OK" not in res:
  776. raise Exception("EAPOL_RX failed")
  777. ev = dev[0].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
  778. if ev is None:
  779. raise Exception("Group formation timed out on GO")
  780. ev = dev[1].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
  781. if ev is None:
  782. raise Exception("Group formation timed out on P2P Client")
  783. dev[0].remove_group()
  784. dev[1].wait_go_ending_session()
  785. if mode != "P2P GO - group formation":
  786. raise Exception("Unexpected mode on GO during group formation: " + mode)
  787. def test_grpform_wait_peer(dev):
  788. """P2P group formation wait for peer to become ready"""
  789. addr0 = dev[0].p2p_dev_addr()
  790. addr1 = dev[1].p2p_dev_addr()
  791. dev[1].p2p_listen()
  792. if not dev[0].discover_peer(addr1):
  793. raise Exception("Peer " + addr1 + " not found")
  794. dev[0].request("SET extra_roc_dur 500")
  795. if "OK" not in dev[0].request("P2P_CONNECT " + addr1 + " 12345670 display go_intent=15"):
  796. raise Exception("Failed to initiate GO Neg")
  797. time.sleep(3)
  798. dev[1].request("P2P_CONNECT " + addr0 + " 12345670 enter go_intent=0")
  799. ev = dev[0].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
  800. if ev is None:
  801. raise Exception("Group formation timed out")
  802. dev[0].group_form_result(ev)
  803. dev[0].request("SET extra_roc_dur 0")
  804. ev = dev[1].wait_global_event(["P2P-GROUP-STARTED"], timeout=15)
  805. if ev is None:
  806. raise Exception("Group formation timed out")
  807. dev[0].remove_group()
  808. def test_invalid_p2p_connect_command(dev):
  809. """P2P_CONNECT error cases"""
  810. id = dev[0].add_network()
  811. for cmd in [ "foo",
  812. "00:11:22:33:44:55",
  813. "00:11:22:33:44:55 pbc persistent=123",
  814. "00:11:22:33:44:55 pbc persistent=%d" % id,
  815. "00:11:22:33:44:55 pbc go_intent=-1",
  816. "00:11:22:33:44:55 pbc go_intent=16",
  817. "00:11:22:33:44:55 pin",
  818. "00:11:22:33:44:55 pbc freq=0" ]:
  819. if "FAIL" not in dev[0].request("P2P_CONNECT " + cmd):
  820. raise Exception("Invalid P2P_CONNECT command accepted: " + cmd)
  821. if "FAIL-INVALID-PIN" not in dev[0].request("P2P_CONNECT 00:11:22:33:44:55 1234567"):
  822. raise Exception("Invalid PIN was not rejected")
  823. if "FAIL-CHANNEL-UNSUPPORTED" not in dev[0].request("P2P_CONNECT 00:11:22:33:44:55 pin freq=3000"):
  824. raise Exception("Unsupported channel not reported")
  825. def test_p2p_unauthorize(dev):
  826. """P2P_UNAUTHORIZE to unauthorize a peer"""
  827. if "FAIL" not in dev[0].request("P2P_UNAUTHORIZE foo"):
  828. raise Exception("Invalid P2P_UNAUTHORIZE accepted")
  829. if "FAIL" not in dev[0].request("P2P_UNAUTHORIZE 00:11:22:33:44:55"):
  830. raise Exception("P2P_UNAUTHORIZE for unknown peer accepted")
  831. addr0 = dev[0].p2p_dev_addr()
  832. addr1 = dev[1].p2p_dev_addr()
  833. dev[1].p2p_listen()
  834. pin = dev[0].wps_read_pin()
  835. dev[0].p2p_go_neg_auth(addr1, pin, "display")
  836. dev[0].p2p_listen()
  837. if "OK" not in dev[0].request("P2P_UNAUTHORIZE " + addr1):
  838. raise Exception("P2P_UNAUTHORIZE failed")
  839. dev[1].p2p_go_neg_init(addr0, pin, "keypad", timeout=0)
  840. ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=10)
  841. if ev is None:
  842. raise Exception("No GO Negotiation Request RX reported")
  843. def test_grpform_pbc_multiple(dev):
  844. """P2P group formation using PBC multiple times in a row"""
  845. try:
  846. dev[1].request("SET passive_scan 1")
  847. for i in range(5):
  848. [i_res, r_res] = go_neg_pbc_authorized(i_dev=dev[0], i_intent=15,
  849. r_dev=dev[1], r_intent=0)
  850. remove_group(dev[0], dev[1])
  851. finally:
  852. dev[1].request("SET passive_scan 0")
  853. dev[1].flush_scan_cache()
  854. def test_grpform_not_ready(dev):
  855. """Not ready for GO Negotiation (listen)"""
  856. addr0 = dev[0].p2p_dev_addr()
  857. addr2 = dev[2].p2p_dev_addr()
  858. dev[0].p2p_listen()
  859. if not dev[1].discover_peer(addr0):
  860. raise Exception("Could not discover peer")
  861. dev[1].global_request("P2P_CONNECT " + addr0 + " pbc")
  862. ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=5)
  863. if ev is None:
  864. raise Exception("No P2P-GO-NEG-REQUEST event")
  865. dev[0].dump_monitor()
  866. time.sleep(5)
  867. if not dev[2].discover_peer(addr0):
  868. raise Exception("Could not discover peer(2)")
  869. for i in range(3):
  870. dev[i].p2p_stop_find()
  871. def test_grpform_not_ready2(dev):
  872. """Not ready for GO Negotiation (search)"""
  873. addr0 = dev[0].p2p_dev_addr()
  874. addr2 = dev[2].p2p_dev_addr()
  875. dev[0].p2p_find(social=True)
  876. if not dev[1].discover_peer(addr0):
  877. raise Exception("Could not discover peer")
  878. dev[1].global_request("P2P_CONNECT " + addr0 + " pbc")
  879. ev = dev[0].wait_global_event(["P2P-GO-NEG-REQUEST"], timeout=5)
  880. if ev is None:
  881. raise Exception("No P2P-GO-NEG-REQUEST event")
  882. dev[0].dump_monitor()
  883. time.sleep(1)
  884. dev[2].p2p_listen()
  885. ev = dev[0].wait_global_event(["P2P-DEVICE-FOUND"], timeout=10)
  886. if ev is None:
  887. raise Exception("Peer not discovered after GO Neg Resp(status=1) TX")
  888. if addr2 not in ev:
  889. raise Exception("Unexpected peer discovered: " + ev)
  890. for i in range(3):
  891. dev[i].p2p_stop_find()