Qubes/core-admin
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

tests: improve audio tests

Browse Source 
- wait for the client be listed in dom0
- report parecord stderr
- allow up to 20ms to be missing, to account for potentially suspended
  device initially
This commit is contained in:
Marek Marczykowski-Górecki 2020-04-06 02:21:05 +02:00
parent 3066190283
commit 8420adf973
No known key found for this signature in database
GPG Key ID: 063938BA42CFA724
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
qubes/tests/integ/vm_qrexec_gui.py
View File

@ -1195,6 +1195,13 @@ class TC_00_AppVMMixin(object):
except subprocess.CalledProcessError as e: except subprocess.CalledProcessError as e:
self.fail('Timeout waiting for pulseaudio start in {}: {}{}'.format( self.fail('Timeout waiting for pulseaudio start in {}: {}{}'.format(
vm.name, e.stdout, e.stderr)) vm.name, e.stdout, e.stderr))
# then wait for the stream to appear in dom0
local_user = grp.getgrnam('qubes').gr_mem[0]
p = self.loop.run_until_complete(asyncio.create_subprocess_shell(
"sudo -E -u {} timeout 30s sh -c '"
"while ! pactl list sink-inputs | grep -q :{}; do sleep 1; done'".format(
local_user, vm.name)))
self.loop.run_until_complete(p.wait())
# and some more... # and some more...
self.loop.run_until_complete(asyncio.sleep(1)) self.loop.run_until_complete(asyncio.sleep(1))
@ -1234,10 +1241,10 @@ class TC_00_AppVMMixin(object):
# for some reason sudo do not relay SIGTERM sent above # for some reason sudo do not relay SIGTERM sent above
subprocess.check_call(['pkill', 'parecord']) subprocess.check_call(['pkill', 'parecord'])
p.wait() p.wait()
# allow few bytes missing, don't use assertIn, to avoid printing # allow up to 20ms missing, don't use assertIn, to avoid printing
# the whole data in error message # the whole data in error message
recorded_audio = recorded_audio.file.read() recorded_audio = recorded_audio.file.read()
if audio_in[:-8] not in recorded_audio: if audio_in[:-3528] not in recorded_audio:
found_bytes = recorded_audio.count(audio_in[0]) found_bytes = recorded_audio.count(audio_in[0])
all_bytes = len(audio_in) all_bytes = len(audio_in)
self.fail('played sound not found in dom0, ' self.fail('played sound not found in dom0, '
@ -1338,12 +1345,15 @@ class TC_00_AppVMMixin(object):
# wait for possible parecord buffering # wait for possible parecord buffering
self.loop.run_until_complete(asyncio.sleep(1)) self.loop.run_until_complete(asyncio.sleep(1))
self.loop.run_until_complete( self.loop.run_until_complete(
self.testvm1.run_for_stdio('pkill parecord')) self.testvm1.run_for_stdio('pkill parecord || :'))
self.loop.run_until_complete(record.wait()) _, record_stderr = self.loop.run_until_complete(record.communicate())
if record_stderr:
self.fail('parecord printed something on stderr: {}'.format(
record_stderr))
recorded_audio, _ = self.loop.run_until_complete( recorded_audio, _ = self.loop.run_until_complete(
self.testvm1.run_for_stdio('cat audio_rec.raw')) self.testvm1.run_for_stdio('cat audio_rec.raw'))
# allow few bytes to be missing # allow up to 20ms to be missing
if audio_in[:-8] not in recorded_audio: if audio_in[:-3528] not in recorded_audio:
found_bytes = recorded_audio.count(audio_in[0]) found_bytes = recorded_audio.count(audio_in[0])
all_bytes = len(audio_in) all_bytes = len(audio_in)
self.fail('VM not recorded expected data, ' self.fail('VM not recorded expected data, '