summaryrefslogtreecommitdiffstats
path: root/Lib
diff options
context:
space:
mode:
authorSerhiy Storchaka <storchaka@gmail.com>2013-01-15 13:32:59 (GMT)
committerSerhiy Storchaka <storchaka@gmail.com>2013-01-15 13:32:59 (GMT)
commit44763dd7a709415b665090b5c5b0d3affeeef651 (patch)
treeef62a03d80e9c97937f12f4188f93eb1d4e4d3d2 /Lib
parent4fb8caee87fea1707f9a754365d5ec30c9220f6f (diff)
parent8838061119934b9019cbc53171c8ad159e8c7826 (diff)
downloadcpython-44763dd7a709415b665090b5c5b0d3affeeef651.zip
cpython-44763dd7a709415b665090b5c5b0d3affeeef651.tar.gz
cpython-44763dd7a709415b665090b5c5b0d3affeeef651.tar.bz2
Merge heads
Diffstat (limited to 'Lib')
-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 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):