tests: NAN USD
Signed-off-by: Jouni Malinen <quic_jouni@quicinc.com>
This commit is contained in:
Jouni Malinen
Jouni Malinen
parent
3a5d1a7e6d
commit
9c281a9eaa
1 changed files with 410 additions and 0 deletions
410
tests/hwsim/test_nan_usd.py
Normal file
410
tests/hwsim/test_nan_usd.py
Normal file
|
|
@ -0,0 +1,410 @@
|
|||
# Test cases for Wi-Fi Aware unsynchronized service discovery (NAN USD)
|
||||
# Copyright (c) 2024, Qualcomm Innovation Center, Inc.
|
||||
#
|
||||
# This software may be distributed under the terms of the BSD license.
|
||||
# See README for more details.
|
||||
|
||||
import time
|
||||
|
||||
import logging
|
||||
logger = logging.getLogger()
|
||||
|
||||
import hostapd
|
||||
from utils import *
|
||||
|
||||
def check_nan_usd_capab(dev):
|
||||
capa = dev.request("GET_CAPABILITY nan")
|
||||
if "USD" not in capa:
|
||||
raise HwsimSkip("NAN USD not supported")
|
||||
|
||||
def test_nan_usd_publish(dev, apdev):
|
||||
"""NAN USD Publish"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
cmd = "NAN_UPDATE_PUBLISH publish_id=" + id0 + " ssi=1122334455"
|
||||
if "FAIL" in dev[0].request(cmd):
|
||||
raise Exception("NAN_UPDATE_PUBLISH failed")
|
||||
|
||||
cmd = "NAN_CANCEL_PUBLISH publish_id=" + id0
|
||||
if "FAIL" in dev[0].request(cmd):
|
||||
raise Exception("NAN_CANCEL_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=1)
|
||||
if ev is None:
|
||||
raise Exception("PublishTerminated event not seen")
|
||||
if "publish_id=" + id0 not in ev:
|
||||
raise Exception("Unexpected publish_id: " + ev)
|
||||
if "reason=user-request" not in ev:
|
||||
raise Exception("Unexpected reason: " + ev)
|
||||
|
||||
cmd = "NAN_PUBLISH service_name=_test"
|
||||
count = 0
|
||||
for i in range(256):
|
||||
if "FAIL" in dev[0].request(cmd):
|
||||
break
|
||||
count += 1
|
||||
logger.info("Maximum services: %d" % count)
|
||||
for i in range(count):
|
||||
cmd = "NAN_CANCEL_PUBLISH publish_id=%s" % (i + 1)
|
||||
if "FAIL" in dev[0].request(cmd):
|
||||
raise Exception("NAN_CANCEL_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=1)
|
||||
if ev is None:
|
||||
raise Exception("PublishTerminated event not seen")
|
||||
|
||||
def test_nan_usd_subscribe(dev, apdev):
|
||||
"""NAN USD Subscribe"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test active=1 srv_proto_type=2 ssi=1122334455"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
cmd = "NAN_CANCEL_SUBSCRIBE subscribe_id=" + id0
|
||||
if "FAIL" in dev[0].request(cmd):
|
||||
raise Exception("NAN_CANCEL_SUBSCRIBE failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-SUBSCRIBE-TERMINATED"], timeout=1)
|
||||
if ev is None:
|
||||
raise Exception("SubscribeTerminated event not seen")
|
||||
if "subscribe_id=" + id0 not in ev:
|
||||
raise Exception("Unexpected subscribe_id: " + ev)
|
||||
if "reason=user-request" not in ev:
|
||||
raise Exception("Unexpected reason: " + ev)
|
||||
|
||||
def test_nan_usd_match(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test srv_proto_type=2 ssi=1122334455"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677 ttl=5"
|
||||
id0 = dev[1].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-DISCOVERY-RESULT"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen")
|
||||
if "srv_proto_type=2" not in ev.split(' '):
|
||||
raise Exception("Unexpected srv_proto_type: " + ev)
|
||||
if "ssi=6677" not in ev.split(' '):
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
|
||||
# Check for publisher and subscriber functionality to time out
|
||||
ev = dev[0].wait_event(["NAN-SUBSCRIBE-TERMINATED"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("Subscribe not terminated")
|
||||
ev = dev[1].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("Publish not terminated")
|
||||
|
||||
def test_nan_usd_match2(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match (2)"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677 ttl=10 fsd=0"
|
||||
id0 = dev[1].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
time.sleep(1)
|
||||
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test srv_proto_type=2 ssi=1122334455 active=1"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-DISCOVERY-RESULT"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen")
|
||||
if "srv_proto_type=2" not in ev.split(' '):
|
||||
raise Exception("Unexpected srv_proto_type: " + ev)
|
||||
if "ssi=6677" not in ev.split(' '):
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
|
||||
# Check for publisher and subscriber functionality to time out
|
||||
ev = dev[0].wait_event(["NAN-SUBSCRIBE-TERMINATED"], timeout=2)
|
||||
if ev is None:
|
||||
raise Exception("Subscribe not terminated")
|
||||
ev = dev[1].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("Publish not terminated")
|
||||
|
||||
def test_nan_usd_match3(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match (3)"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test srv_proto_type=2 ssi=1122334455 active=1"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
time.sleep(0.05)
|
||||
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677 ttl=10"
|
||||
id0 = dev[1].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-DISCOVERY-RESULT"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen")
|
||||
if "srv_proto_type=2" not in ev.split(' '):
|
||||
raise Exception("Unexpected srv_proto_type: " + ev)
|
||||
if "ssi=6677" not in ev.split(' '):
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
|
||||
# Check for publisher and subscriber functionality to time out
|
||||
ev = dev[0].wait_event(["NAN-SUBSCRIBE-TERMINATED"], timeout=2)
|
||||
if ev is None:
|
||||
raise Exception("Subscribe not terminated")
|
||||
ev = dev[1].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("Publish not terminated")
|
||||
|
||||
def split_nan_event(ev):
|
||||
vals = dict()
|
||||
for p in ev.split(' ')[1:]:
|
||||
name, val = p.split('=')
|
||||
vals[name] = val
|
||||
return vals
|
||||
|
||||
def test_nan_usd_followup(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match and follow-up"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
run_nan_usd_followup(dev[0], dev[1])
|
||||
|
||||
def test_nan_usd_followup_multi_chan(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match and follow-up with multi channels"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
run_nan_usd_followup(dev[0], dev[1], multi_chan=True)
|
||||
|
||||
def test_nan_usd_followup_hostapd(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match and follow-up with hostapd"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
hapd = hostapd.add_ap(apdev[0], {"ssid": "open",
|
||||
"channel": "6"})
|
||||
run_nan_usd_followup(hapd, dev[1])
|
||||
|
||||
def run_nan_usd_followup(dev0, dev1, multi_chan=False):
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test srv_proto_type=3 ssi=1122334455"
|
||||
if multi_chan:
|
||||
cmd += " freq=2462"
|
||||
id0 = dev0.request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=3 ssi=6677 ttl=10"
|
||||
if multi_chan:
|
||||
cmd += " freq=2412 freq_list=2437,2462"
|
||||
id1 = dev1.request(cmd)
|
||||
if "FAIL" in id1:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
ev = dev0.wait_event(["NAN-DISCOVERY-RESULT"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen")
|
||||
vals = split_nan_event(ev)
|
||||
if vals['srv_proto_type'] != '3':
|
||||
raise Exception("Unexpected srv_proto_type: " + ev)
|
||||
if vals['ssi'] != '6677':
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
if vals['subscribe_id'] != id0:
|
||||
raise Exception("Unexpected subscribe_id: " + ev)
|
||||
if vals['publish_id'] != id1:
|
||||
raise Exception("Unexpected publish_id: " + ev)
|
||||
addr1 = vals['address']
|
||||
|
||||
# Automatically sent Follow-up message without ssi
|
||||
ev = dev1.wait_event(["NAN-RECEIVE"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("Receive event not seen")
|
||||
vals2 = split_nan_event(ev)
|
||||
if vals2['ssi'] != '':
|
||||
raise Exception("Unexpected ssi in Follow-up: " + ev)
|
||||
|
||||
# Follow-up from subscriber to publisher
|
||||
cmd = "NAN_TRANSMIT handle={} req_instance_id={} address={} ssi=8899".format(vals['subscribe_id'], vals['publish_id'], addr1)
|
||||
if "FAIL" in dev0.request(cmd):
|
||||
raise Exception("NAN_TRANSMIT failed")
|
||||
|
||||
ev = dev1.wait_event(["NAN-RECEIVE"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("Receive event not seen")
|
||||
vals = split_nan_event(ev)
|
||||
if vals['ssi'] != '8899':
|
||||
raise Exception("Unexpected ssi in Follow-up: " + ev)
|
||||
if vals['id'] != id1:
|
||||
raise Exception("Unexpected id: " + ev)
|
||||
if vals['peer_instance_id'] != id0:
|
||||
raise Exception("Unexpected peer_instance_id: " + ev)
|
||||
addr0 = vals['address']
|
||||
|
||||
# Follow-up from publisher to subscriber
|
||||
cmd = "NAN_TRANSMIT handle={} req_instance_id={} address={} ssi=aabbccdd".format(id1, vals['peer_instance_id'], addr0)
|
||||
if "FAIL" in dev1.request(cmd):
|
||||
raise Exception("NAN_TRANSMIT failed")
|
||||
|
||||
ev = dev0.wait_event(["NAN-RECEIVE"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("Receive event not seen")
|
||||
vals = split_nan_event(ev)
|
||||
if vals['ssi'] != 'aabbccdd':
|
||||
raise Exception("Unexpected ssi in Follow-up: " + ev)
|
||||
if vals['id'] != id0:
|
||||
raise Exception("Unexpected id: " + ev)
|
||||
if vals['peer_instance_id'] != id1:
|
||||
raise Exception("Unexpected peer_instance_id: " + ev)
|
||||
|
||||
# Check for publisher and subscriber functionality to time out
|
||||
ev = dev0.wait_event(["NAN-SUBSCRIBE-TERMINATED"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("Subscribe not terminated")
|
||||
ev = dev1.wait_event(["NAN-PUBLISH-TERMINATED"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("Publish not terminated")
|
||||
|
||||
def test_nan_usd_solicited_publisher(dev, apdev):
|
||||
"""NAN USD Publish/Subscribe match with solicited-only Publisher"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test unsolicited=0 srv_proto_type=2 ssi=6677"
|
||||
id1 = dev[1].request(cmd)
|
||||
if "FAIL" in id1:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test active=1 srv_proto_type=2 ssi=1122334455"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-DISCOVERY-RESULT"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen")
|
||||
vals = split_nan_event(ev)
|
||||
if vals['srv_proto_type'] != "2":
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
if vals['ssi'] != "6677":
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
|
||||
ev = dev[1].wait_event(["NAN-REPLIED"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("Replied event not seen")
|
||||
vals = split_nan_event(ev)
|
||||
if vals['publish_id'] != id1:
|
||||
raise Exception("Unexpected publish_id: " + ev)
|
||||
if vals['subscribe_id'] != id0:
|
||||
raise Exception("Unexpected subscribe_id: " + ev)
|
||||
if vals['address'] != dev[0].own_addr():
|
||||
raise Exception("Unexpected address: " + ev)
|
||||
if vals['srv_proto_type'] != "2":
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
if vals['ssi'] != "1122334455":
|
||||
raise Exception("Unexpected ssi: " + ev)
|
||||
|
||||
def test_nan_usd_solicited_publisher_timeout(dev, apdev):
|
||||
"""NAN USD solicited Publisher timeout"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test unsolicited=0 ttl=10 srv_proto_type=2 ssi=6677"
|
||||
id = dev[0].request(cmd)
|
||||
if "FAIL" in id:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=2)
|
||||
if ev is not None:
|
||||
raise Exception("Too quick Publish termination")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("Publish not terminated")
|
||||
if "reason=timeout" not in ev:
|
||||
raise Exception("Unexpected reason: " + ev)
|
||||
|
||||
def test_nan_usd_unsolicited_publisher_timeout(dev, apdev):
|
||||
"""NAN USD unsolicited Publisher timeout"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test solicited=0 ttl=10 srv_proto_type=2 ssi=6677"
|
||||
id = dev[0].request(cmd)
|
||||
if "FAIL" in id:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=2)
|
||||
if ev is not None:
|
||||
raise Exception("Too quick Publish termination")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=10)
|
||||
if ev is None:
|
||||
raise Exception("Publish not terminated")
|
||||
if "reason=timeout" not in ev:
|
||||
raise Exception("Unexpected reason: " + ev)
|
||||
|
||||
def test_nan_usd_publish_all_chans(dev, apdev):
|
||||
"""NAN USD Publish - all channels"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677 freq_list=all ttl=10"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=15)
|
||||
if ev is None:
|
||||
raise Exception("PublishTerminated event not seen")
|
||||
|
||||
def test_nan_usd_publish_multi_chan(dev, apdev):
|
||||
"""NAN USD Publish - multi channel"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677 freq_list=2412,2462 ttl=10"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=15)
|
||||
if ev is None:
|
||||
raise Exception("PublishTerminated event not seen")
|
||||
|
||||
def test_nan_usd_publish_multi_chan_solicited(dev, apdev):
|
||||
"""NAN USD Publish - multi channel - solicited"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test unsolicited=0 srv_proto_type=2 ssi=6677 freq_list=2412,2462 ttl=10"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=15)
|
||||
if ev is None:
|
||||
raise Exception("PublishTerminated event not seen")
|
||||
|
||||
def test_nan_usd_publish_multi_chan_pause(dev, apdev):
|
||||
"""NAN USD Publish - multi channel"""
|
||||
check_nan_usd_capab(dev[0])
|
||||
cmd = "NAN_PUBLISH service_name=_test srv_proto_type=2 ssi=6677 freq_list=2412,2462 ttl=10"
|
||||
id0 = dev[0].request(cmd)
|
||||
if "FAIL" in id0:
|
||||
raise Exception("NAN_PUBLISH failed")
|
||||
|
||||
time.sleep(1)
|
||||
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test srv_proto_type=2 ssi=1122334455"
|
||||
id1 = dev[1].request(cmd)
|
||||
if "FAIL" in id1:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
cmd = "NAN_SUBSCRIBE service_name=_test srv_proto_type=2 ssi=8899 active=1"
|
||||
id2 = dev[2].request(cmd)
|
||||
if "FAIL" in id2:
|
||||
raise Exception("NAN_SUBSCRIBE failed")
|
||||
|
||||
ev = dev[1].wait_event(["NAN-DISCOVERY-RESULT"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen (1)")
|
||||
|
||||
ev = dev[2].wait_event(["NAN-DISCOVERY-RESULT"], timeout=5)
|
||||
if ev is None:
|
||||
raise Exception("DiscoveryResult event not seen (2)")
|
||||
|
||||
ev = dev[0].wait_event(["NAN-PUBLISH-TERMINATED"], timeout=15)
|
||||
if ev is None:
|
||||
raise Exception("PublishTerminated event not seen")
|
||||
Loading…
Reference in a new issue