@@ -254,7 +254,7 @@ async def wait_preload(
254
254
timeout = 60 ,
255
255
):
256
256
"""Waiting for completion avoids coroutine objects leaking."""
257
- logger .info ("preload_max= '%s'" , preload_max )
257
+ logger .info ("preload_max: '%s'" , preload_max )
258
258
if not appvm :
259
259
appvm = self .dvm
260
260
for _ in range (timeout ):
@@ -332,7 +332,8 @@ def run_latency_calls(self, test):
332
332
"set -eu --; "
333
333
f'max_concurrency="{ MAX_CONCURRENCY } "; '
334
334
f"for i in $(seq { self .iterations } ); do "
335
- f" out=$({ cmd } ) { term } "
335
+ ' echo "$i"; '
336
+ f" { cmd } { term } "
336
337
' pid="${!-}"; '
337
338
' if test -n "${pid}"; then '
338
339
' set -- "${@}" "${pid}"; '
@@ -347,7 +348,7 @@ def run_latency_calls(self, test):
347
348
start_time = get_time ()
348
349
try :
349
350
if test .from_dom0 :
350
- subprocess .run (code , shell = True , check = True , timeout = timeout )
351
+ subprocess .run (code , shell = True , check = True , capture_output = True , timeout = timeout )
351
352
else :
352
353
self .vm1 .run (code , timeout = timeout )
353
354
except subprocess .CalledProcessError as e :
@@ -565,6 +566,8 @@ def run_test(self, test: TestConfig):
565
566
else :
566
567
result = self .run_latency_calls (test )
567
568
self .report_result (test , result )
569
+ except :
570
+ logger .error ("Failed to run test: '%s'" , test .name )
568
571
finally :
569
572
if test .preload_max :
570
573
old_preload_max = int (
0 commit comments