summaryrefslogtreecommitdiffstats
path: root/Lib/test/test_logging.py
diff options
context:
space:
mode:
authorVictor Stinner <vstinner@python.org>2021-04-16 12:32:01 (GMT)
committerGitHub <noreply@github.com>2021-04-16 12:32:01 (GMT)
commit75ec103b3adbb7c619a0e22fa60f3d34c5a9e603 (patch)
treef5659351ffe9e214978409fec2b8008b402c2409 /Lib/test/test_logging.py
parent471870fc504b0d69c767b188f180b17248be6998 (diff)
downloadcpython-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.py7
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)