test_p2p_persistent.py 28 KB

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