diff options
author | Ned Batchelder <nedbat@gmail.com> | 2015-12-24 09:02:59 -0500 |
---|---|---|
committer | Ned Batchelder <nedbat@gmail.com> | 2015-12-24 09:02:59 -0500 |
commit | 82ce62cafc73167f66914126abd831a1d1acab69 (patch) | |
tree | d5999167fa4fa73f9be66c53f90028c2d859d5e2 /coverage/monkey.py | |
parent | 795a3679f89ed98bb278daf075123d0b55fd091e (diff) | |
parent | d9ca4b3f6501effe8e8dca1de836c28ca3321b4e (diff) | |
download | python-coveragepy-82ce62cafc73167f66914126abd831a1d1acab69.tar.gz |
Merged in rodcloutier/coverage.py/windows_multiprocessing_support (pull request #76)
Fix Windows support for multiprocessing monkey patch
Diffstat (limited to 'coverage/monkey.py')
-rw-r--r-- | coverage/monkey.py | 42 |
1 files changed, 22 insertions, 20 deletions
diff --git a/coverage/monkey.py b/coverage/monkey.py index c4ec68c..b896dbf 100644 --- a/coverage/monkey.py +++ b/coverage/monkey.py @@ -11,6 +11,28 @@ import sys # monkey-patched. PATCHED_MARKER = "_coverage$patched" +if sys.version_info >= (3, 4): + + klass = multiprocessing.process.BaseProcess +else: + klass = multiprocessing.Process + +original_bootstrap = klass._bootstrap + + +class ProcessWithCoverage(klass): + """A replacement for multiprocess.Process that starts coverage.""" + def _bootstrap(self): + """Wrapper around _bootstrap to start coverage.""" + from coverage import Coverage + cov = Coverage(data_suffix=True) + cov.start() + try: + return original_bootstrap(self) + finally: + cov.stop() + cov.save() + def patch_multiprocessing(): """Monkey-patch the multiprocessing module. @@ -23,26 +45,6 @@ def patch_multiprocessing(): return if sys.version_info >= (3, 4): - klass = multiprocessing.process.BaseProcess - else: - klass = multiprocessing.Process - - original_bootstrap = klass._bootstrap - - class ProcessWithCoverage(klass): - """A replacement for multiprocess.Process that starts coverage.""" - def _bootstrap(self): - """Wrapper around _bootstrap to start coverage.""" - from coverage import Coverage - cov = Coverage(data_suffix=True) - cov.start() - try: - return original_bootstrap(self) - finally: - cov.stop() - cov.save() - - if sys.version_info >= (3, 4): klass._bootstrap = ProcessWithCoverage._bootstrap else: multiprocessing.Process = ProcessWithCoverage |