| hg-reviewers |
| Lint Skipped |
| Unit Tests Skipped |
| Test UI worker interaction | Test UI worker interaction | ||||
| $ cat > t.py <<EOF | $ cat > t.py <<EOF | ||||
| > from __future__ import absolute_import, print_function | > from __future__ import absolute_import, print_function | ||||
| > import time | > import time | ||||
| > from mercurial import ( | > from mercurial import ( | ||||
| > error, | > error, | ||||
| > registrar, | > registrar, | ||||
| > ui as uimod, | > ui as uimod, | ||||
| > worker, | > worker, | ||||
| > ) | > ) | ||||
| > def abort(ui, args): | > def abort(ui, args): | ||||
| > if args[0] == 0: | > if args[0] == 0: | ||||
| > # by first worker for test stability | > # by first worker for test stability | ||||
| > raise error.Abort('known exception') | > raise error.Abort(b'known exception') | ||||
| > return runme(ui, []) | > return runme(ui, []) | ||||
| > def exc(ui, args): | > def exc(ui, args): | ||||
| > if args[0] == 0: | > if args[0] == 0: | ||||
| > # by first worker for test stability | > # by first worker for test stability | ||||
| > raise Exception('unknown exception') | > raise Exception('unknown exception') | ||||
| > return runme(ui, []) | > return runme(ui, []) | ||||
| > def runme(ui, args): | > def runme(ui, args): | ||||
| > for arg in args: | > for arg in args: | ||||
| > ui.status('run\n') | > ui.status(b'run\n') | ||||
| > yield 1, arg | > yield 1, arg | ||||
| > time.sleep(0.1) # easier to trigger killworkers code path | > time.sleep(0.1) # easier to trigger killworkers code path | ||||
| > functable = { | > functable = { | ||||
| > 'abort': abort, | > b'abort': abort, | ||||
| > 'exc': exc, | > b'exc': exc, | ||||
| > 'runme': runme, | > b'runme': runme, | ||||
| > } | > } | ||||
| > cmdtable = {} | > cmdtable = {} | ||||
| > command = registrar.command(cmdtable) | > command = registrar.command(cmdtable) | ||||
| > @command(b'test', [], 'hg test [COST] [FUNC]') | > @command(b'test', [], b'hg test [COST] [FUNC]') | ||||
| > def t(ui, repo, cost=1.0, func='runme'): | > def t(ui, repo, cost=1.0, func=b'runme'): | ||||
| > cost = float(cost) | > cost = float(cost) | ||||
| > func = functable[func] | > func = functable[func] | ||||
| > ui.status('start\n') | > ui.status(b'start\n') | ||||
| > runs = worker.worker(ui, cost, func, (ui,), range(8)) | > runs = worker.worker(ui, cost, func, (ui,), range(8)) | ||||
| > for n, i in runs: | > for n, i in runs: | ||||
| > pass | > pass | ||||
| > ui.status('done\n') | > ui.status(b'done\n') | ||||
| > EOF | > EOF | ||||
| $ abspath=`pwd`/t.py | $ abspath=`pwd`/t.py | ||||
| $ hg init | $ hg init | ||||
| Run tests with worker enable by forcing a heigh cost | Run tests with worker enable by forcing a heigh cost | ||||
| $ hg --config "extensions.t=$abspath" test 100000.0 | $ hg --config "extensions.t=$abspath" test 100000.0 | ||||
| start | start | ||||