[pypy-svn] r78657 - in pypy/branch/fast-forward/pypy/module/_multiprocessing: . test

[afa at codespeak.net]

Author: afa
Date: Wed Nov  3 09:25:55 2010
New Revision: 78657

Modified:
   pypy/branch/fast-forward/pypy/module/_multiprocessing/interp_connection.py
   pypy/branch/fast-forward/pypy/module/_multiprocessing/test/test_connection.py
Log:
poll() should not work on write-only connections


Modified: pypy/branch/fast-forward/pypy/module/_multiprocessing/interp_connection.py
==============================================================================
--- pypy/branch/fast-forward/pypy/module/_multiprocessing/interp_connection.py	(original)
+++ pypy/branch/fast-forward/pypy/module/_multiprocessing/interp_connection.py	Wed Nov  3 09:25:55 2010
@@ -165,6 +165,7 @@
 
     @unwrap_spec('self', ObjSpace, W_Root)
     def poll(self, space, w_timeout=0.0):
+        self._check_readable(space)
         if space.is_w(w_timeout, space.w_None):
             timeout = -1.0 # block forever
         else:

Modified: pypy/branch/fast-forward/pypy/module/_multiprocessing/test/test_connection.py
==============================================================================
--- pypy/branch/fast-forward/pypy/module/_multiprocessing/test/test_connection.py	(original)
+++ pypy/branch/fast-forward/pypy/module/_multiprocessing/test/test_connection.py	Wed Nov  3 09:25:55 2010
@@ -52,6 +52,7 @@
         assert rhandle.poll(None) == True
         assert rhandle.recv() == 1
         assert rhandle.poll() == False
+        raises(IOError, whandle.poll)
 
     def test_read_into(self):
         import array, multiprocessing
@@ -83,7 +84,7 @@
         cls.w_make_pair = cls.space.appexec([], """():
             import multiprocessing
             def make_pair():
-                rhandle, whandle = multiprocessing.Pipe()
+                rhandle, whandle = multiprocessing.Pipe(duplex=False)
                 return rhandle, whandle
             return make_pair
         """)