summaryrefslogtreecommitdiffstats
path: root/Lib
diff options
context:
space:
mode:
authorRichard Oudkerk <shibturn@gmail.com>2012-08-14 10:41:32 (GMT)
committerRichard Oudkerk <shibturn@gmail.com>2012-08-14 10:41:32 (GMT)
commite88a2445bc31dce0caa0be9b543689a953c1f920 (patch)
treecdb9dc044ec4584b1610e6f03ce995ac4a9f5f75 /Lib
parent296d1bea6aab9c5cb78ec4f90369352aba64d7c5 (diff)
downloadcpython-e88a2445bc31dce0caa0be9b543689a953c1f920.zip
cpython-e88a2445bc31dce0caa0be9b543689a953c1f920.tar.gz
cpython-e88a2445bc31dce0caa0be9b543689a953c1f920.tar.bz2
Issue #15646: Prevent equivalent of a fork bomb when using multiprocessing
on Windows without the "if __name__ == '__main__'" idiom.
Diffstat (limited to 'Lib')
-rw-r--r--Lib/multiprocessing/forking.py2
-rw-r--r--Lib/test/mp_fork_bomb.py13
-rw-r--r--Lib/test/test_multiprocessing.py23
3 files changed, 36 insertions, 2 deletions
diff --git a/Lib/multiprocessing/forking.py b/Lib/multiprocessing/forking.py
index 4e24d6a..bc8ac44 100644
--- a/Lib/multiprocessing/forking.py
+++ b/Lib/multiprocessing/forking.py
@@ -331,7 +331,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 847deb4..ab6d36a 100644
--- a/Lib/test/test_multiprocessing.py
+++ b/Lib/test/test_multiprocessing.py
@@ -18,6 +18,7 @@ import socket
import random
import logging
import test.support
+import test.script_helper
# Skip tests if _multiprocessing wasn't built.
@@ -2429,9 +2430,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, TestInvalidFamily,
- TestTimeouts]
+ TestTimeouts, TestNoForkBomb]
#
#