[Python-checkins] cpython (merge 3.2 -> 3.2): Merge heads

serhiy.storchaka python-checkins at python.org
Tue Jan 15 14:40:07 CET 2013


http://hg.python.org/cpython/rev/2ededf960837
changeset:   81522:2ededf960837
branch:      3.2
parent:      81518:13cd78a2a17b
parent:      81514:49d45151b9ed
user:        Serhiy Storchaka <storchaka at gmail.com>
date:        Tue Jan 15 15:32:59 2013 +0200
summary:
  Merge heads

files:
  Lib/multiprocessing/connection.py |  23 -------------------
  1 files changed, 0 insertions(+), 23 deletions(-)


diff --git a/Lib/multiprocessing/connection.py b/Lib/multiprocessing/connection.py
--- a/Lib/multiprocessing/connection.py
+++ b/Lib/multiprocessing/connection.py
@@ -41,7 +41,6 @@
 import time
 import tempfile
 import itertools
-import select
 
 import _multiprocessing
 from multiprocessing import current_process, AuthenticationError
@@ -214,28 +213,6 @@
         return c1, c2
 
 else:
-    if hasattr(select, 'poll'):
-        def _poll(fds, timeout):
-            if timeout is not None:
-                timeout = int(timeout) * 1000  # timeout is in milliseconds
-            fd_map = {}
-            pollster = select.poll()
-            for fd in fds:
-                pollster.register(fd, select.POLLIN)
-                if hasattr(fd, 'fileno'):
-                    fd_map[fd.fileno()] = fd
-                else:
-                    fd_map[fd] = fd
-            ls = []
-            for fd, event in pollster.poll(timeout):
-                if event & select.POLLNVAL:
-                    raise ValueError('invalid file descriptor %i' % fd)
-                ls.append(fd_map[fd])
-            return ls
-    else:
-        def _poll(fds, timeout):
-            return select.select(fds, [], [], timeout)[0]
-
     from _multiprocessing import win32
 
     def Pipe(duplex=True):

-- 
Repository URL: http://hg.python.org/cpython


More information about the Python-checkins mailing list