diff options
author | Richard Oudkerk <shibturn@gmail.com> | 2012-08-14 11:51:14 (GMT) |
---|---|---|
committer | Richard Oudkerk <shibturn@gmail.com> | 2012-08-14 11:51:14 (GMT) |
commit | 3165a75e45817e858b77ce307cebb93657249dc2 (patch) | |
tree | 7511830c6138de57f2f45ac10ea2a3ba9293e052 /Lib | |
parent | e471772fff6cde0f0f30aab62bb4c4d57271bbcf (diff) | |
parent | e88a2445bc31dce0caa0be9b543689a953c1f920 (diff) | |
download | cpython-3165a75e45817e858b77ce307cebb93657249dc2.zip cpython-3165a75e45817e858b77ce307cebb93657249dc2.tar.gz cpython-3165a75e45817e858b77ce307cebb93657249dc2.tar.bz2 |
Merge 3.2
Diffstat (limited to 'Lib')
-rw-r--r-- | Lib/multiprocessing/forking.py | 2 | ||||
-rw-r--r-- | Lib/test/mp_fork_bomb.py | 13 | ||||
-rw-r--r-- | Lib/test/test_multiprocessing.py | 23 |
3 files changed, 36 insertions, 2 deletions
diff --git a/Lib/multiprocessing/forking.py b/Lib/multiprocessing/forking.py index 3beb816..af6580d 100644 --- a/Lib/multiprocessing/forking.py +++ b/Lib/multiprocessing/forking.py @@ -305,7 +305,7 @@ else: ''' Returns prefix of command line used for spawning a child process ''' - if process.current_process()._identity==() and is_forking(sys.argv): + if getattr(process.current_process(), '_inheriting', False): raise RuntimeError(''' Attempt to start a new process before the current process has finished its bootstrapping phase. diff --git a/Lib/test/mp_fork_bomb.py b/Lib/test/mp_fork_bomb.py new file mode 100644 index 0000000..908afe3 --- /dev/null +++ b/Lib/test/mp_fork_bomb.py @@ -0,0 +1,13 @@ +import multiprocessing, sys + +def foo(): + print("123") + +# Because "if __name__ == '__main__'" is missing this will not work +# correctly on Windows. However, we should get a RuntimeError rather +# than the Windows equivalent of a fork bomb. + +p = multiprocessing.Process(target=foo) +p.start() +p.join() +sys.exit(p.exitcode) diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py index afb0bee..57252a7 100644 --- a/Lib/test/test_multiprocessing.py +++ b/Lib/test/test_multiprocessing.py @@ -20,6 +20,7 @@ import random import logging import struct import test.support +import test.script_helper # Skip tests if _multiprocessing wasn't built. @@ -3346,9 +3347,29 @@ class TestTimeouts(unittest.TestCase): finally: socket.setdefaulttimeout(old_timeout) +# +# Test what happens with no "if __name__ == '__main__'" +# + +class TestNoForkBomb(unittest.TestCase): + def test_noforkbomb(self): + name = os.path.join(os.path.dirname(__file__), 'mp_fork_bomb.py') + if WIN32: + rc, out, err = test.script_helper.assert_python_failure(name) + self.assertEqual('', out.decode('ascii')) + self.assertIn('RuntimeError', err.decode('ascii')) + else: + rc, out, err = test.script_helper.assert_python_ok(name) + self.assertEqual('123', out.decode('ascii').rstrip()) + self.assertEqual('', err.decode('ascii')) + +# +# +# + testcases_other = [OtherTest, TestInvalidHandle, TestInitializers, TestStdinBadfiledescriptor, TestWait, TestInvalidFamily, - TestFlags, TestTimeouts] + TestFlags, TestTimeouts, TestNoForkBomb] # # |