thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-14 03:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed code style issue

Browse Source
This commit is contained in:
jinjunzh 2022-05-16 17:21:20 -04:00
parent 2ae9e22248
commit f334cd371f
1 changed files with 7 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/Compression/CompressedWriteBuffer.cpp
View File

@ -1,11 +1,11 @@
#include <city.h>
#include <string.h>
#include <base/unaligned.h>
#include <base/types.h>
#include <base/unaligned.h>
#include "CompressedWriteBuffer.h"
#include <Compression/CompressionFactory.h>
#include "CompressedWriteBuffer.h"
namespace DB
@ -25,11 +25,11 @@ void CompressedWriteBuffer::nextImpl()
UInt32 compressed_size = 0;
size_t decompressed_size = offset();
UInt32 compressed_reserve_size = codec->getCompressedReserveSize(decompressed_size);
if(out.available() > (compressed_reserve_size + CHECKSUM_SIZE))
if (out.available() > compressed_reserve_size + CHECKSUM_SIZE)
{
char *out_checksum_ptr = out.position();
char *out_compressed_ptr = out.position() + CHECKSUM_SIZE;
char * out_checksum_ptr = out.position();
char * out_compressed_ptr = out.position() + CHECKSUM_SIZE;
compressed_size = codec->compress(working_buffer.begin(), decompressed_size, out_compressed_ptr);
CityHash_v1_0_2::uint128 checksum = CityHash_v1_0_2::CityHash128(out_compressed_ptr, compressed_size);
@ -52,10 +52,7 @@ CompressedWriteBuffer::~CompressedWriteBuffer()
finalize();
}
CompressedWriteBuffer::CompressedWriteBuffer(
WriteBuffer & out_,
CompressionCodecPtr codec_,
size_t buf_size)
CompressedWriteBuffer::CompressedWriteBuffer(WriteBuffer & out_, CompressionCodecPtr codec_, size_t buf_size)
: BufferWithOwnMemory<WriteBuffer>(buf_size), out(out_), codec(std::move(codec_))
{
}