Skip to content

Commit 757a9fb

Browse files
committed
check self._closing in Datagram _loop_reading
1 parent 92d347c commit 757a9fb

1 file changed

Lines changed: 2 additions & 10 deletions

File tree

Lib/asyncio/proactor_events.py

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -574,28 +574,20 @@ def write_next():
574574
def _loop_reading(self, fut=None):
575575
data = None
576576
try:
577-
if self._conn_lost:
577+
if self._closing:
578578
return
579579

580-
assert self._read_fut is fut or (self._read_fut is None and
581-
self._closing)
580+
assert self._read_fut is fut
582581

583582
self._read_fut = None
584583
if fut is not None:
585584
res = fut.result()
586585

587-
if self._closing:
588-
# since close() has been called we ignore any read data
589-
data = None
590-
return
591-
592586
if self._address is not None:
593587
data, addr = res, self._address
594588
else:
595589
data, addr = res
596590

597-
if self._conn_lost:
598-
return
599591
if self._address is not None:
600592
self._read_fut = self._loop._proactor.recv(self._sock,
601593
self.max_size)

0 commit comments

Comments
 (0)