summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSerhiy Storchaka <storchaka@gmail.com>2013-01-15 15:32:49 +0200
committerSerhiy Storchaka <storchaka@gmail.com>2013-01-15 15:32:49 +0200
commitbdea5ec574bb456b4d8ca576cdd4752161f03497 (patch)
treebcd17014e09ecc221fa76f7d034c13ee45997c6f
parent9599745e2cad406d6e8e38b3bb5727a3d2335a3e (diff)
parent7796b08664d07e65b9b7bb612fce8cbd99a26c55 (diff)
downloadcpython-git-bdea5ec574bb456b4d8ca576cdd4752161f03497.tar.gz
Merge heads
-rw-r--r--Lib/multiprocessing/connection.py23
1 files changed, 0 insertions, 23 deletions
diff --git a/Lib/multiprocessing/connection.py b/Lib/multiprocessing/connection.py
index 74db09451f..57bf811eda 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
@@ -201,28 +200,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):