diff options
author | Victor Stinner <vstinner@python.org> | 2021-04-16 12:32:01 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-04-16 12:32:01 (GMT) |
commit | 75ec103b3adbb7c619a0e22fa60f3d34c5a9e603 (patch) | |
tree | f5659351ffe9e214978409fec2b8008b402c2409 /Lib/test/test_logging.py | |
parent | 471870fc504b0d69c767b188f180b17248be6998 (diff) | |
download | cpython-75ec103b3adbb7c619a0e22fa60f3d34c5a9e603.zip cpython-75ec103b3adbb7c619a0e22fa60f3d34c5a9e603.tar.gz cpython-75ec103b3adbb7c619a0e22fa60f3d34c5a9e603.tar.bz2 |
bpo-43842: Fix race condition in test_logging SMTP test (GH-25436)
Fix a race condition in the SMTP test of test_logging. Don't close a
file descriptor (socket) from a different thread while
asyncore.loop() is polling the file descriptor.
Diffstat (limited to 'Lib/test/test_logging.py')
-rw-r--r-- | Lib/test/test_logging.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/Lib/test/test_logging.py b/Lib/test/test_logging.py index 6179e28..bb31e29 100644 --- a/Lib/test/test_logging.py +++ b/Lib/test/test_logging.py @@ -829,6 +829,7 @@ class TestSMTPServer(smtpd.SMTPServer): self.port = self.socket.getsockname()[1] self._handler = handler self._thread = None + self._quit = False self.poll_interval = poll_interval def process_message(self, peer, mailfrom, rcpttos, data): @@ -860,16 +861,18 @@ class TestSMTPServer(smtpd.SMTPServer): :func:`select` or :func:`poll` call by :func:`asyncore.loop`. """ - asyncore.loop(poll_interval, map=self._map) + while not self._quit: + asyncore.loop(poll_interval, map=self._map, count=1) def stop(self): """ Stop the thread by closing the server instance. Wait for the server thread to terminate. """ - self.close() + self._quit = True threading_helper.join_thread(self._thread) self._thread = None + self.close() asyncore.close_all(map=self._map, ignore_all=True) |