diff options
author | Victor Stinner <victor.stinner@gmail.com> | 2015-01-09 00:51:43 +0100 |
---|---|---|
committer | Victor Stinner <victor.stinner@gmail.com> | 2015-01-09 00:51:43 +0100 |
commit | e63f6c5bf0da187ce7c4db85c68fb0b8fd23ba4f (patch) | |
tree | e8608bac08d5fb727d18a25a8411fe72d3661764 | |
parent | 73a5c0c24bf42bc3d9ca5d8fb7fb91c127e34139 (diff) | |
download | trollius-e63f6c5bf0da187ce7c4db85c68fb0b8fd23ba4f.tar.gz |
sock_connect(): pass directly the fd to _sock_connect_done instead of the socket
-rw-r--r-- | asyncio/selector_events.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/asyncio/selector_events.py b/asyncio/selector_events.py index 69b649c..58b61f1 100644 --- a/asyncio/selector_events.py +++ b/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(): |