mirror of
https://gitlab.alpinelinux.org/alpine/aports.git
synced 2025-08-07 06:17:14 +02:00
43 lines
1.6 KiB
Diff
43 lines
1.6 KiB
Diff
# issue opened: https://github.com/python-lz4/python-lz4/issues/19
|
|
|
|
--- lz4-0.9.0/tests/test_frame.py.orig
|
|
+++ lz4-0.9.0/tests/test_frame.py
|
|
@@ -211,37 +211,6 @@
|
|
pool.close()
|
|
self.assertEqual(data, out)
|
|
|
|
- def test_compress_begin_update_end_no_auto_flush_not_defaults_threaded(self):
|
|
- data = [os.urandom(3 * 256 * 1024) for i in range(100)]
|
|
-
|
|
- def roundtrip(x):
|
|
- context = lz4frame.create_compression_context()
|
|
- self.assertNotEqual(context, None)
|
|
- compressed = lz4frame.compress_begin(
|
|
- context,
|
|
- block_size=lz4frame.BLOCKSIZE_MAX256KB,
|
|
- block_mode=lz4frame.BLOCKMODE_LINKED,
|
|
- compression_level=lz4frame.COMPRESSIONLEVEL_MAX,
|
|
- auto_flush=0
|
|
- )
|
|
- chunk_size = 128 * 1024 # 128 kb, half of block size
|
|
- start = 0
|
|
- end = start + chunk_size
|
|
-
|
|
- while start <= len(x):
|
|
- compressed += lz4frame.compress_update(context, x[start:end])
|
|
- start = end
|
|
- end = start + chunk_size
|
|
-
|
|
- compressed += lz4frame.compress_end(context)
|
|
- decompressed = lz4frame.decompress(compressed)
|
|
- return decompressed
|
|
-
|
|
- pool = ThreadPool(8)
|
|
- out = pool.map(roundtrip, data)
|
|
- pool.close()
|
|
- self.assertEqual(data, out)
|
|
-
|
|
def test_LZ4FrameCompressor(self):
|
|
input_data = b"2099023098234882923049823094823094898239230982349081231290381209380981203981209381238901283098908123109238098123"
|
|
with lz4frame.LZ4FrameCompressor() as compressor:
|