mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-04 17:08:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

gh-109370: Fix unexpected traceback output in test_concurrent_futures (GH-109780)

Browse source 
Follow-up of gh-107219.

* Only close the connection writer on Windows.
* Also use existing constant _winapi.ERROR_OPERATION_ABORTED instead of
  WSA_OPERATION_ABORTED.
This commit is contained in:
Serhiy Storchaka 2023-09-26 10:06:07 +03:00 • committed by GitHub
parent 4091deba88
commit 0b4e090422
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
Lib/concurrent/futures/process.py
View file

@ -521,7 +521,8 @@ class _ExecutorManagerThread(threading.Thread):
# gh-107219: Close the connection writer which can unblock
# Queue._feed() if it was stuck in send_bytes().
self.call_queue._writer.close()
if sys.platform == 'win32':
self.call_queue._writer.close()
# clean up resources
self.join_executor_internals()

3
Lib/multiprocessing/connection.py
View file

@ -42,7 +42,6 @@ except ImportError:
BUFSIZE = 8192
# A very generous timeout when it comes to local connections...
CONNECTION_TIMEOUT = 20.
WSA_OPERATION_ABORTED = 995
_mmap_counter = itertools.count()
@ -300,7 +299,7 @@ if _winapi:
finally:
self._send_ov = None
nwritten, err = ov.GetOverlappedResult(True)
if err == WSA_OPERATION_ABORTED:
if err == _winapi.ERROR_OPERATION_ABORTED:
# close() was called by another thread while
# WaitForMultipleObjects() was waiting for the overlapped
# operation.