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

addressed review comment: ForkWriteBuffer for loop

Browse Source
This commit is contained in:
Smita Kulkarni 2022-07-15 18:37:50 +02:00
parent d7fc7a4290
commit 6318927fba
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/IO/ForkWriteBuffer.cpp
View File

@ -1,7 +1,5 @@
#include <IO/ForkWriteBuffer.h>
#include <Common/Exception.h>
#include <ranges>
namespace DB
{
@ -28,14 +26,14 @@ void ForkWriteBuffer::nextImpl()
try
{
for (const WriteBufferPtr & write_buffer : sources | std::views::reverse)
auto & source_buffer = sources.front();
for (auto it = sources.begin() + 1; it != sources.end(); ++it)
{
if (write_buffer != sources.front())
{
write_buffer->write(sources.front()->buffer().begin(), sources.front()->offset());
}
write_buffer->next();
auto & buffer = *it;
buffer->write(source_buffer->buffer().begin(), source_buffer->offset());
buffer->next();
}
source_buffer->next();
}
catch (Exception & exception)
{