IO/CompressedWriteBuffer: support new LZ4 library

11ec4c62 · Dmitry Bilunov · alexey-milovidov · 0c72259c · 11ec4c62
隐藏空白更改
内联并排

Showing with 7 addition and 4 deletion

dbms/src/IO/CompressedWriteBuffer.cpp dbms/src/IO/CompressedWriteBuffer.cpp +7 -4

未找到文件。
--- a/dbms/src/IO/CompressedWriteBuffer.cpp
+++ b/dbms/src/IO/CompressedWriteBuffer.cpp
@@ -70,15 +70,18 @@ void CompressedWriteBuffer::nextImpl()
            compressed_buffer[0] = static_cast<UInt8>(CompressionMethodByte::LZ4);

            if (method == CompressionMethod::LZ4)
-                compressed_size = header_size + LZ4_compress(
+                compressed_size = header_size + LZ4_compress_default(
                    working_buffer.begin(),
                    &compressed_buffer[header_size],
-                    uncompressed_size);
+                    uncompressed_size,
+                    LZ4_COMPRESSBOUND(uncompressed_size));
            else
-                compressed_size = header_size + LZ4_compressHC(
+                compressed_size = header_size + LZ4_compress_HC(
                    working_buffer.begin(),
                    &compressed_buffer[header_size],
-                    uncompressed_size);
+                    uncompressed_size,
+                    LZ4_COMPRESSBOUND(uncompressed_size),
+                    0);

            UInt32 compressed_size_32 = compressed_size;
            UInt32 uncompressed_size_32 = uncompressed_size;