mirror of
https://github.com/linuxserver/docker-python.git
synced 2026-02-19 17:24:19 +08:00
temp push 3.13.11 with HA patches
This commit is contained in:
parent
63b9627546
commit
5345705be6
2
.github/workflows/external_trigger.yml
vendored
2
.github/workflows/external_trigger.yml
vendored
@ -29,7 +29,7 @@ jobs:
|
||||
echo "> [!NOTE]" >> $GITHUB_STEP_SUMMARY
|
||||
echo "> External trigger running off of alpine322 branch. To disable this trigger, add \`python_alpine322\` into the Github organizational variable \`SKIP_EXTERNAL_TRIGGER\`." >> $GITHUB_STEP_SUMMARY
|
||||
printf "\n## Retrieving external version\n\n" >> $GITHUB_STEP_SUMMARY
|
||||
EXT_RELEASE=$(curl -u ${{ secrets.CR_USER }}:${{ secrets.CR_PAT }} -sX GET https://api.github.com/repos/python/cpython/tags | jq -r '.[] | select(.name | contains("rc") or contains("a") or contains("b") | not) | .name' | sed 's|^v||g' | sort -rV | head -1)
|
||||
EXT_RELEASE=$(echo 3.13.11)
|
||||
echo "Type is \`custom_version_command\`" >> $GITHUB_STEP_SUMMARY
|
||||
if grep -q "^python_alpine322_${EXT_RELEASE}" <<< "${SKIP_EXTERNAL_TRIGGER}"; then
|
||||
echo "> [!WARNING]" >> $GITHUB_STEP_SUMMARY
|
||||
|
||||
2
Jenkinsfile
vendored
2
Jenkinsfile
vendored
@ -147,7 +147,7 @@ pipeline {
|
||||
steps{
|
||||
script{
|
||||
env.EXT_RELEASE = sh(
|
||||
script: ''' curl -sX GET https://api.github.com/repos/python/cpython/tags | jq -r '.[] | select(.name | contains("rc") or contains("a") or contains("b") | not) | .name' | sed 's|^v||g' | sort -rV | head -1 ''',
|
||||
script: ''' echo 3.13.11 ''',
|
||||
returnStdout: true).trim()
|
||||
env.RELEASE_LINK = 'custom_command'
|
||||
}
|
||||
|
||||
@ -3,7 +3,7 @@
|
||||
# jenkins variables
|
||||
project_name: docker-python
|
||||
external_type: na
|
||||
custom_version_command: "curl -sX GET https://api.github.com/repos/python/cpython/tags | jq -r '.[] | select(.name | contains(\"rc\") or contains(\"a\") or contains(\"b\") | not) | .name' | sed 's|^v||g' | sort -rV | head -1"
|
||||
custom_version_command: "echo 3.13.11"
|
||||
release_type: stable
|
||||
release_tag: alpine322
|
||||
ls_branch: alpine322
|
||||
|
||||
@ -1,17 +0,0 @@
|
||||
Author: Dave Jones <dave.jones@canonical.com>
|
||||
Description: Use aligned access for _sha3 module on ARM.
|
||||
--- a/Modules/_sha3/sha3module.c
|
||||
+++ b/Modules/_sha3/sha3module.c
|
||||
@@ -64,6 +64,12 @@
|
||||
#define PLATFORM_BYTE_ORDER IS_BIG_ENDIAN
|
||||
#endif
|
||||
|
||||
+/* Bus error on 32-bit ARM due to un-aligned memory accesses; 64-bit ARM
|
||||
+ * doesn't complain but un-aligned memory accesses are sub-optimal */
|
||||
+#if defined(__arm__) || defined(__aarch64__)
|
||||
+#define NO_MISALIGNED_ACCESSES
|
||||
+#endif
|
||||
+
|
||||
/* mangle names */
|
||||
#define KeccakF1600_FastLoop_Absorb _PySHA3_KeccakF1600_FastLoop_Absorb
|
||||
#define Keccak_HashFinal _PySHA3_Keccak_HashFinal
|
||||
@ -1,16 +0,0 @@
|
||||
diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py
|
||||
index f34a5b4b44..b1d0f1e61e 100644
|
||||
--- a/Lib/asyncio/unix_events.py
|
||||
+++ b/Lib/asyncio/unix_events.py
|
||||
@@ -369,6 +369,11 @@ class _UnixSelectorEventLoop(selector_events.BaseSelectorEventLoop):
|
||||
fut.set_result(total_sent)
|
||||
return
|
||||
|
||||
+ # On 32-bit architectures truncate to 1GiB to avoid OverflowError,
|
||||
+ # see bpo-38319.
|
||||
+ if sys.maxsize < 2 ** 32:
|
||||
+ blocksize = min(blocksize, 2 ** 30)
|
||||
+
|
||||
try:
|
||||
sent = os.sendfile(fd, fileno, offset, blocksize)
|
||||
except (BlockingIOError, InterruptedError):
|
||||
@ -1,112 +0,0 @@
|
||||
From b7dc795dfd175c0d25a479cfaf94a13c368a5a7b Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Sat, 22 Jul 2023 16:07:40 -0500
|
||||
Subject: [PATCH] gh-106527: asyncio: optimize to add/remove readers and
|
||||
writers (#106528)
|
||||
|
||||
---
|
||||
Lib/asyncio/selector_events.py | 64 +++++++++----------
|
||||
Lib/test/test_asyncio/test_selector_events.py | 36 +++++------
|
||||
2 files changed, 47 insertions(+), 53 deletions(-)
|
||||
|
||||
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
|
||||
index f895750e3c..d521b4e2e2 100644
|
||||
--- a/Lib/asyncio/selector_events.py
|
||||
+++ b/Lib/asyncio/selector_events.py
|
||||
@@ -274,9 +274,8 @@ def _ensure_fd_no_transport(self, fd):
|
||||
def _add_reader(self, fd, callback, *args):
|
||||
self._check_closed()
|
||||
handle = events.Handle(callback, args, self, None)
|
||||
- try:
|
||||
- key = self._selector.get_key(fd)
|
||||
- except KeyError:
|
||||
+ key = self._selector.get_map().get(fd)
|
||||
+ if key is None:
|
||||
self._selector.register(fd, selectors.EVENT_READ,
|
||||
(handle, None))
|
||||
else:
|
||||
@@ -290,30 +289,27 @@ def _add_reader(self, fd, callback, *args):
|
||||
def _remove_reader(self, fd):
|
||||
if self.is_closed():
|
||||
return False
|
||||
- try:
|
||||
- key = self._selector.get_key(fd)
|
||||
- except KeyError:
|
||||
+ key = self._selector.get_map().get(fd)
|
||||
+ if key is None:
|
||||
return False
|
||||
+ mask, (reader, writer) = key.events, key.data
|
||||
+ mask &= ~selectors.EVENT_READ
|
||||
+ if not mask:
|
||||
+ self._selector.unregister(fd)
|
||||
else:
|
||||
- mask, (reader, writer) = key.events, key.data
|
||||
- mask &= ~selectors.EVENT_READ
|
||||
- if not mask:
|
||||
- self._selector.unregister(fd)
|
||||
- else:
|
||||
- self._selector.modify(fd, mask, (None, writer))
|
||||
+ self._selector.modify(fd, mask, (None, writer))
|
||||
|
||||
- if reader is not None:
|
||||
- reader.cancel()
|
||||
- return True
|
||||
- else:
|
||||
- return False
|
||||
+ if reader is not None:
|
||||
+ reader.cancel()
|
||||
+ return True
|
||||
+ else:
|
||||
+ return False
|
||||
|
||||
def _add_writer(self, fd, callback, *args):
|
||||
self._check_closed()
|
||||
handle = events.Handle(callback, args, self, None)
|
||||
- try:
|
||||
- key = self._selector.get_key(fd)
|
||||
- except KeyError:
|
||||
+ key = self._selector.get_map().get(fd)
|
||||
+ if key is None:
|
||||
self._selector.register(fd, selectors.EVENT_WRITE,
|
||||
(None, handle))
|
||||
else:
|
||||
@@ -328,24 +324,22 @@ def _remove_writer(self, fd):
|
||||
"""Remove a writer callback."""
|
||||
if self.is_closed():
|
||||
return False
|
||||
- try:
|
||||
- key = self._selector.get_key(fd)
|
||||
- except KeyError:
|
||||
+ key = self._selector.get_map().get(fd)
|
||||
+ if key is None:
|
||||
return False
|
||||
+ mask, (reader, writer) = key.events, key.data
|
||||
+ # Remove both writer and connector.
|
||||
+ mask &= ~selectors.EVENT_WRITE
|
||||
+ if not mask:
|
||||
+ self._selector.unregister(fd)
|
||||
else:
|
||||
- mask, (reader, writer) = key.events, key.data
|
||||
- # Remove both writer and connector.
|
||||
- mask &= ~selectors.EVENT_WRITE
|
||||
- if not mask:
|
||||
- self._selector.unregister(fd)
|
||||
- else:
|
||||
- self._selector.modify(fd, mask, (reader, None))
|
||||
+ self._selector.modify(fd, mask, (reader, None))
|
||||
|
||||
- if writer is not None:
|
||||
- writer.cancel()
|
||||
- return True
|
||||
- else:
|
||||
- return False
|
||||
+ if writer is not None:
|
||||
+ writer.cancel()
|
||||
+ return True
|
||||
+ else:
|
||||
+ return False
|
||||
|
||||
def add_reader(self, fd, callback, *args):
|
||||
"""Add a reader callback."""
|
||||
--
|
||||
2.39.2 (Apple Git-143)
|
||||
@ -1,72 +0,0 @@
|
||||
From aeef8591e41b68341af308e56a744396c66879cc Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Fri, 14 Jul 2023 08:46:30 -1000
|
||||
Subject: [PATCH] gh-106554: replace `_BaseSelectorImpl._key_from_fd` with
|
||||
`dict.get` (#106555)
|
||||
|
||||
---
|
||||
Lib/selectors.py | 21 ++++-----------------
|
||||
1 file changed, 4 insertions(+), 17 deletions(-)
|
||||
|
||||
diff --git a/Lib/selectors.py b/Lib/selectors.py
|
||||
index dfcc125dcd..6d82935445 100644
|
||||
--- a/Lib/selectors.py
|
||||
+++ b/Lib/selectors.py
|
||||
@@ -276,19 +276,6 @@ def close(self):
|
||||
def get_map(self):
|
||||
return self._map
|
||||
|
||||
- def _key_from_fd(self, fd):
|
||||
- """Return the key associated to a given file descriptor.
|
||||
-
|
||||
- Parameters:
|
||||
- fd -- file descriptor
|
||||
-
|
||||
- Returns:
|
||||
- corresponding key, or None if not found
|
||||
- """
|
||||
- try:
|
||||
- return self._fd_to_key[fd]
|
||||
- except KeyError:
|
||||
- return None
|
||||
|
||||
|
||||
class SelectSelector(_BaseSelectorImpl):
|
||||
@@ -336,7 +323,7 @@ def select(self, timeout=None):
|
||||
if fd in w:
|
||||
events |= EVENT_WRITE
|
||||
|
||||
- key = self._key_from_fd(fd)
|
||||
+ key = self._fd_to_key.get(fd)
|
||||
if key:
|
||||
ready.append((key, events & key.events))
|
||||
return ready
|
||||
@@ -426,7 +413,7 @@ def select(self, timeout=None):
|
||||
if event & ~self._EVENT_WRITE:
|
||||
events |= EVENT_READ
|
||||
|
||||
- key = self._key_from_fd(fd)
|
||||
+ key = self._fd_to_key.get(fd)
|
||||
if key:
|
||||
ready.append((key, events & key.events))
|
||||
return ready
|
||||
@@ -479,7 +466,7 @@ def select(self, timeout=None):
|
||||
if event & ~select.EPOLLOUT:
|
||||
events |= EVENT_READ
|
||||
|
||||
- key = self._key_from_fd(fd)
|
||||
+ key = self._fd_to_key.get(fd)
|
||||
if key:
|
||||
ready.append((key, events & key.events))
|
||||
return ready
|
||||
@@ -574,7 +561,7 @@ def select(self, timeout=None):
|
||||
if flag == select.KQ_FILTER_WRITE:
|
||||
events |= EVENT_WRITE
|
||||
|
||||
- key = self._key_from_fd(fd)
|
||||
+ key = self._fd_to_key.get(fd)
|
||||
if key:
|
||||
ready.append((key, events & key.events))
|
||||
return ready
|
||||
--
|
||||
2.39.2 (Apple Git-143)
|
||||
@ -1,42 +0,0 @@
|
||||
From 8d2f3c36caf9ecdee1176314b18388aef6e7f2c2 Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Thu, 13 Jul 2023 09:18:53 -1000
|
||||
Subject: [PATCH] gh-106664: selectors: add get() method to _SelectorMapping
|
||||
(#106665)
|
||||
|
||||
It can be used to avoid raising and catching KeyError twice via __getitem__.
|
||||
|
||||
Co-authored-by: Inada Naoki <songofacandy@gmail.com>
|
||||
---
|
||||
Lib/selectors.py | 14 +++++++++-----
|
||||
Lib/test/test_selectors.py | 6 ++++++
|
||||
2 files changed, 15 insertions(+), 5 deletions(-)
|
||||
|
||||
diff --git a/Lib/selectors.py b/Lib/selectors.py
|
||||
index af6a4f94b5..dfcc125dcd 100644
|
||||
--- a/Lib/selectors.py
|
||||
+++ b/Lib/selectors.py
|
||||
@@ -66,12 +66,16 @@ def __init__(self, selector):
|
||||
def __len__(self):
|
||||
return len(self._selector._fd_to_key)
|
||||
|
||||
+ def get(self, fileobj, default=None):
|
||||
+ fd = self._selector._fileobj_lookup(fileobj)
|
||||
+ return self._selector._fd_to_key.get(fd, default)
|
||||
+
|
||||
def __getitem__(self, fileobj):
|
||||
- try:
|
||||
- fd = self._selector._fileobj_lookup(fileobj)
|
||||
- return self._selector._fd_to_key[fd]
|
||||
- except KeyError:
|
||||
- raise KeyError("{!r} is not registered".format(fileobj)) from None
|
||||
+ fd = self._selector._fileobj_lookup(fileobj)
|
||||
+ key = self._selector._fd_to_key.get(fd)
|
||||
+ if key is None:
|
||||
+ raise KeyError("{!r} is not registered".format(fileobj))
|
||||
+ return key
|
||||
|
||||
def __iter__(self):
|
||||
return iter(self._selector._fd_to_key)
|
||||
--
|
||||
2.39.2 (Apple Git-143)
|
||||
@ -1,56 +0,0 @@
|
||||
From aecf6aca515a203a823a87c711f15cbb82097c8b Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Tue, 18 Jul 2023 00:16:32 -1000
|
||||
Subject: [PATCH] gh-106751: selectors: optimize EpollSelector.select()
|
||||
(#106754)
|
||||
|
||||
Co-authored-by: Pieter Eendebak <pieter.eendebak@gmail.com>
|
||||
---
|
||||
Lib/selectors.py | 17 +++++++++--------
|
||||
1 file changed, 9 insertions(+), 8 deletions(-)
|
||||
|
||||
diff --git a/Lib/selectors.py b/Lib/selectors.py
|
||||
index 6d82935445..a42d156340 100644
|
||||
--- a/Lib/selectors.py
|
||||
+++ b/Lib/selectors.py
|
||||
@@ -430,6 +430,9 @@ class PollSelector(_PollLikeSelector):
|
||||
|
||||
if hasattr(select, 'epoll'):
|
||||
|
||||
+ _NOT_EPOLLIN = ~select.EPOLLIN
|
||||
+ _NOT_EPOLLOUT = ~select.EPOLLOUT
|
||||
+
|
||||
class EpollSelector(_PollLikeSelector):
|
||||
"""Epoll-based selector."""
|
||||
_selector_cls = select.epoll
|
||||
@@ -452,22 +455,20 @@ def select(self, timeout=None):
|
||||
# epoll_wait() expects `maxevents` to be greater than zero;
|
||||
# we want to make sure that `select()` can be called when no
|
||||
# FD is registered.
|
||||
- max_ev = max(len(self._fd_to_key), 1)
|
||||
+ max_ev = len(self._fd_to_key) or 1
|
||||
|
||||
ready = []
|
||||
try:
|
||||
fd_event_list = self._selector.poll(timeout, max_ev)
|
||||
except InterruptedError:
|
||||
return ready
|
||||
- for fd, event in fd_event_list:
|
||||
- events = 0
|
||||
- if event & ~select.EPOLLIN:
|
||||
- events |= EVENT_WRITE
|
||||
- if event & ~select.EPOLLOUT:
|
||||
- events |= EVENT_READ
|
||||
|
||||
- key = self._fd_to_key.get(fd)
|
||||
+ fd_to_key = self._fd_to_key
|
||||
+ for fd, event in fd_event_list:
|
||||
+ key = fd_to_key.get(fd)
|
||||
if key:
|
||||
+ events = ((event & _NOT_EPOLLIN and EVENT_WRITE)
|
||||
+ | (event & _NOT_EPOLLOUT and EVENT_READ))
|
||||
ready.append((key, events & key.events))
|
||||
return ready
|
||||
|
||||
--
|
||||
2.39.2 (Apple Git-143)
|
||||
@ -1,30 +0,0 @@
|
||||
From 86a112f61954dede0a777544e59068c0b01c8439 Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Wed, 11 Oct 2023 08:34:01 -1000
|
||||
Subject: [PATCH] gh-110733: Optimize _run_once for many iterations of the
|
||||
event loop
|
||||
|
||||
---
|
||||
Lib/asyncio/base_events.py | 7 +++++--
|
||||
1 file changed, 5 insertions(+), 2 deletions(-)
|
||||
|
||||
diff --git a/Lib/asyncio/base_events.py b/Lib/asyncio/base_events.py
|
||||
index b092c93436..956864e424 100644
|
||||
--- a/Lib/asyncio/base_events.py
|
||||
+++ b/Lib/asyncio/base_events.py
|
||||
@@ -1907,8 +1907,11 @@ def _run_once(self):
|
||||
timeout = 0
|
||||
elif self._scheduled:
|
||||
# Compute the desired timeout.
|
||||
- when = self._scheduled[0]._when
|
||||
- timeout = min(max(0, when - self.time()), MAXIMUM_SELECT_TIMEOUT)
|
||||
+ timeout = self._scheduled[0]._when - self.time()
|
||||
+ if timeout > MAXIMUM_SELECT_TIMEOUT:
|
||||
+ timeout = MAXIMUM_SELECT_TIMEOUT
|
||||
+ elif timeout < 0:
|
||||
+ timeout = 0
|
||||
|
||||
event_list = self._selector.select(timeout)
|
||||
self._process_events(event_list)
|
||||
--
|
||||
2.39.3 (Apple Git-145)
|
||||
@ -1,38 +0,0 @@
|
||||
From 7e2d93f30b157e414924c32232bb748c8f66c828 Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Tue, 12 Dec 2023 14:29:21 -1000
|
||||
Subject: [PATCH] gh-112989: asyncio: Reduce overhead to connect sockets with
|
||||
SelectorEventLoop (#112991)
|
||||
|
||||
_ensure_fd_no_transport had a KeyError in the success path
|
||||
---
|
||||
Lib/asyncio/selector_events.py | 14 +++++---------
|
||||
.../2023-12-12-05-48-17.gh-issue-112989.ZAa_eq.rst | 1 +
|
||||
2 files changed, 6 insertions(+), 9 deletions(-)
|
||||
create mode 100644 Misc/NEWS.d/next/Library/2023-12-12-05-48-17.gh-issue-112989.ZAa_eq.rst
|
||||
|
||||
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
|
||||
index d521b4e2e2..dcd5e0aa34 100644
|
||||
--- a/Lib/asyncio/selector_events.py
|
||||
+++ b/Lib/asyncio/selector_events.py
|
||||
@@ -261,15 +261,11 @@ def _ensure_fd_no_transport(self, fd):
|
||||
except (AttributeError, TypeError, ValueError):
|
||||
# This code matches selectors._fileobj_to_fd function.
|
||||
raise ValueError(f"Invalid file object: {fd!r}") from None
|
||||
- try:
|
||||
- transport = self._transports[fileno]
|
||||
- except KeyError:
|
||||
- pass
|
||||
- else:
|
||||
- if not transport.is_closing():
|
||||
- raise RuntimeError(
|
||||
- f'File descriptor {fd!r} is used by transport '
|
||||
- f'{transport!r}')
|
||||
+ transport = self._transports.get(fileno)
|
||||
+ if transport and not transport.is_closing():
|
||||
+ raise RuntimeError(
|
||||
+ f'File descriptor {fd!r} is used by transport '
|
||||
+ f'{transport!r}')
|
||||
|
||||
def _add_reader(self, fd, callback, *args):
|
||||
self._check_closed()
|
||||
@ -0,0 +1,38 @@
|
||||
From dd3c0fa3fd2795326dae0e0ed63c668f5506cf32 Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Thu, 31 Oct 2024 14:05:40 -0500
|
||||
Subject: [PATCH] gh-126156: Improve performance of creating `Morsel` objects
|
||||
(#126157)
|
||||
|
||||
Replaces the manually constructed loop with a call to `dict.update`
|
||||
---
|
||||
Lib/http/cookies.py | 5 +++--
|
||||
.../Library/2024-10-30-00-12-22.gh-issue-126156.BOSqv0.rst | 1 +
|
||||
2 files changed, 4 insertions(+), 2 deletions(-)
|
||||
create mode 100644 Misc/NEWS.d/next/Library/2024-10-30-00-12-22.gh-issue-126156.BOSqv0.rst
|
||||
|
||||
diff --git a/Lib/http/cookies.py b/Lib/http/cookies.py
|
||||
index 6b9ed24ad8e..d7e8d08b2d9 100644
|
||||
--- a/Lib/http/cookies.py
|
||||
+++ b/Lib/http/cookies.py
|
||||
@@ -266,6 +266,8 @@ class Morsel(dict):
|
||||
"samesite" : "SameSite",
|
||||
}
|
||||
|
||||
+ _reserved_defaults = dict.fromkeys(_reserved, "")
|
||||
+
|
||||
_flags = {'secure', 'httponly'}
|
||||
|
||||
def __init__(self):
|
||||
@@ -273,8 +275,7 @@ def __init__(self):
|
||||
self._key = self._value = self._coded_value = None
|
||||
|
||||
# Set default attributes
|
||||
- for key in self._reserved:
|
||||
- dict.__setitem__(self, key, "")
|
||||
+ dict.update(self, self._reserved_defaults)
|
||||
|
||||
@property
|
||||
def key(self):
|
||||
--
|
||||
2.39.3 (Apple Git-145)
|
||||
@ -0,0 +1,88 @@
|
||||
From 53da1e8c8ccbe3161ebc42e8b8b7ebd1ab70e05b Mon Sep 17 00:00:00 2001
|
||||
From: "J. Nick Koston" <nick@koston.org>
|
||||
Date: Sun, 18 May 2025 11:56:20 -0400
|
||||
Subject: [PATCH] gh-134173: optimize state transfer between
|
||||
`concurrent.futures.Future` and `asyncio.Future` (#134174)
|
||||
|
||||
Co-authored-by: Kumar Aditya <kumaraditya@python.org>
|
||||
---
|
||||
Lib/asyncio/futures.py | 17 +++---
|
||||
Lib/concurrent/futures/_base.py | 27 +++++++++
|
||||
Lib/test/test_asyncio/test_futures.py | 58 +++++++++++++++++--
|
||||
.../test_concurrent_futures/test_future.py | 57 ++++++++++++++++++
|
||||
...-05-18-07-25-15.gh-issue-134173.53oOoF.rst | 3 +
|
||||
5 files changed, 148 insertions(+), 14 deletions(-)
|
||||
create mode 100644 Misc/NEWS.d/next/Library/2025-05-18-07-25-15.gh-issue-134173.53oOoF.rst
|
||||
|
||||
diff --git a/Lib/asyncio/futures.py b/Lib/asyncio/futures.py
|
||||
index d1df6707302..6bd00a64478 100644
|
||||
--- a/Lib/asyncio/futures.py
|
||||
+++ b/Lib/asyncio/futures.py
|
||||
@@ -351,22 +351,19 @@ def _set_concurrent_future_state(concurrent, source):
|
||||
def _copy_future_state(source, dest):
|
||||
"""Internal helper to copy state from another Future.
|
||||
|
||||
- The other Future may be a concurrent.futures.Future.
|
||||
+ The other Future must be a concurrent.futures.Future.
|
||||
"""
|
||||
- assert source.done()
|
||||
if dest.cancelled():
|
||||
return
|
||||
assert not dest.done()
|
||||
- if source.cancelled():
|
||||
+ done, cancelled, result, exception = source._get_snapshot()
|
||||
+ assert done
|
||||
+ if cancelled:
|
||||
dest.cancel()
|
||||
+ elif exception is not None:
|
||||
+ dest.set_exception(_convert_future_exc(exception))
|
||||
else:
|
||||
- exception = source.exception()
|
||||
- if exception is not None:
|
||||
- dest.set_exception(_convert_future_exc(exception))
|
||||
- else:
|
||||
- result = source.result()
|
||||
- dest.set_result(result)
|
||||
-
|
||||
+ dest.set_result(result)
|
||||
|
||||
def _chain_future(source, destination):
|
||||
"""Chain two futures so that when one completes, so does the other.
|
||||
diff --git a/Lib/concurrent/futures/_base.py b/Lib/concurrent/futures/_base.py
|
||||
index d98b1ebdd58..f506ce68aea 100644
|
||||
--- a/Lib/concurrent/futures/_base.py
|
||||
+++ b/Lib/concurrent/futures/_base.py
|
||||
@@ -558,6 +558,33 @@ def set_exception(self, exception):
|
||||
self._condition.notify_all()
|
||||
self._invoke_callbacks()
|
||||
|
||||
+ def _get_snapshot(self):
|
||||
+ """Get a snapshot of the future's current state.
|
||||
+
|
||||
+ This method atomically retrieves the state in one lock acquisition,
|
||||
+ which is significantly faster than multiple method calls.
|
||||
+
|
||||
+ Returns:
|
||||
+ Tuple of (done, cancelled, result, exception)
|
||||
+ - done: True if the future is done (cancelled or finished)
|
||||
+ - cancelled: True if the future was cancelled
|
||||
+ - result: The result if available and not cancelled
|
||||
+ - exception: The exception if available and not cancelled
|
||||
+ """
|
||||
+ # Fast path: check if already finished without lock
|
||||
+ if self._state == FINISHED:
|
||||
+ return True, False, self._result, self._exception
|
||||
+
|
||||
+ # Need lock for other states since they can change
|
||||
+ with self._condition:
|
||||
+ # We have to check the state again after acquiring the lock
|
||||
+ # because it may have changed in the meantime.
|
||||
+ if self._state == FINISHED:
|
||||
+ return True, False, self._result, self._exception
|
||||
+ if self._state in {CANCELLED, CANCELLED_AND_NOTIFIED}:
|
||||
+ return True, True, None, None
|
||||
+ return False, False, None, None
|
||||
+
|
||||
__class_getitem__ = classmethod(types.GenericAlias)
|
||||
|
||||
class Executor(object):
|
||||
39
patches/musl-skip_failing_tests.patch
Normal file
39
patches/musl-skip_failing_tests.patch
Normal file
@ -0,0 +1,39 @@
|
||||
From c4355fe059aad95122cae9747ec9e34b934a2a3a Mon Sep 17 00:00:00 2001
|
||||
From: =?UTF-8?q?Jan=20=C4=8Cerm=C3=A1k?= <sairon@sairon.cz>
|
||||
Date: Fri, 11 Apr 2025 13:20:37 +0200
|
||||
Subject: [PATCH] Skip test_re tests failing on musl
|
||||
|
||||
---
|
||||
Lib/test/test_re.py | 6 +++---
|
||||
1 file changed, 3 insertions(+), 3 deletions(-)
|
||||
|
||||
diff --git a/Lib/test/test_re.py b/Lib/test/test_re.py
|
||||
index 813cb4a..0b5877a 100644
|
||||
--- a/Lib/test/test_re.py
|
||||
+++ b/Lib/test/test_re.py
|
||||
@@ -1,6 +1,6 @@
|
||||
from test.support import (gc_collect, bigmemtest, _2G,
|
||||
cpython_only, captured_stdout,
|
||||
- check_disallow_instantiation, is_emscripten, is_wasi,
|
||||
+ check_disallow_instantiation, is_emscripten, is_wasi, linked_to_musl,
|
||||
warnings_helper, SHORT_TIMEOUT, CPUStopwatch, requires_resource)
|
||||
import locale
|
||||
import re
|
||||
@@ -2177,7 +2177,7 @@ class ReTests(unittest.TestCase):
|
||||
self.assertEqual(re.fullmatch('[a-c]+', 'ABC', re.I).span(), (0, 3))
|
||||
|
||||
@unittest.skipIf(
|
||||
- is_emscripten or is_wasi,
|
||||
+ is_emscripten or is_wasi or linked_to_musl,
|
||||
"musl libc issue on Emscripten/WASI, bpo-46390"
|
||||
)
|
||||
def test_locale_caching(self):
|
||||
@@ -2217,7 +2217,7 @@ class ReTests(unittest.TestCase):
|
||||
self.assertIsNone(re.match(b'(?Li)\xe5', b'\xc5'))
|
||||
|
||||
@unittest.skipIf(
|
||||
- is_emscripten or is_wasi,
|
||||
+ is_emscripten or is_wasi or linked_to_musl,
|
||||
"musl libc issue on Emscripten/WASI, bpo-46390"
|
||||
)
|
||||
def test_locale_compiled(self):
|
||||
Loading…
x
Reference in New Issue
Block a user