Merge pull request #605 from nose-devs/add-fix-for-subproc-tests

Add a fix for nose2's own subprocess tests (on top of #601)

Author: sirosen

.gitignore

@@ -9,7 +9,7 @@
 *$py.class
 *.orig
 example.cfg
-.coverage
+.coverage*
 .idea
 nosetests.xml
 xunit.xml

nose2/plugins/coverage.py

@@ -55,6 +55,7 @@ def __init__(self):
         self.covConfig = (
             self.config.as_str("coverage-config", "").strip() or ".coveragerc"
         )
+        self.covCombine = self.config.as_bool("coverage-combine", False)
 
         group = self.session.pluginargs
         group.add_argument(
@@ -125,8 +126,8 @@ def beforeSummaryReport(self, event):
             # requesting a better fix in nedbat/coveragepy#34
             self.covController.save()
 
-            if self._mpmode:
-                self.covController.combine(strict=True)
+            if self.covCombine or self._mpmode:
+                self.covController.combine(strict=self._mpmode)
 
             percent_coverage = None
 

nose2/tests/_common.py

@@ -81,6 +81,19 @@ def assertTestRunOutputMatches(self, proc, stdout=None, stderr=None):
         if stderr:
             self.assertRegex(util.safe_decode(cmd_stderr), stderr)
 
+    def runInProc(self, working_dir, *args, timeout=10):
+        if not os.path.isabs(working_dir):
+            working_dir = support_file(working_dir)
+
+        proc = subprocess.Popen(
+            [sys.executable, "-m", "nose2"] + list(args),
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE,
+            cwd=working_dir,
+        )
+        proc.wait(timeout=timeout)
+        return proc
+
     def runIn(self, testdir, *args, **kw):
         return run_nose2(*args, cwd=testdir, **kw)
 

nose2/tests/functional/support/scenario/coverage_multiprocessing_with_combine/.coveragerc

@@ -0,0 +1,2 @@
+[run]
+concurrency = multiprocessing

nose2/tests/functional/support/scenario/coverage_multiprocessing_with_combine/lib/__init__.py

@@ -0,0 +1,12 @@
+from multiprocessing import Process
+
+
+def method2():
+    return
+
+
+def method():
+    p = Process(target=method2)
+    p.start()
+    p.join()
+    return True

nose2/tests/functional/support/scenario/coverage_multiprocessing_with_combine/lib/mod1.py

@@ -0,0 +1,5 @@
+[coverage]
+always-on = True
+coverage = lib
+coverage-config = .coveragerc
+coverage-combine = True

nose2/tests/functional/support/scenario/coverage_multiprocessing_with_combine/nose2.cfg

@@ -0,0 +1,8 @@
+import unittest
+
+from lib.mod1 import method
+
+
+class TestLib(unittest.TestCase):
+    def test1(self):
+        self.assertEqual(method(), True)

nose2/tests/functional/support/scenario/coverage_multiprocessing_with_combine/test_lib.py

@@ -0,0 +1,2 @@
+[run]
+concurrency = multiprocessing