thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

work with tests

Browse Source
This commit is contained in:
Sema Checherinda 2024-05-30 17:01:28 +02:00
parent ef3a2fef01
commit 99ce2985d4
4 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Compression/CompressedWriteBuffer.cpp
View File

@ -62,10 +62,11 @@ CompressedWriteBuffer::CompressedWriteBuffer(WriteBuffer & out_, CompressionCode
{
}
// CompressedWriteBuffer::~CompressedWriteBuffer()
// {
// finalize();
// }
CompressedWriteBuffer::~CompressedWriteBuffer()
{
if (!canceled)
finalize();
}
}

2
src/Compression/CompressedWriteBuffer.h
View File

@ -21,7 +21,7 @@ public:
CompressionCodecPtr codec_ = CompressionCodecFactory::instance().getDefaultCodec(),
size_t buf_size = DBMS_DEFAULT_BUFFER_SIZE);
// ~CompressedWriteBuffer() override;
~CompressedWriteBuffer() override;
/// The amount of compressed data
size_t getCompressedBytes()

23
src/IO/WriteBufferFromPocoSocket.cpp
View File

@ -193,16 +193,17 @@ WriteBufferFromPocoSocket::WriteBufferFromPocoSocket(Poco::Net::Socket & socket_
write_event = write_event_;
}
// WriteBufferFromPocoSocket::~WriteBufferFromPocoSocket()
// {
// // try
// // {
// // finalize();
// // }
// // catch (...)
// // {
// // tryLogCurrentException(__PRETTY_FUNCTION__);
// // }
// }
WriteBufferFromPocoSocket::~WriteBufferFromPocoSocket()
{
try
{
if (!canceled)
finalize();
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);
}
}
}

2
src/IO/WriteBufferFromPocoSocket.h
View File

@ -19,7 +19,7 @@ public:
explicit WriteBufferFromPocoSocket(Poco::Net::Socket & socket_, size_t buf_size = DBMS_DEFAULT_BUFFER_SIZE);
explicit WriteBufferFromPocoSocket(Poco::Net::Socket & socket_, const ProfileEvents::Event & write_event_, size_t buf_size = DBMS_DEFAULT_BUFFER_SIZE);
//~WriteBufferFromPocoSocket() override;
~WriteBufferFromPocoSocket() override;
void setAsyncCallback(AsyncCallback async_callback_) { async_callback = std::move(async_callback_); }