2 # Copyright (c) 2014-2015, Qualcomm Atheros, Inc.
4 # This software may be distributed under the terms of the BSD license.
5 # See README for more details.
8 logger
= logging
.getLogger()
14 from wpasupplicant
import WpaSupplicant
15 from test_p2p_grpform
import check_grpform_results
16 from test_p2p_grpform
import remove_group
17 from test_p2p_persistent
import go_neg_pin_authorized_persistent
18 from utils
import HwsimSkip
20 # Dev[0] -> Advertiser
22 # ev0 -> Event generated at advertiser side
23 # ev1 -> Event generated at Seeker side
25 def p2ps_advertise(r_dev
, r_role
, svc_name
, srv_info
, rsp_info
=None, cpt
=None):
26 """P2PS Advertise function"""
27 adv_id
= random
.randrange(1, 0xFFFFFFFF)
28 advid
= hex(adv_id
)[2:]
30 cpt_param
= (" cpt=" + cpt
) if cpt
is not None else ""
32 if rsp_info
is not None and srv_info
is not None:
33 if "OK" not in r_dev
.global_request("P2P_SERVICE_ADD asp " + str(r_role
) + " " + str(advid
) + " 1 1108 " + svc_name
+ cpt_param
+ " svc_info='" + srv_info
+ "'" + " rsp_info=" + rsp_info
+ "'"):
34 raise Exception("P2P_SERVICE_ADD with response info and service info failed")
36 if rsp_info
is None and srv_info
is not None:
37 if "OK" not in r_dev
.global_request("P2P_SERVICE_ADD asp " + str(r_role
) + " " + str(advid
) + " 1 1108 " + svc_name
+ cpt_param
+ " svc_info='" + srv_info
+ "'"):
38 raise Exception("P2P_SERVICE_ADD with service info failed")
40 if rsp_info
is None and srv_info
is None:
41 if "OK" not in r_dev
.global_request("P2P_SERVICE_ADD asp " + str(r_role
) + " " + str(advid
) + " 1 1108 " + svc_name
+ cpt_param
):
42 raise Exception("P2P_SERVICE_ADD without service info and without response info failed")
44 if rsp_info
is not None and srv_info
is None:
45 if "OK" not in r_dev
.global_request("P2P_SERVICE_ADD asp " + str(r_role
) + " " + str(adv_id
) + " 1 1108 " + svc_name
+ cpt_param
+ " svc_info='" + " rsp_info=" + rsp_info
+ "'"):
46 raise Exception("P2P_SERVICE_ADD with response info failed")
51 def p2ps_exact_seek(i_dev
, r_dev
, svc_name
, srv_info
=None,
52 single_peer_expected
=True):
53 """P2PS exact service seek request"""
54 if srv_info
is not None:
55 ev1
= i_dev
.global_request("P2P_SERV_DISC_REQ 00:00:00:00:00:00 asp 1 " + svc_name
+ " '" + srv_info
+ "'")
57 raise Exception("Failed to add Service Discovery request for exact seek request")
59 if "OK" not in i_dev
.global_request("P2P_FIND 10 type=social seek=" + svc_name
):
60 raise Exception("Failed to initiate seek operation")
62 timeout
= time
.time() + 10
63 ev1
= i_dev
.wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
64 while ev1
is not None and not single_peer_expected
:
65 if r_dev
.p2p_dev_addr() in ev1
and "adv_id=" in ev1
:
67 ev1
= i_dev
.wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
69 if timeout
< time
.time():
70 raise Exception("Device not found")
73 raise Exception("P2P-DEVICE-FOUND timeout on seeker side")
74 if r_dev
.p2p_dev_addr() not in ev1
:
75 raise Exception("Unexpected peer")
78 adv_id
= ev1
.split("adv_id=")[1].split(" ")[0]
79 rcvd_svc_name
= ev1
.split("asp_svc=")[1].split(" ")[0]
80 if rcvd_svc_name
!= svc_name
:
81 raise Exception("service name not matching")
83 ev1
= i_dev
.wait_global_event(["P2P-SERV-ASP-RESP"], timeout
=10)
85 raise Exception("Failed to receive Service Discovery Response")
86 if r_dev
.p2p_dev_addr() not in ev1
:
87 raise Exception("Service Discovery response from Unknown Peer")
88 if srv_info
is not None and srv_info
not in ev1
:
89 raise Exception("service info not available in Service Discovery response")
90 adv_id
= ev1
.split(" ")[3]
91 rcvd_svc_name
= ev1
.split(" ")[6]
92 if rcvd_svc_name
!= svc_name
:
93 raise Exception("service name not matching")
95 return [adv_id
, rcvd_svc_name
]
97 def p2ps_nonexact_seek(i_dev
, r_dev
, svc_name
, srv_info
=None, adv_num
=None):
98 """P2PS nonexact service seek request"""
101 if srv_info
is not None:
102 ev1
= i_dev
.global_request("P2P_SERV_DISC_REQ 00:00:00:00:00:00 asp 1 " + svc_name
+ " '" + srv_info
+ "'")
104 ev1
= i_dev
.global_request("P2P_SERV_DISC_REQ 00:00:00:00:00:00 asp 1 " + svc_name
+ " '")
106 raise Exception("Failed to add Service Discovery request for nonexact seek request")
107 if "OK" not in i_dev
.global_request("P2P_FIND 10 type=social seek="):
108 raise Exception("Failed to initiate seek")
109 ev1
= i_dev
.wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
111 raise Exception("P2P-DEVICE-FOUND timeout on seeker side")
112 if r_dev
.p2p_dev_addr() not in ev1
:
113 raise Exception("Unexpected peer")
115 for i
in range (0, adv_num
):
116 ev1
= i_dev
.wait_global_event(["P2P-SERV-ASP-RESP"], timeout
=10)
118 raise Exception("Failed to receive Service Discovery Response")
119 if r_dev
.p2p_dev_addr() not in ev1
:
120 raise Exception("Service Discovery response from Unknown Peer")
121 if srv_info
is not None and srv_info
not in ev1
:
122 raise Exception("service info not available in Service Discovery response")
123 adv_id
= ev1
.split(" ")[3]
124 rcvd_svc_name
= ev1
.split(" ")[6]
125 ev_list
.append(''.join([adv_id
, ' ', rcvd_svc_name
]))
128 def p2ps_parse_event(ev
, *args
):
131 m
= re
.search("\s+" + arg
+ r
"=(\S+)", ev
)
132 ret
+= (m
.group(1) if m
is not None else None,)
135 def p2ps_provision(seeker
, advertiser
, adv_id
, auto_accept
=True, method
="1000", adv_cpt
=None, seeker_cpt
=None):
136 addr0
= seeker
.p2p_dev_addr()
137 addr1
= advertiser
.p2p_dev_addr()
139 seeker
.asp_provision(addr1
, adv_id
=str(adv_id
), adv_mac
=addr1
, session_id
=1,
140 session_mac
=addr0
, method
=method
, cpt
=seeker_cpt
)
142 if not auto_accept
or method
== "100":
144 ev_pd_start
= advertiser
.wait_global_event(["P2PS-PROV-START"],
146 if ev_pd_start
is None:
147 raise Exception("P2PS-PROV-START timeout on Advertiser side")
148 peer
= ev_pd_start
.split()[1]
149 advert_id
, advert_mac
, session
, session_mac
=\
150 p2ps_parse_event(ev_pd_start
, "adv_id", "adv_mac", "session", "mac")
152 ev
= seeker
.wait_global_event(["P2P-PROV-DISC-FAILURE"], timeout
=10)
154 raise Exception("P2P-PROV-DISC-FAILURE timeout on seeker side")
157 ev
= advertiser
.wait_global_event(["P2P-PROV-DISC-ENTER-PIN"],
160 raise Exception("P2P-PROV-DISC-ENTER-PIN timeout on advertiser side")
162 raise Exception("Unknown peer " + addr0
)
163 ev
= seeker
.wait_global_event(["P2P-PROV-DISC-SHOW-PIN"],
166 raise Exception("P2P-PROV-DISC-SHOW-PIN timeout on seeker side")
168 raise Exception("Unknown peer " + addr1
)
171 ev
= advertiser
.wait_global_event(["P2P-PROV-DISC-SHOW-PIN"],
174 raise Exception("P2P-PROV-DISC-SHOW-PIN timeout on advertiser side")
176 raise Exception("Unknown peer " + addr0
)
179 advertiser
.asp_provision(peer
, adv_id
=advert_id
, adv_mac
=advert_mac
,
180 session_id
=int(session
, 0),
181 session_mac
=session_mac
, status
=12,
184 ev1
= seeker
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
186 raise Exception("P2PS-PROV-DONE timeout on seeker side")
188 ev2
= advertiser
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
190 raise Exception("P2PS-PROV-DONE timeout on advertiser side")
193 ev
= seeker
.wait_global_event(["P2P-PROV-DISC-ENTER-PIN"],
196 raise Exception("P2P-PROV-DISC-ENTER-PIN failed on seeker side")
198 raise Exception("Unknown peer " + addr1
)
204 # Auto-accept is true and the method is either P2PS or advertiser is DISPLAY
205 ev1
= seeker
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
207 raise Exception("P2PS-PROV-DONE timeout on seeker side")
209 ev2
= advertiser
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
211 raise Exception("P2PS-PROV-DONE timeout on advertiser side")
214 ev
= seeker
.wait_global_event(["P2P-PROV-DISC-ENTER-PIN"], timeout
=10)
216 raise Exception("P2P-PROV-DISC-ENTER-PIN timeout on seeker side")
218 raise Exception("Unknown peer " + addr1
)
219 ev
= advertiser
.wait_global_event(["P2P-PROV-DISC-SHOW-PIN"],
222 raise Exception("P2P-PROV-DISC-SHOW-PIN timeout on advertiser side")
224 raise Exception("Unknown peer " + addr0
)
230 def p2p_connect_p2ps_method(i_dev
, r_dev
, autoaccept
):
231 """P2PS connect function with p2ps method"""
232 if autoaccept
== False:
233 if "OK" not in i_dev
.global_request("P2P_CONNECT " + r_dev
.p2p_dev_addr() + " 12345670 p2ps persistent auth"):
234 raise Exception("P2P_CONNECT fails on seeker side")
235 ev0
= r_dev
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
237 raise Exception("P2PS-PROV-DONE timeout on Advertiser side")
239 if "OK" not in r_dev
.global_request("P2P_CONNECT " + i_dev
.p2p_dev_addr() + " 12345670 p2ps persistent"):
240 raise Exception("P2P_CONNECT fails on Advertiser side")
243 if "OK" not in r_dev
.global_request("P2P_CONNECT " + i_dev
.p2p_dev_addr() + " 12345670 p2ps persistent auth"):
244 raise Exception("P2P_CONNECT fails on Advertiser side")
245 ev1
= i_dev
.wait_global_event(["P2PS-PROV-DONE"], timeout
=5)
247 raise Exception("Failed to receive deferred acceptance at seeker")
249 if "OK" not in i_dev
.global_request("P2P_CONNECT " + r_dev
.p2p_dev_addr() + " 12345670 p2ps persistent"):
250 raise Exception("P2P_CONNECT fails on seeker side")
251 ev0
= r_dev
.wait_global_event(["P2P-GO-NEG-SUCCESS"], timeout
=10)
253 raise Exception("GO Neg did not succeed")
254 ev0
= r_dev
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=15)
256 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
257 r_dev
.group_form_result(ev0
)
259 ev1
= i_dev
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=5)
261 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
262 i_dev
.group_form_result(ev1
)
264 def p2ps_provision_keypad_method(i_dev
, r_dev
, autoaccept
,
265 initiator_or_responder
):
266 """P2PS keypad method provisioning function"""
267 if autoaccept
== False and initiator_or_responder
== 'initiator':
268 ev
= i_dev
.wait_global_event(["P2P-PROV-DISC-FAILURE"], timeout
=10)
270 raise Exception("Provisioning deferred on seeker side")
271 ev1
= i_dev
.wait_global_event(["P2P-PROV-DISC-ENTER-PIN"], timeout
=10)
273 raise Exception("P2P-PROV-DISC-ENTER-PIN timeout on seeker side")
274 if r_dev
.p2p_dev_addr() not in ev1
:
275 raise Exception("Unknown peer ")
276 ev
= r_dev
.wait_global_event(["P2PS-PROV-START"], timeout
=10)
278 raise Exception("P2PS-PROV-START timeout on Advertiser side")
280 if autoaccept
== False and initiator_or_responder
== 'responder':
281 ev0
= r_dev
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
283 raise Exception("P2PS-PROV-DONE timeout on seeker side")
284 ev0
= r_dev
.wait_global_event(["P2P-PROV-DISC-ENTER-PIN"], timeout
=5)
286 raise Exception("P2P-PROV-DISC-ENTER-PIN timeout on advertiser side")
288 if autoaccept
== True and initiator_or_responder
== 'initiator':
289 ev1
= i_dev
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
291 raise Exception("P2PS-PROV-DONE timeout on seeker side")
292 ev2
= i_dev
.wait_global_event(["P2P-PROV-DISC-ENTER-PIN"], timeout
=10)
294 raise Exception("P2P-PROV-DISC-ENTER-PIN failed on seeker side")
295 if r_dev
.p2p_dev_addr() not in ev2
:
296 raise Exception("Unknown peer ")
299 def p2ps_provision_display_method(i_dev
, r_dev
, autoaccept
,
300 initiator_or_responder
):
301 """P2PS display method provisioning function"""
302 if initiator_or_responder
== 'initiator':
303 ev0
= r_dev
.wait_global_event(["P2PS-PROV-START"], timeout
=10)
305 raise Exception("P2PS-PROV-START timeout on Advertiser side")
306 if autoaccept
== False:
307 ev
= i_dev
.wait_global_event(["P2P-PROV-DISC-FAILURE"], timeout
=10)
309 raise Exception("Provisioning deferred on seeker side")
310 ev1
= i_dev
.wait_global_event(["P2P-PROV-DISC-SHOW-PIN"], timeout
=10)
312 raise Exception("P2P-PROV-DISC-SHOW-PIN timeout on Seeker side")
313 if r_dev
.p2p_dev_addr() not in ev1
:
314 raise Exception("Unknown peer ")
315 pin
= ev1
.split(" ")[2]
317 ev0
= r_dev
.wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
319 raise Exception("P2PS-PROV-DONE timeout on advertiser")
320 ev0
= r_dev
.wait_global_event(["P2P-PROV-DISC-SHOW-PIN"], timeout
=5)
322 raise Exception("PIN Display on advertiser side")
323 pin
= ev0
.split(" ")[2]
326 def p2ps_connect_pin(pin
, i_dev
, r_dev
, initiator_method
):
327 """P2PS function to perform connection using PIN method"""
328 if initiator_method
=="display":
329 if "OK" not in i_dev
.global_request("P2P_CONNECT " + r_dev
.p2p_dev_addr() + " " + pin
+ " display persistent "):
330 raise Exception("P2P_CONNECT fails on seeker side")
331 ev0
= r_dev
.wait_global_event(["P2P-GO-NEG-REQUEST"], timeout
=10)
333 raise Exception("Failed to receive P2P_GO-NEG-REQUEST on responder side")
334 if "OK" not in r_dev
.global_request("P2P_CONNECT " + i_dev
.p2p_dev_addr() + " " + pin
+ " keypad persistent "):
335 raise Exception("P2P_CONNECT fails on Advertiser side")
337 if "OK" not in i_dev
.global_request("P2P_CONNECT " + r_dev
.p2p_dev_addr() + " " + pin
+ " keypad persistent "):
338 raise Exception("P2P_CONNECT fails on seeker side")
339 ev0
= r_dev
.wait_global_event(["P2P-GO-NEG-REQUEST"], timeout
=10)
341 raise Exception("Failed to receive P2P_GO-NEG-REQUEST on responder side")
342 if "OK" not in r_dev
.global_request("P2P_CONNECT " + i_dev
.p2p_dev_addr() + " " + pin
+ " display persistent "):
343 raise Exception("P2P_CONNECT fails on Advertiser side")
345 ev0
= r_dev
.wait_global_event(["P2P-GO-NEG-SUCCESS"], timeout
=10)
347 raise Exception("GO Neg did not succeed on advertiser side")
348 peer_mac
= ev0
.split("peer_dev=")[1].split(" ")[0]
350 ev1
= i_dev
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
352 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
353 i_dev
.group_form_result(ev1
)
355 ev_grpfrm
= r_dev
.wait_global_event(["P2P-GROUP-FORMATION-SUCCESS"],
357 if ev_grpfrm
is None:
358 raise Exception("Group Formation failed on advertiser side")
360 ev
= r_dev
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
362 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
363 res
= r_dev
.group_form_result(ev
)
365 if res
['role'] == "GO":
366 ev_grpfrm
= r_dev
.wait_global_event(["AP-STA-CONNECTED"], timeout
=10)
367 if ev_grpfrm
is None:
368 raise Exception("AP-STA-CONNECTED timeout on advertiser side")
369 if i_dev
.p2p_dev_addr() not in ev_grpfrm
:
370 raise Exception("Group formed with unknown Peer")
372 ev1
= i_dev
.wait_global_event(["AP-STA-CONNECTED"], timeout
=5)
374 raise Exception("AP-STA-CONNECTED timeout on Seeker side")
375 if r_dev
.p2p_dev_addr() not in ev1
:
376 raise Exception("Group formed with unknown Peer")
378 def p2ps_connect_pd(dev0
, dev1
, ev0
, ev1
, pin
=None):
379 conf_methods_map
= {"8": "p2ps", "1": "display", "5": "keypad"}
380 peer0
= ev0
.split()[1]
381 peer1
= ev1
.split()[1]
382 status0
, conncap0
, adv_id0
, adv_mac0
, mac0
, session0
, dev_passwd_id0
, go0
, join0
, feature_cap0
, persist0
=\
383 p2ps_parse_event(ev0
, "status", "conncap", "adv_id", "adv_mac", "mac", "session", "dev_passwd_id", "go", "join", "feature_cap", "persist")
384 status1
, conncap1
, adv_id1
, adv_mac1
, mac1
, session1
, dev_passwd_id1
, go1
, join1
, feature_cap1
, persist1
=\
385 p2ps_parse_event(ev1
, "status", "conncap", "adv_id", "adv_mac", "mac", "session", "dev_passwd_id", "go", "join", "feature_cap", "persist")
387 if status0
!= "0" and status0
!= "12":
388 raise Exception("PD failed on " + dev0
.p2p_dev_addr())
390 if status1
!= "0" and status1
!= "12":
391 raise Exception("PD failed on " + dev1
.p2p_dev_addr())
393 if status0
== "12" and status1
== "12":
394 raise Exception("Both sides have status 12 which doesn't make sense")
396 if adv_id0
!= adv_id1
or adv_id0
is None:
397 raise Exception("Adv. IDs don't match")
399 if adv_mac0
!= adv_mac1
or adv_mac0
is None:
400 raise Exception("Adv. MACs don't match")
402 if session0
!= session1
or session0
is None:
403 raise Exception("Session IDs don't match")
405 if mac0
!= mac1
or mac0
is None:
406 raise Exception("Session MACs don't match")
408 #TODO: Validate feature capability
410 if bool(persist0
) != bool(persist1
):
411 raise Exception("Only one peer has persistent group")
413 if persist0
is None and not all([conncap0
, conncap1
, dev_passwd_id0
,
415 raise Exception("Persistent group not used but conncap/dev_passwd_id are missing")
417 if persist0
is not None and any([conncap0
, conncap1
, dev_passwd_id0
,
419 raise Exception("Persistent group is used but conncap/dev_passwd_id are present")
421 # Persistent Connection (todo: handle frequency)
422 if persist0
is not None:
423 if "OK" not in dev0
.global_request("P2P_GROUP_ADD persistent=" + persist0
+ " freq=2412"):
424 raise Exception("Could not re-start persistent group")
425 ev0
= dev0
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
427 raise Exception("P2P-GROUP-STARTED timeout on " + dev0
.p2p_dev_addr())
428 dev0
.group_form_result(ev0
)
430 if "OK" not in dev1
.global_request("P2P_GROUP_ADD persistent=" + persist1
+ " freq=2412"):
431 raise Exception("Could not re-start persistent group")
432 ev1
= dev1
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
434 raise Exception("P2P-GROUP-STARTED timeout on " + dev1
.p2p_dev_addr())
435 dev1
.group_form_result(ev1
)
437 ev
= dev0
.wait_global_event(["AP-STA-CONNECTED"], timeout
=10)
439 raise Exception("AP-STA-CONNECTED timeout on " + dev0
.p2p_dev_addr())
441 ev
= dev1
.wait_global_event(["AP-STA-CONNECTED"], timeout
=10)
443 raise Exception("AP-STA-CONNECTED timeout on " + dev1
.p2p_dev_addr())
446 method0
= conf_methods_map
[dev_passwd_id0
]
447 method1
= conf_methods_map
[dev_passwd_id1
]
449 raise Exception("Unsupported method")
451 if method0
== "p2ps":
454 raise Exception("Pin is not provided")
456 if conncap0
== "1" and conncap1
== "1": # NEW/NEW - GON
457 if any([join0
, join1
, go0
, go1
]):
458 raise Exception("Unexpected join/go PD attributes")
460 if "OK" not in dev0
.global_request("P2P_CONNECT " + peer0
+ " " + pin
+ " " + method0
+ " persistent auth"):
461 raise Exception("P2P_CONNECT fails on " + dev0
.p2p_dev_addr())
462 if "OK" not in dev1
.global_request("P2P_CONNECT " + peer1
+ " " + pin
+ " " + method1
+ " persistent"):
463 raise Exception("P2P_CONNECT fails on " + dev1
.p2p_dev_addr())
464 ev
= dev0
.wait_global_event(["P2P-GO-NEG-SUCCESS"], timeout
=10)
466 raise Exception("GO Neg did not succeed on " + dev0
.p2p_dev_addr())
467 ev
= dev1
.wait_global_event(["P2P-GO-NEG-SUCCESS"], timeout
=10)
469 raise Exception("GO Neg did not succeed on " + dev1
.p2p_dev_addr())
470 ev
= dev0
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
472 raise Exception("P2P-GROUP-STARTED timeout on " + dev0
.p2p_dev_addr())
473 dev0
.group_form_result(ev
)
474 ev
= dev1
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
476 raise Exception("P2P-GROUP-STARTED timeout on " + dev1
.p2p_dev_addr())
477 dev1
.group_form_result(ev
)
479 if conncap0
== "2" and conncap1
== "4": # dev0 CLI, dev1 GO
480 dev_cli
, dev_go
, go_if
, join_address
, go_method
, cli_method
= dev0
, dev1
, go1
, join0
, method1
, method0
481 elif conncap0
== "4" and conncap1
== "2": # dev0 GO, dev1 CLI
482 dev_cli
, dev_go
, go_if
, join_address
, go_method
, cli_method
= dev1
, dev0
, go0
, join1
, method0
, method1
484 raise Exception("Bad connection capabilities")
487 raise Exception("Device " + dev_go
.p2p_dev_addr() + " failed to become GO")
488 if join_address
is None:
489 raise Exception("Device " + dev_cli
.p2p_dev_addr() + " failed to become CLI")
490 ev
= dev_go
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
492 raise Exception("P2P-GROUP-STARTED timeout on " + dev_go
.p2p_dev_addr())
493 dev_go
.group_form_result(ev
)
494 if go_method
!= "p2ps":
495 ev
= dev_go
.group_request("WPS_PIN any " + pin
)
497 raise Exception("Failed to initiate pin authorization on registrar side")
498 if "OK" not in dev_cli
.global_request("P2P_CONNECT " + join_address
+ " " + pin
+ " " + cli_method
+ " persistent join"):
499 raise Exception("P2P_CONNECT failed on " + dev_cli
.p2p_dev_addr())
500 ev
= dev_cli
.wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
502 raise Exception("P2P-GROUP-STARTED timeout on " + dev_cli
.p2p_dev_addr())
503 dev_cli
.group_form_result(ev
)
504 ev
= dev_go
.wait_global_event(["AP-STA-CONNECTED"], timeout
=10)
506 raise Exception("AP-STA-CONNECTED timeout on " + dev_go
.p2p_dev_addr())
508 hwsim_utils
.test_connectivity_p2p(dev0
, dev1
)
510 def set_no_group_iface(dev
, enable
):
512 res
= dev
.get_driver_status()
513 if (int(res
['capa.flags'], 0) & 0x20000000):
514 raise HwsimSkip("P2P Device used. Cannot set enable no_group_iface")
515 dev
.global_request("SET p2p_no_group_iface 1")
517 dev
.global_request("SET p2p_no_group_iface 0")
519 def test_p2ps_exact_search(dev
):
520 """P2PS exact service request"""
521 p2ps_advertise(r_dev
=dev
[0], r_role
='1', svc_name
='org.wi-fi.wfds.send.rx',
522 srv_info
='I can receive files upto size 2 GB')
523 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
524 svc_name
='org.wi-fi.wfds.send.rx')
526 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
528 raise Exception("Unable to remove the advertisement instance")
530 def test_p2ps_exact_search_srvinfo(dev
):
531 """P2PS exact service request with service info"""
532 p2ps_advertise(r_dev
=dev
[0], r_role
='0', svc_name
='org.wi-fi.wfds.send.rx',
533 srv_info
='I can receive files upto size 2 GB')
534 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
535 svc_name
='org.wi-fi.wfds.send.rx',
538 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
540 raise Exception("Unable to remove the advertisement instance")
542 def test_p2ps_nonexact_search(dev
):
543 """P2PS nonexact seek request"""
544 p2ps_advertise(r_dev
=dev
[0], r_role
='0', svc_name
='org.wi-fi.wfds.play.rx',
545 srv_info
='I support Miracast Mode ')
546 ev_list
= p2ps_nonexact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
547 svc_name
='org.wi-fi.wfds.play*')
548 adv_id
= ev_list
[0].split()[0]
550 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
552 raise Exception("Unable to remove the advertisement instance")
554 def test_p2ps_nonexact_search_srvinfo(dev
):
555 """P2PS nonexact seek request with service info"""
556 p2ps_advertise(r_dev
=dev
[0], r_role
='0', svc_name
='org.wi-fi.wfds.send.rx',
557 srv_info
='I can receive files upto size 2 GB')
558 ev_list
= p2ps_nonexact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
559 svc_name
='org.wi-fi.wfds.send*',
561 adv_id
= ev_list
[0].split()[0]
562 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
564 raise Exception("Unable to remove the advertisement instance")
566 def test_p2ps_connect_p2ps_method_nonautoaccept(dev
):
567 """P2PS connect for non-auto-accept and P2PS config method"""
568 addr0
= dev
[0].p2p_dev_addr()
569 addr1
= dev
[1].p2p_dev_addr()
570 p2ps_advertise(r_dev
=dev
[0], r_role
='0', svc_name
='org.wi-fi.wfds.send.rx',
571 srv_info
='I can receive files upto size 2 GB')
572 ev_list
= p2ps_nonexact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
573 svc_name
='org.wi-fi.wfds.send*',
575 adv_id
= ev_list
[0].split(" ")[0]
576 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=1000"):
577 raise Exception("Failed to request provisioning on seeker")
578 ev0
= dev
[0].wait_global_event(["P2PS-PROV-START"], timeout
=10)
580 raise Exception("P2PS-PROV-START timeout on advertiser side")
581 ev1
= dev
[1].wait_global_event(["P2P-PROV-DISC-FAILURE"], timeout
=15)
583 raise Exception("Provisioning deferred timeout on seeker side")
585 if "OK" not in dev
[0].global_request("P2P_ASP_PROVISION_RESP " + addr1
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " status=12"):
586 raise Exception("Failed to send deferred acceptance from advertizer")
587 ev1
= dev
[1].wait_global_event(["P2PS-PROV-DONE"], timeout
=15)
589 raise Exception("Failed to receive deferred acceptance at seeker")
591 p2p_connect_p2ps_method(i_dev
=dev
[1], r_dev
=dev
[0], autoaccept
=False)
592 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
594 raise Exception("Unable to remove the advertisement instance")
595 remove_group(dev
[0], dev
[1])
597 def test_p2ps_connect_p2ps_method_autoaccept(dev
):
598 """P2PS connection with P2PS default config method and auto-accept"""
599 addr0
= dev
[0].p2p_dev_addr()
600 addr1
= dev
[1].p2p_dev_addr()
601 p2ps_advertise(r_dev
=dev
[0], r_role
='1', svc_name
='org.wi-fi.wfds.send.rx',
602 srv_info
='I can receive files upto size 2 GB')
603 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
604 svc_name
='org.wi-fi.wfds.send.rx',
606 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=1000"):
607 raise Exception("P2P_ASP_PROVISION failed on seeker side")
609 ev0
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
611 raise Exception("P2PS-PROV-DONE timeout on advertiser side")
613 p2p_connect_p2ps_method(i_dev
=dev
[1], r_dev
=dev
[0], autoaccept
=True)
615 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
617 raise Exception("Unable to remove the advertisement instance")
618 remove_group(dev
[0], dev
[1])
620 def test_p2ps_connect_keypad_method_nonautoaccept(dev
):
621 """P2PS Connection with non-auto-accept and seeker having keypad method"""
622 addr0
= dev
[0].p2p_dev_addr()
623 addr1
= dev
[1].p2p_dev_addr()
624 p2ps_advertise(r_dev
=dev
[0], r_role
='0', svc_name
='org.wi-fi.wfds.send.rx',
625 srv_info
='I can receive files upto size 2 GB')
626 ev_list
= p2ps_nonexact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
627 svc_name
='org.wi-fi.wfds.send*',
629 adv_id
= ev_list
[0].split(" ")[0]
630 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=8"): # keypad method on seeker side
631 raise Exception("Failed to request provisioning on seeker")
632 p2ps_provision_keypad_method(i_dev
=dev
[1], r_dev
=dev
[0], autoaccept
=False,
633 initiator_or_responder
='initiator')
636 if "OK" not in dev
[0].global_request("P2P_ASP_PROVISION_RESP " + addr1
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " status=12"):
637 raise Exception("Failed to send deferred acceptance from advertizer")
639 pin
= p2ps_provision_display_method(i_dev
=dev
[1], r_dev
=dev
[0],
641 initiator_or_responder
='responder')
642 p2ps_connect_pin(pin
, i_dev
=dev
[0], r_dev
=dev
[1],
643 initiator_method
="display")
644 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
646 raise Exception("Unable to remove the advertisement instance")
647 remove_group(dev
[0], dev
[1])
649 def test_p2ps_connect_display_method_nonautoaccept(dev
):
650 """P2PS connection with non-auto-accept and seeker having display method"""
651 addr0
= dev
[0].p2p_dev_addr()
652 addr1
= dev
[1].p2p_dev_addr()
653 p2ps_advertise(r_dev
=dev
[0], r_role
='0', svc_name
='org.wi-fi.wfds.send.rx',
654 srv_info
='I can receive files upto size 2 GB')
655 ev_list
= p2ps_nonexact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
656 svc_name
='org.wi-fi.wfds*', srv_info
='2 GB')
657 adv_id
= ev_list
[0].split(" ")[0]
658 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=100"): # keypad method on seeker side
659 raise Exception("Failed to request provisioning on seeker")
660 pin
= p2ps_provision_display_method(i_dev
=dev
[1], r_dev
=dev
[0],
662 initiator_or_responder
='initiator')
665 if "OK" not in dev
[0].global_request("P2P_ASP_PROVISION_RESP " + addr1
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " status=12"):
666 raise Exception("Failed to send deferred acceptance from advertiser")
667 p2ps_provision_keypad_method(i_dev
=dev
[1], r_dev
=dev
[0], autoaccept
=False,
668 initiator_or_responder
='responder')
669 p2ps_connect_pin(pin
, i_dev
=dev
[0], r_dev
=dev
[1], initiator_method
="keypad")
671 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
673 raise Exception("Unable to remove the advertisement instance")
674 remove_group(dev
[0], dev
[1])
676 def test_p2ps_connect_keypad_method_autoaccept(dev
):
677 """P2PS connection with auto-accept and keypad method on seeker side"""
678 addr0
= dev
[0].p2p_dev_addr()
679 addr1
= dev
[1].p2p_dev_addr()
680 p2ps_advertise(r_dev
=dev
[0], r_role
='1', svc_name
='org.wi-fi.wfds.send.rx',
681 srv_info
='I can receive files upto size 2 GB')
682 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
683 svc_name
='org.wi-fi.wfds.send.rx',
685 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=8"): # keypad method on seeker side
686 raise Exception("Failed to request provisioning on seeker")
688 p2ps_provision_keypad_method(i_dev
=dev
[1], r_dev
=dev
[0], autoaccept
=True,
689 initiator_or_responder
='initiator')
690 pin
= p2ps_provision_display_method(i_dev
=dev
[1], r_dev
=dev
[0],
692 initiator_or_responder
='responder')
693 p2ps_connect_pin(pin
, i_dev
=dev
[1], r_dev
=dev
[0], initiator_method
="Keypad")
694 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
696 raise Exception("Unable to remove the advertisement instance")
697 remove_group(dev
[0], dev
[1])
699 def test_p2ps_connect_display_method_autoaccept(dev
):
700 """P2PS connection with auto-accept and display method on seeker side"""
701 addr0
= dev
[0].p2p_dev_addr()
702 addr1
= dev
[1].p2p_dev_addr()
703 p2ps_advertise(r_dev
=dev
[0], r_role
='1', svc_name
='org.wi-fi.wfds.send.rx',
704 srv_info
='I can receive files upto size 2 GB')
705 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
706 svc_name
='org.wi-fi.wfds.send.rx',
708 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=100"): # display method on seeker side
709 raise Exception("Failed to request provisioning on seeker")
711 pin
= p2ps_provision_display_method(i_dev
=dev
[1], r_dev
=dev
[0],
713 initiator_or_responder
='initiator')
716 p2ps_connect_pin(pin
, i_dev
=dev
[1], r_dev
=dev
[0], initiator_method
="display")
717 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
719 raise Exception("Unable to remove the advertisement instance")
720 remove_group(dev
[0], dev
[1])
722 def test_p2ps_connect_adv_go_p2ps_method(dev
):
723 """P2PS auto-accept connection with advertisement as GO and P2PS method"""
724 addr0
= dev
[0].p2p_dev_addr()
725 addr1
= dev
[1].p2p_dev_addr()
726 p2ps_advertise(r_dev
=dev
[0], r_role
='4', svc_name
='org.wi-fi.wfds.send.rx',
727 srv_info
='I can receive files upto size 2 GB')
728 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
729 svc_name
='org.wi-fi.wfds.send.rx',
731 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=1000"):
732 raise Exception("Failed to request provisioning on seeker")
734 ev0
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
736 raise Exception("Timed out while waiting for prov done on advertizer")
738 raise Exception("Advertiser failed to become GO")
740 adv_conncap
= ev0
.split("conncap=")[1].split(" ")[0]
741 if adv_conncap
== "4":
742 logger
.info("Advertiser is GO")
743 ev0
= dev
[0].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
745 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
746 dev
[0].group_form_result(ev0
)
748 ev1
= dev
[1].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
750 raise Exception("P2PS-PROV-DONE timeout on seeker side")
752 seeker_conncap
= ev1
.split("conncap=")[1].split(" ")[0]
755 if "OK" not in dev
[1].global_request("P2P_CONNECT " + addr0
+ " 12345670 p2ps persistent join"):
756 raise Exception("P2P_CONNECT failed on seeker side")
757 ev1
= dev
[1].wait_global_event(["P2P-GROUP-STARTED"], timeout
=15)
759 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
760 dev
[1].group_form_result(ev1
)
762 ev0
= dev
[0].wait_global_event(["AP-STA-CONNECTED"], timeout
=5)
764 raise Exception("AP-STA-CONNECTED timeout on advertiser side")
765 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
767 raise Exception("Unable to remove the advertisement instance")
768 remove_group(dev
[0], dev
[1])
770 def test_p2ps_connect_adv_client_p2ps_method(dev
):
771 """P2PS auto-accept connection with advertisement as Client and P2PS method"""
772 addr0
= dev
[0].p2p_dev_addr()
773 addr1
= dev
[1].p2p_dev_addr()
774 p2ps_advertise(r_dev
=dev
[0], r_role
='2', svc_name
='org.wi-fi.wfds.send.rx',
775 srv_info
='I can receive files upto size 2 GB')
776 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
777 svc_name
='org.wi-fi.wfds.send.rx',
779 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=1000"):
780 raise Exception("Failed to request provisioning on seeker")
782 ev0
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
784 raise Exception("P2PS-PROV-DONE timeout on advertiser side")
785 if "join=" not in ev0
:
786 raise Exception("Advertiser failed to become Client")
788 adv_conncap
= ev0
.split("conncap=")[1].split(" ")[0]
789 if adv_conncap
== "2":
790 logger
.info("Advertiser is Client")
792 ev1
= dev
[1].wait_global_event(["P2PS-PROV-DONE"], timeout
=5)
794 raise Exception("Provisioning failed on seeker side")
796 seeker_conncap
= ev1
.split("conncap=")[1].split(" ")[0]
797 ev1
= dev
[1].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
799 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
800 dev
[1].group_form_result(ev1
)
803 if "OK" not in dev
[0].global_request("P2P_CONNECT " + addr1
+ " 12345670 p2ps persistent join"):
804 raise Exception("P2P_CONNECT failed on seeker side")
806 ev0
= dev
[0].wait_global_event(["P2P-GROUP-FORMATION-SUCCESS"], timeout
=15)
808 raise Exception("P2P Group Formation failed on advertiser side")
810 ev0
= dev
[0].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
812 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
813 dev
[0].group_form_result(ev0
)
815 ev1
= dev
[1].wait_global_event(["AP-STA-CONNECTED"], timeout
=5)
817 raise Exception("Group formation failed")
818 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
820 raise Exception("Unable to remove the advertisement instance")
821 remove_group(dev
[0], dev
[1])
823 def p2ps_connect_adv_go_pin_method(dev
, keep_group
=False):
824 addr0
= dev
[0].p2p_dev_addr()
825 addr1
= dev
[1].p2p_dev_addr()
826 p2ps_advertise(r_dev
=dev
[0], r_role
='4', svc_name
='org.wi-fi.wfds.send.rx',
827 srv_info
='I can receive files upto size 2 GB')
828 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
829 svc_name
='org.wi-fi.wfds.send.rx',
831 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=8"): # keypad method on seeker side
832 raise Exception("Failed to request provisioning on seeker")
834 seek_prov_ev
= p2ps_provision_keypad_method(i_dev
=dev
[1], r_dev
=dev
[0],
836 initiator_or_responder
='initiator')
838 ev0
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
840 raise Exception("P2PS-PROV-DONE timeout on advertier side")
841 adv_conncap
= ev0
.split("conncap=")[1].split(" ")[0]
842 if adv_conncap
== "4":
843 logger
.info("Advertiser is GO")
844 ev0
= dev
[0].wait_global_event(["P2P-PROV-DISC-SHOW-PIN"], timeout
=5)
846 raise Exception("PIN Display on advertiser side")
847 pin
= ev0
.split(" ")[2]
849 ev0
= dev
[0].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
851 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
852 dev
[0].group_form_result(ev0
)
854 ev0
= dev
[0].group_request("WPS_PIN any " + pin
)
856 raise Exception("Failed to initiate Pin authorization on registrar side")
857 if "join=" in seek_prov_ev
:
858 if "OK" not in dev
[1].global_request("P2P_CONNECT " + addr0
+ " " + pin
+ " keypad persistent join"):
859 raise Exception("P2P_CONNECT failed on seeker side")
860 ev1
= dev
[1].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
862 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
863 dev
[1].group_form_result(ev1
)
865 ev0
= dev
[0].wait_global_event(["AP-STA-CONNECTED"], timeout
=10)
867 raise Exception("AP-STA-CONNECTED timeout on advertiser side")
870 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
872 raise Exception("Unable to remove the advertisement instance")
873 remove_group(dev
[0], dev
[1])
875 def test_p2ps_connect_adv_go_pin_method(dev
):
876 """P2PS advertiser as GO with keypad config method on seeker side and auto-accept"""
877 p2ps_connect_adv_go_pin_method(dev
)
879 def test_p2ps_connect_adv_client_pin_method(dev
):
880 """P2PS advertiser as client with keypad config method on seeker side and auto-accept"""
881 addr0
= dev
[0].p2p_dev_addr()
882 addr1
= dev
[1].p2p_dev_addr()
883 dev
[0].flush_scan_cache()
884 p2ps_advertise(r_dev
=dev
[0], r_role
='2', svc_name
='org.wi-fi.wfds.send.rx',
885 srv_info
='I can receive files upto size 2 GB')
886 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
887 svc_name
='org.wi-fi.wfds.send.rx',
889 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=8"): # keypad method on seeker side
890 raise Exception("Failed to request provisioning on seeker")
892 seek_prov_ev
= p2ps_provision_keypad_method(i_dev
=dev
[1], r_dev
=dev
[0],
894 initiator_or_responder
='initiator')
896 adv_prov
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
898 raise Exception("Prov failed on advertiser")
899 adv_conncap
= adv_prov
.split("conncap=")[1].split(" ")[0]
900 if adv_conncap
== "2":
901 logger
.info("Advertiser is Client")
902 adv_pin_show_event
= dev
[0].wait_global_event(["P2P-PROV-DISC-SHOW-PIN"],
904 if adv_pin_show_event
is None:
905 raise Exception("PIN Display on advertiser side")
906 pin
= adv_pin_show_event
.split(" ")[2]
908 ev1
= dev
[1].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
910 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
911 dev
[1].group_form_result(ev1
)
913 ev1
= dev
[1].group_request("WPS_PIN any " + pin
)
915 raise Exception("Failed to initiate Pin authorization on registrar side")
917 if "join=" in adv_prov
:
918 if "OK" not in dev
[0].global_request("P2P_CONNECT " + addr1
+ " " + pin
+ " display persistent join"):
919 raise Exception("P2P_CONNECT failed on advertiser side")
920 ev0
= dev
[0].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
922 raise Exception("Group formation failed to start on seeker side")
923 dev
[0].group_form_result(ev0
)
925 ev1
= dev
[1].wait_global_event(["AP-STA-CONNECTED"], timeout
=10)
927 raise Exception("AP-STA-CONNECTED timeout on advertiser side")
928 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
930 raise Exception("Unable to remove the advertisement instance")
931 remove_group(dev
[0], dev
[1])
933 def test_p2ps_service_discovery_multiple_queries(dev
):
934 """P2P service discovery with multiple queries"""
935 addr0
= dev
[0].p2p_dev_addr()
936 addr1
= dev
[1].p2p_dev_addr()
937 adv_id1
= p2ps_advertise(r_dev
=dev
[0], r_role
='0',
938 svc_name
='org.wi-fi.wfds.send.tx',
939 srv_info
='I can transfer files upto size of 2 GB')
940 adv_id2
= p2ps_advertise(r_dev
=dev
[0], r_role
='0',
941 svc_name
='org.wi-fi.wfds.send.rx',
942 srv_info
='I can receive files upto size of 2 GB')
943 adv_id3
= p2ps_advertise(r_dev
=dev
[0], r_role
='1',
944 svc_name
='org.wi-fi.wfds.display.tx',
945 srv_info
='Miracast Mode')
946 adv_id4
= p2ps_advertise(r_dev
=dev
[0], r_role
='1',
947 svc_name
='org.wi-fi.wfds.display.rx',
948 srv_info
='Miracast Mode')
950 dev
[1].global_request("P2P_SERV_DISC_REQ " + addr0
+ " asp 1 org.wi-fi.wfds.display.tx 'Miracast Mode'")
951 dev
[1].global_request("P2P_FIND 10 type=social seek=org.wi-fi.wfds.display.tx")
952 dev
[1].global_request("P2P_SERV_DISC_REQ " + addr0
+ " asp 2 org.wi-fi.wfds.send* 'size of 2 GB'")
953 dev
[1].p2p_stop_find()
954 dev
[1].global_request("P2P_FIND 10 type=social seek=")
955 ev
= dev
[1].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
957 raise Exception("P2P Device Found timed out")
959 raise Exception("Unexpected service discovery request source")
961 for i
in range(0, 3):
962 ev
= dev
[1].wait_global_event(["P2P-SERV-ASP-RESP"], timeout
=10)
964 raise Exception("P2P Service discovery timed out")
967 if len(ev_list
) == 3:
969 dev
[1].p2p_stop_find()
971 for test
in [ ("seek=org.wi-fi.wfds.display.TX",
972 "asp_svc=org.wi-fi.wfds.display.tx"),
973 ("seek=foo seek=org.wi-fi.wfds.display.tx seek=bar",
974 "asp_svc=org.wi-fi.wfds.display.tx"),
975 ("seek=1 seek=2 seek=3 seek=org.wi-fi.wfds.display.tx seek=4 seek=5 seek=6",
976 "asp_svc=org.wi-fi.wfds.display.tx"),
977 ("seek=not-found", None),
978 ("seek=org.wi-fi.wfds", "asp_svc=org.wi-fi.wfds")]:
979 dev
[2].global_request("P2P_FIND 10 type=social " + test
[0])
981 ev
= dev
[2].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=1)
983 raise Exception("Unexpected device found: " + ev
)
985 ev
= dev
[2].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
987 raise Exception("P2P device discovery timed out (dev2)")
988 if test
[1] not in ev
:
989 raise Exception("Expected asp_svc not reported: " + ev
)
990 dev
[2].p2p_stop_find()
991 dev
[2].request("P2P_FLUSH")
993 dev
[0].p2p_stop_find()
995 ev1
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id1
))
997 raise Exception("Unable to remove the advertisement instance")
998 ev2
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id2
))
1000 raise Exception("Unable to remove the advertisement instance")
1001 ev3
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id3
))
1003 raise Exception("Unable to remove the advertisement instance")
1004 ev4
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id4
))
1006 raise Exception("Unable to remove the advertisement instance")
1008 if "OK" not in dev
[0].global_request("P2P_SERVICE_ADD asp 1 12345678 1 1108 org.wi-fi.wfds.foobar svc_info='Test'"):
1009 raise Exception("P2P_SERVICE_ADD failed")
1010 if "OK" not in dev
[0].global_request("P2P_SERVICE_DEL asp all"):
1011 raise Exception("P2P_SERVICE_DEL asp all failed")
1012 if "OK" not in dev
[0].global_request("P2P_SERVICE_ADD asp 1 12345678 1 1108 org.wi-fi.wfds.foobar svc_info='Test'"):
1013 raise Exception("P2P_SERVICE_ADD failed")
1014 if "OK" not in dev
[0].global_request("P2P_SERVICE_REP asp 1 12345678 1 1108 org.wi-fi.wfds.foobar svc_info='Test'"):
1015 raise Exception("P2P_SERVICE_REP failed")
1016 if "FAIL" not in dev
[0].global_request("P2P_SERVICE_REP asp 1 12345678 1 1108 org.wi-fi.wfds.Foo svc_info='Test'"):
1017 raise Exception("Invalid P2P_SERVICE_REP accepted")
1018 if "OK" not in dev
[0].global_request("P2P_SERVICE_ADD asp 1 a2345678 1 1108 org.wi-fi.wfds.something svc_info='Test'"):
1019 raise Exception("P2P_SERVICE_ADD failed")
1020 if "OK" not in dev
[0].global_request("P2P_SERVICE_ADD asp 1 a2345679 1 1108 org.wi-fi.wfds.Foo svc_info='Test'"):
1021 raise Exception("P2P_SERVICE_ADD failed")
1024 with
open('/proc/net/dev', 'r') as f
:
1027 for line
in data
.splitlines():
1028 ifname
= line
.strip().split(' ')[0]
1029 if ':' not in ifname
:
1031 ifname
= ifname
.split(':')[0]
1032 ifnames
.append(ifname
)
1035 def p2ps_connect_p2ps_method(dev
, keep_group
=False):
1036 addr0
= dev
[0].p2p_dev_addr()
1037 addr1
= dev
[1].p2p_dev_addr()
1038 dev
[0].flush_scan_cache()
1039 dev
[1].flush_scan_cache()
1040 p2ps_advertise(r_dev
=dev
[0], r_role
='2', svc_name
='org.wi-fi.wfds.send.rx',
1041 srv_info
='I can receive files upto size 2 GB')
1042 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
1043 svc_name
='org.wi-fi.wfds.send.rx',
1045 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='test-session-info-data' method=1000"):
1046 raise Exception("Failed to request provisioning on seeker")
1048 ev0
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
1050 raise Exception("P2PS-PROV-DONE timeout on advertiser side")
1051 if "join=" not in ev0
:
1052 raise Exception("join parameter missing from P2PS-PROV-DONE")
1054 ev1
= dev
[1].wait_global_event(["P2PS-PROV-DONE"], timeout
=5)
1056 raise Exception("Provisioning failed on seeker side")
1058 ev1
= dev
[1].wait_global_event(["P2P-GROUP-STARTED"], timeout
=15)
1060 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
1061 res1
= dev
[1].group_form_result(ev1
)
1062 ifnames
= get_ifnames()
1064 if "OK" not in dev
[0].global_request("P2P_CONNECT " + addr1
+ " 12345670 p2ps persistent join"):
1065 raise Exception("P2P_CONNECT failed on seeker side")
1067 ev0
= dev
[0].wait_global_event(["P2P-GROUP-STARTED"], timeout
=15)
1069 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
1070 res0
= dev
[0].group_form_result(ev0
)
1072 ev1
= dev
[1].wait_global_event(["AP-STA-CONNECTED"], timeout
=5)
1074 raise Exception("Group formation failed")
1077 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
1079 raise Exception("Unable to remove the advertisement instance")
1080 ifnames
= ifnames
+ get_ifnames()
1081 remove_group(dev
[0], dev
[1])
1082 ifnames
= ifnames
+ get_ifnames()
1084 return (res0
, res1
, ifnames
)
1086 def has_string_prefix(vals
, prefix
):
1088 if val
.startswith(prefix
):
1092 def test_p2ps_connect_p2ps_method_1(dev
):
1093 """P2PS connection with P2PS method - no group interface"""
1094 set_no_group_iface(dev
[0], 1)
1095 set_no_group_iface(dev
[1], 1)
1097 (res0
, res1
, ifnames
) = p2ps_connect_p2ps_method(dev
)
1098 if res0
['ifname'] != dev
[0].ifname
:
1099 raise Exception("unexpected dev0 group ifname: " + res0
['ifname'])
1100 if res1
['ifname'] != dev
[1].ifname
:
1101 raise Exception("unexpected dev1 group ifname: " + res1
['ifname'])
1102 if has_string_prefix(ifnames
, 'p2p-' + res0
['ifname']):
1103 raise Exception("dev0 group interface unexpectedly present")
1104 if has_string_prefix(ifnames
, 'p2p-' + res1
['ifname']):
1105 raise Exception("dev1 group interface unexpectedly present")
1107 def test_p2ps_connect_p2ps_method_2(dev
):
1108 """P2PS connection with P2PS method - group interface on dev0"""
1109 set_no_group_iface(dev
[0], 0)
1110 set_no_group_iface(dev
[1], 1)
1112 (res0
, res1
, ifnames
) = p2ps_connect_p2ps_method(dev
)
1113 if not res0
['ifname'].startswith('p2p-' + dev
[0].ifname
+ '-'):
1114 raise Exception("unexpected dev0 group ifname: " + res0
['ifname'])
1115 if res1
['ifname'] != dev
[1].ifname
:
1116 raise Exception("unexpected dev1 group ifname: " + res1
['ifname'])
1117 if has_string_prefix(ifnames
, 'p2p-' + res0
['ifname']):
1118 raise Exception("dev0 group interface unexpectedly present")
1120 def test_p2ps_connect_p2ps_method_3(dev
):
1121 """P2PS connection with P2PS method - group interface on dev1"""
1122 set_no_group_iface(dev
[0], 1)
1123 set_no_group_iface(dev
[1], 0)
1125 (res0
, res1
, ifnames
) = p2ps_connect_p2ps_method(dev
)
1126 if res0
['ifname'] != dev
[0].ifname
:
1127 raise Exception("unexpected dev0 group ifname: " + res0
['ifname'])
1128 if not res1
['ifname'].startswith('p2p-' + dev
[1].ifname
+ '-'):
1129 raise Exception("unexpected dev1 group ifname: " + res1
['ifname'])
1130 if has_string_prefix(ifnames
, 'p2p-' + res0
['ifname']):
1131 raise Exception("dev0 group interface unexpectedly present")
1133 def test_p2ps_connect_p2ps_method_4(dev
):
1134 """P2PS connection with P2PS method - group interface on both"""
1135 set_no_group_iface(dev
[0], 0)
1136 set_no_group_iface(dev
[1], 0)
1138 (res0
, res1
, ifnames
) = p2ps_connect_p2ps_method(dev
)
1139 if not res0
['ifname'].startswith('p2p-' + dev
[0].ifname
+ '-'):
1140 raise Exception("unexpected dev0 group ifname: " + res0
['ifname'])
1141 if not res1
['ifname'].startswith('p2p-' + dev
[1].ifname
+ '-'):
1142 raise Exception("unexpected dev1 group ifname: " + res1
['ifname'])
1144 def test_p2ps_connect_adv_go_persistent(dev
):
1145 """P2PS auto-accept connection with advertisement as GO and having persistent group"""
1146 addr0
= dev
[0].p2p_dev_addr()
1147 addr1
= dev
[1].p2p_dev_addr()
1149 go_neg_pin_authorized_persistent(i_dev
=dev
[0], i_intent
=15,
1150 r_dev
=dev
[1], r_intent
=0)
1151 dev
[0].remove_group()
1152 dev
[1].wait_go_ending_session()
1154 p2ps_advertise(r_dev
=dev
[0], r_role
='4', svc_name
='org.wi-fi.wfds.send.rx',
1155 srv_info
='I can receive files upto size 2 GB')
1156 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[1], r_dev
=dev
[0],
1157 svc_name
='org.wi-fi.wfds.send.rx',
1159 if "OK" not in dev
[1].global_request("P2P_ASP_PROVISION " + addr0
+ " adv_id=" + str(adv_id
) + " adv_mac=" + addr0
+ " session=1 session_mac=" + addr1
+ " info='' method=1000"):
1160 raise Exception("Failed to request provisioning on seeker")
1162 ev0
= dev
[0].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
1164 raise Exception("Timed out while waiting for prov done on advertizer")
1165 if "persist=" not in ev0
:
1166 raise Exception("Advertiser did not indicate persistent group")
1167 id0
= ev0
.split("persist=")[1].split(" ")[0]
1168 if "OK" not in dev
[0].global_request("P2P_GROUP_ADD persistent=" + id0
+ " freq=2412"):
1169 raise Exception("Could not re-start persistent group")
1171 ev0
= dev
[0].wait_global_event(["P2P-GROUP-STARTED"], timeout
=10)
1173 raise Exception("P2P-GROUP-STARTED timeout on advertiser side")
1174 dev
[0].group_form_result(ev0
)
1176 ev1
= dev
[1].wait_global_event(["P2PS-PROV-DONE"], timeout
=10)
1178 raise Exception("P2PS-PROV-DONE timeout on seeker side")
1180 if "persist=" not in ev1
:
1181 raise Exception("Seeker did not indicate persistent group")
1182 id1
= ev1
.split("persist=")[1].split(" ")[0]
1183 if "OK" not in dev
[1].global_request("P2P_GROUP_ADD persistent=" + id1
+ " freq=2412"):
1184 raise Exception("Could not re-start persistent group")
1186 ev1
= dev
[1].wait_global_event(["P2P-GROUP-STARTED"], timeout
=15)
1188 raise Exception("P2P-GROUP-STARTED timeout on seeker side")
1189 dev
[1].group_form_result(ev1
)
1191 ev0
= dev
[0].wait_global_event(["AP-STA-CONNECTED"], timeout
=15)
1193 raise Exception("AP-STA-CONNECTED timeout on advertiser side")
1194 ev0
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
1196 raise Exception("Unable to remove the advertisement instance")
1197 remove_group(dev
[0], dev
[1])
1199 def test_p2ps_client_probe(dev
):
1200 """P2PS CLI discoverability on operating channel"""
1201 cli_probe
= dev
[0].global_request("SET p2p_cli_probe 1")
1202 p2ps_connect_p2ps_method(dev
, keep_group
=True)
1203 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[2], r_dev
=dev
[0],
1204 svc_name
='org.wi-fi.wfds.send.rx',
1205 single_peer_expected
=False)
1206 dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
1207 remove_group(dev
[0], dev
[1])
1209 def test_p2ps_go_probe(dev
):
1210 """P2PS GO discoverability on operating channel"""
1211 p2ps_connect_adv_go_pin_method(dev
, keep_group
=True)
1212 [adv_id
, rcvd_svc_name
] = p2ps_exact_seek(i_dev
=dev
[2], r_dev
=dev
[0],
1213 svc_name
='org.wi-fi.wfds.send.rx',
1214 single_peer_expected
=False)
1215 dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
1216 remove_group(dev
[0], dev
[1])
1218 def test_p2ps_wildcard_p2ps(dev
):
1219 """P2PS wildcard SD Probe Request/Response"""
1220 p2ps_wildcard
= "org.wi-fi.wfds"
1222 adv_id
= p2ps_advertise(r_dev
=dev
[0], r_role
='1',
1223 svc_name
='org.foo.service',
1224 srv_info
='I can do stuff')
1225 adv_id2
= p2ps_advertise(r_dev
=dev
[0], r_role
='1',
1226 svc_name
='org.wi-fi.wfds.send.rx',
1227 srv_info
='I can receive files upto size 2 GB')
1229 if "OK" not in dev
[1].global_request("P2P_FIND 10 type=social seek=org.foo.service seek=" + p2ps_wildcard
):
1230 raise Exception("Failed on P2P_FIND command")
1232 ev1
= dev
[1].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
1234 raise Exception("P2P-DEVICE-FOUND timeout on seeker side")
1235 if dev
[0].p2p_dev_addr() not in ev1
:
1236 raise Exception("Unexpected peer")
1238 ev2
= dev
[1].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
1240 raise Exception("P2P-DEVICE-FOUND timeout on seeker side (2)")
1241 if dev
[0].p2p_dev_addr() not in ev2
:
1242 raise Exception("Unexpected peer (2)")
1244 if p2ps_wildcard
not in ev1
+ ev2
:
1245 raise Exception("P2PS Wildcard name not found in P2P-DEVICE-FOUND event")
1246 if "org.foo.service" not in ev1
+ ev2
:
1247 raise Exception("Vendor specific service name not found in P2P-DEVICE-FOUND event")
1249 if "OK" not in dev
[1].global_request("P2P_STOP_FIND"):
1250 raise Exception("P2P_STOP_FIND failed")
1251 dev
[1].dump_monitor()
1253 res
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id
))
1255 raise Exception("Unable to remove the advertisement instance")
1257 if "OK" not in dev
[1].global_request("P2P_FIND 10 type=social seek=" + p2ps_wildcard
):
1258 raise Exception("Failed on P2P_FIND command")
1260 ev1
= dev
[1].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
1262 raise Exception("P2P-DEVICE-FOUND timeout on seeker side")
1263 if dev
[0].p2p_dev_addr() not in ev1
:
1264 raise Exception("Unexpected peer")
1265 if p2ps_wildcard
not in ev1
:
1266 raise Exception("P2PS Wildcard name not found in P2P-DEVICE-FOUND event (2)")
1267 dev
[1].dump_monitor()
1269 res
= dev
[0].global_request("P2P_SERVICE_DEL asp " + str(adv_id2
))
1271 raise Exception("Unable to remove the advertisement instance 2")
1273 if "OK" not in dev
[1].global_request("P2P_FIND 10 type=social seek=" + p2ps_wildcard
):
1274 raise Exception("Failed on P2P_FIND command")
1276 ev1
= dev
[1].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=2)
1278 raise Exception("Unexpected P2P-DEVICE-FOUND event on seeker side")
1279 dev
[1].p2p_stop_find()
1280 dev
[1].dump_monitor()
1282 def test_p2ps_many_services_in_probe(dev
):
1283 """P2PS with large number of services in Probe Request/Response"""
1284 long1
= 'org.example.0123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789.a'
1285 long2
= 'org.example.0123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789.b'
1286 long3
= 'org.example.0123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789.c'
1287 long4
= 'org.example.0123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789.d'
1288 long5
= 'org.example.0123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789.e'
1289 for name
in [ long1
, long2
, long3
, long4
, long5
]:
1290 p2ps_advertise(r_dev
=dev
[0], r_role
='1',
1292 srv_info
='I can do stuff')
1294 if "OK" not in dev
[1].global_request("P2P_FIND 10 type=social seek=%s seek=%s seek=%s seek=%s seek=%s" % (long1
, long2
, long3
, long4
, long5
)):
1295 raise Exception("Failed on P2P_FIND command")
1298 # Note: Require only four events since all the services do not fit within
1301 ev
= dev
[1].wait_global_event(["P2P-DEVICE-FOUND"], timeout
=10)
1303 raise Exception("Missing P2P-DEVICE-FOUND")
1304 events
= events
+ ev
1305 dev
[1].p2p_stop_find()
1306 dev
[1].dump_monitor()
1307 for name
in [ long2
, long3
, long4
, long5
]:
1308 if name
not in events
:
1309 raise Exception("Service missing from peer events")