thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-13 09:52:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Yakov Olkhovskiy 2023-11-27 22:06:01 +00:00
parent 52ef3fe34b
commit c0a9b82c3c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/IO/Lz4DeflatingWriteBuffer.cpp
View File

@ -102,7 +102,7 @@ void Lz4DeflatingWriteBuffer::nextImpl()
if (first_time) if (first_time)
{ {
auto sink = SinkToOut(out.get(), tmp_memory, LZ4F_HEADER_SIZE_MAX); auto sink = SinkToOut(out, tmp_memory, LZ4F_HEADER_SIZE_MAX);
chassert(sink.getCapacity() >= LZ4F_HEADER_SIZE_MAX); chassert(sink.getCapacity() >= LZ4F_HEADER_SIZE_MAX);
/// write frame header and check for errors /// write frame header and check for errors
@ -128,7 +128,7 @@ void Lz4DeflatingWriteBuffer::nextImpl()
/// Ensure that there is enough space for compressed block of minimal size /// Ensure that there is enough space for compressed block of minimal size
size_t min_compressed_block_size = LZ4F_compressBound(1, &kPrefs); size_t min_compressed_block_size = LZ4F_compressBound(1, &kPrefs);
auto sink = SinkToOut(out.get(), tmp_memory, min_compressed_block_size); auto sink = SinkToOut(out, tmp_memory, min_compressed_block_size);
chassert(sink.getCapacity() >= min_compressed_block_size); chassert(sink.getCapacity() >= min_compressed_block_size);
/// LZ4F_compressUpdate compresses whole input buffer at once so we need to shink it manually /// LZ4F_compressUpdate compresses whole input buffer at once so we need to shink it manually
@ -165,7 +165,7 @@ void Lz4DeflatingWriteBuffer::finalizeBefore()
return; return;
auto suffix_size = LZ4F_compressBound(0, &kPrefs); auto suffix_size = LZ4F_compressBound(0, &kPrefs);
auto sink = SinkToOut(out.get(), tmp_memory, suffix_size); auto sink = SinkToOut(out, tmp_memory, suffix_size);
chassert(sink.getCapacity() >= suffix_size); chassert(sink.getCapacity() >= suffix_size);
/// compression end /// compression end