This is an archive of the discontinued Mercurial Phabricator instance.

Differential D1718

worker: handle interrupt on windows
ClosedPublic

Authored by wlis on Dec 18 2017, 6:19 PM.

Details

Reviewers
krbullock
Group Reviewers
hg-reviewers
Commits
rHG44fd4cfc6c0a: worker: handle interrupt on windows
Summary

After applying suggestions from https://phab.mercurial-scm.org/D1564
to catch all exceptions in the same way I actually broke the handling of
KeyboardInterrupt on windows. The reason is that KeyboardInterrupt doesn't
dervie from Exception, but BaseException:
https://docs.python.org/2/library/exceptions.html starting from python 2.5

Test Plan

Run hg on windows and ctrl-c during a large update. No random
exceptions from threads surface in the shell. Previously we'd nearly always get
stack traces from some of threads

Run tests ./run-tests.py
[...]
Failed test-convert-svn-encoding.t: output changed

Ran 622 tests, 41 skipped, 1 failed.

python hash seed: 2962682116

The test failing seems to have nothing to do with the change and fails on base
revision as well

Diff Detail

Repository
rHG Mercurial
Lint
Lint Skipped
Unit
Unit Tests Skipped

Event Timeline

wlis created this revision.Dec 18 2017, 6:19 PM
krbullock accepted this revision.Dec 18 2017, 10:55 PM
krbullock added a subscriber: krbullock.

Whoops, queued, thanks.

This revision is now accepted and ready to land.Dec 18 2017, 10:55 PM
Closed by commit rHG44fd4cfc6c0a: worker: handle interrupt on windows (authored by wlis). · Explain WhyDec 18 2017, 11:22 PM
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Mmercurial/worker.py (2 lines)

Diff 4533

mercurial/worker.py

while not resultqueue.empty(): while not resultqueue.empty():
yield resultqueue.get() yield resultqueue.get()
threads[0].join(0.05) threads[0].join(0.05)
finishedthreads = [_t for _t in threads if not _t.is_alive()] finishedthreads = [_t for _t in threads if not _t.is_alive()]
for t in finishedthreads: for t in finishedthreads:
if t.exception is not None: if t.exception is not None:
raise t.exception raise t.exception
threads.remove(t) threads.remove(t)
except Exception: # re-raises except (Exception, KeyboardInterrupt): # re-raises
trykillworkers() trykillworkers()
raise raise
while not resultqueue.empty(): while not resultqueue.empty():
yield resultqueue.get() yield resultqueue.get()
if pycompat.iswindows: if pycompat.iswindows:
_platformworker = _windowsworker _platformworker = _windowsworker
else: else: