Stowage/cpython
2
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-12-31 04:23:37 +00:00
Code Issues Projects Releases Packages Wiki Activity

[3.14] gh-136394: Fix race condition in test_zstd (GH-136432) (GH-136506)

Browse source 
gh-136394: Fix race condition in test_zstd (GH-136432)
(cherry picked from commit f519918ec6)

Co-authored-by: Rogdham <3994389+Rogdham@users.noreply.github.com>
This commit is contained in:
Miss Islington (bot) 2025-07-10 15:13:34 +02:00 • committed by GitHub
parent 1346049782
commit da8bcfd949
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
Lib/test/test_zstd.py
View file

@ -2674,8 +2674,12 @@ def test_compress_locking(self):
input = b'a'* (16*_1K)
num_threads = 8
# gh-136394: the first output of .compress() includes the frame header
# we run the first .compress() call outside of the threaded portion
# to make the test order-independent
comp = ZstdCompressor()
parts = []
parts = [comp.compress(input, ZstdCompressor.FLUSH_BLOCK)]
for _ in range(num_threads):
res = comp.compress(input, ZstdCompressor.FLUSH_BLOCK)
if res:
@ -2684,7 +2688,7 @@ def test_compress_locking(self):
expected = b''.join(parts) + rest1
comp = ZstdCompressor()
output = []
output = [comp.compress(input, ZstdCompressor.FLUSH_BLOCK)]
def run_method(method, input_data, output_data):
res = method(input_data, ZstdCompressor.FLUSH_BLOCK)
if res: