Lines Matching refs:test_queue
95 def vm_read_stdout(vm, test_queue): argument
149 test_queue.append((name, vm['current_count'] + 1))
203 def vm_next_step(_vm, scr, test_queue): argument
211 if not test_queue:
218 (name, count) = test_queue.pop(0)
227 def check_vm_start(scr, sel, test_queue): argument
243 if vm[i]['cmd'] and len(test_queue) > num_starting and \
254 def vm_terminated(_vm, scr, sel, test_queue): argument
273 if test_queue:
278 if len(test_queue) > num_vm:
326 test_queue = [(t, 0) for t in tests]
352 if vm_read_stdout(_vm, test_queue):
353 vm_next_step(_vm, scr, test_queue)
357 if vm_terminated(_vm, scr, sel, test_queue):
360 running, run_update = check_vm_start(scr, sel, test_queue)