blob: 7e658ff707e430f4a65c91844edfa9dc10caf463 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
# 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:
|
