diff options
author | Jesse Noller <jnoller@gmail.com> | 2009-06-30 17:11:52 (GMT) |
---|---|---|
committer | Jesse Noller <jnoller@gmail.com> | 2009-06-30 17:11:52 (GMT) |
commit | 1b90efbdc5bb204fe50aea87374603dcba309227 (patch) | |
tree | 42a36dca54321c6caf5e9ca488bdc1be1988b9d2 /Lib/test/test_multiprocessing.py | |
parent | 0c9eb431491387fc68940e2b24dc873f3147e0c8 (diff) | |
download | cpython-1b90efbdc5bb204fe50aea87374603dcba309227.zip cpython-1b90efbdc5bb204fe50aea87374603dcba309227.tar.gz cpython-1b90efbdc5bb204fe50aea87374603dcba309227.tar.bz2 |
Resolves issues 5155, 5313, 5331 - bad file descriptor error with processes in processes
Diffstat (limited to 'Lib/test/test_multiprocessing.py')
-rw-r--r-- | Lib/test/test_multiprocessing.py | 70 |
1 files changed, 69 insertions, 1 deletions
diff --git a/Lib/test/test_multiprocessing.py b/Lib/test/test_multiprocessing.py index baaece8..1e4a98e 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 +from StringIO import StringIO _multiprocessing = test_support.import_module('_multiprocessing') @@ -1861,7 +1862,74 @@ class TestInitializers(unittest.TestCase): p.join() self.assertEqual(self.ns.test, 1) -testcases_other = [OtherTest, TestInvalidHandle, TestInitializers] +# +# Issue 5155, 5313, 5331: Test process in processes +# Verifies os.close(sys.stdin.fileno) vs. sys.stdin.close() behavior +# + +def _ThisSubProcess(q): + try: + item = q.get(block=False) + except Queue.Empty: + pass + +def _TestProcess(q): + queue = multiprocessing.Queue() + subProc = multiprocessing.Process(target=_ThisSubProcess, args=(queue,)) + subProc.start() + subProc.join() + +def _afunc(x): + return x*x + +def pool_in_process(): + pool = multiprocessing.Pool(processes=4) + x = pool.map(_afunc, [1, 2, 3, 4, 5, 6, 7]) + +class _file_like(object): + def __init__(self, delegate): + self._delegate = delegate + self._pid = None + + @property + def cache(self): + pid = os.getpid() + # There are no race conditions since fork keeps only the running thread + if pid != self._pid: + self._pid = pid + self._cache = [] + return self._cache + + def write(self, data): + self.cache.append(data) + + def flush(self): + self._delegate.write(''.join(self.cache)) + self._cache = [] + +class TestStdinBadfiledescriptor(unittest.TestCase): + + def test_queue_in_process(self): + queue = multiprocessing.Queue() + proc = multiprocessing.Process(target=_TestProcess, args=(queue,)) + proc.start() + proc.join() + + def test_pool_in_process(self): + p = multiprocessing.Process(target=pool_in_process) + p.start() + p.join() + + def test_flushing(self): + sio = StringIO() + flike = _file_like(sio) + flike.write('foo') + proc = multiprocessing.Process(target=lambda: flike.flush()) + flike.flush() + assert sio.getvalue() == 'foo' + +testcases_other = [OtherTest, TestInvalidHandle, TestInitializers, + TestStdinBadfiledescriptor] # # |