equal
deleted
inserted
replaced
2551 |
2551 |
2552 runtests = list(tests) |
2552 runtests = list(tests) |
2553 done = queue.Queue() |
2553 done = queue.Queue() |
2554 running = 0 |
2554 running = 0 |
2555 |
2555 |
|
2556 channels_lock = threading.Lock() |
2556 channels = [""] * self._jobs |
2557 channels = [""] * self._jobs |
2557 |
2558 |
2558 def job(test, result): |
2559 def job(test, result): |
2559 for n, v in enumerate(channels): |
2560 with channels_lock: |
2560 if not v: |
2561 for n, v in enumerate(channels): |
2561 channel = n |
2562 if not v: |
2562 break |
2563 channel = n |
2563 else: |
2564 break |
2564 raise ValueError('Could not find output channel') |
2565 else: |
2565 channels[channel] = "=" + test.name[5:].split(".")[0] |
2566 raise ValueError('Could not find output channel') |
|
2567 channels[channel] = "=" + test.name[5:].split(".")[0] |
2566 |
2568 |
2567 r = None |
2569 r = None |
2568 try: |
2570 try: |
2569 test(result) |
2571 test(result) |
2570 except KeyboardInterrupt: |
2572 except KeyboardInterrupt: |