diff options
author | Serhiy Storchaka <storchaka@gmail.com> | 2013-01-15 13:32:59 (GMT) |
---|---|---|
committer | Serhiy Storchaka <storchaka@gmail.com> | 2013-01-15 13:32:59 (GMT) |
commit | 44763dd7a709415b665090b5c5b0d3affeeef651 (patch) | |
tree | ef62a03d80e9c97937f12f4188f93eb1d4e4d3d2 | |
parent | 4fb8caee87fea1707f9a754365d5ec30c9220f6f (diff) | |
parent | 8838061119934b9019cbc53171c8ad159e8c7826 (diff) | |
download | cpython-44763dd7a709415b665090b5c5b0d3affeeef651.zip cpython-44763dd7a709415b665090b5c5b0d3affeeef651.tar.gz cpython-44763dd7a709415b665090b5c5b0d3affeeef651.tar.bz2 |
Merge heads
-rw-r--r-- | Lib/multiprocessing/connection.py | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/Lib/multiprocessing/connection.py b/Lib/multiprocessing/connection.py index f73faf6..a5dc2a8 100644 --- a/Lib/multiprocessing/connection.py +++ b/Lib/multiprocessing/connection.py @@ -41,7 +41,6 @@ import errno import time import tempfile import itertools -import select import _multiprocessing from multiprocessing import current_process, AuthenticationError @@ -214,28 +213,6 @@ if sys.platform != 'win32': 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): |