aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/Lib/asyncio/selector_events.py
diff options
context:
space:
mode:
authorVictor Stinner <victor.stinner@gmail.com>2015-01-09 01:42:52 +0100
committerVictor Stinner <victor.stinner@gmail.com>2015-01-09 01:42:52 +0100
commit3531d9044dbfd15b3bf5ec1abe5b9744fce37464 (patch)
tree4b4846bc3c351148f8bb8e6355b18710e6660e92 /Lib/asyncio/selector_events.py
parent399c59d7bd5caeacfd98338d69400f83f15987db (diff)
downloadcpython-3531d9044dbfd15b3bf5ec1abe5b9744fce37464.tar.gz
cpython-3531d9044dbfd15b3bf5ec1abe5b9744fce37464.zip
asyncio: sync with Tulip
* Document why set_result() calls are safe * Cleanup gather(). Use public methods instead of hacks to consume the exception of a future. * sock_connect(): pass directly the fd to _sock_connect_done instead of the socket.
Diffstat (limited to 'Lib/asyncio/selector_events.py')
-rw-r--r--Lib/asyncio/selector_events.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
index 69b649ceeae..58b61f1c89e 100644
--- a/Lib/asyncio/selector_events.py
+++ b/Lib/asyncio/selector_events.py
@@ -363,15 +363,15 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
break
except BlockingIOError:
fut.add_done_callback(functools.partial(self._sock_connect_done,
- sock))
+ fd))
self.add_writer(fd, self._sock_connect_cb, fut, sock, address)
except Exception as exc:
fut.set_exception(exc)
else:
fut.set_result(None)
- def _sock_connect_done(self, sock, fut):
- self.remove_writer(sock.fileno())
+ def _sock_connect_done(self, fd, fut):
+ self.remove_writer(fd)
def _sock_connect_cb(self, fut, sock, address):
if fut.cancelled():