Very rare exception in the case of reconnect

This commit is contained in:
Andrey Egorov 2018-03-18 20:41:00 +03:00
parent a6c6bc73eb
commit 236fccea7f

View File

@ -169,7 +169,7 @@ class TcpClient:
def _sock_recv(self, fut, registered_fd, n):
if registered_fd is not None:
self._loop.remove_reader(registered_fd)
if fut.cancelled():
if fut.cancelled() or self._socket is None:
return
try:
@ -193,7 +193,7 @@ class TcpClient:
def _sock_sendall(self, fut, registered_fd, data):
if registered_fd:
self._loop.remove_writer(registered_fd)
if fut.cancelled():
if fut.cancelled() or self._socket is None:
return
try: