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

Merge e073506cde into 7fd2207626

Browse Source
This commit is contained in:
Kseniia Sumarokova 2024-09-18 14:36:18 +02:00 committed by GitHub
commit 4584d0f51b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/Disks/IO/ReadBufferFromRemoteFSGather.cpp
View File

@ -183,13 +183,23 @@ bool ReadBufferFromRemoteFSGather::nextImpl()
if (!current_buf)
return false;
if (readImpl())
bool result = readImpl();
if (!result)
{
if (!moveToNextBuffer())
return false;
result = readImpl();
}
if (result)
{
if (!use_external_buffer)
{
working_buffer = Buffer(position(), working_buffer.end());
pos = working_buffer.begin();
}
return true;
if (!moveToNextBuffer())
return false;
return readImpl();
}
return false;
}
bool ReadBufferFromRemoteFSGather::moveToNextBuffer()
@ -215,7 +225,6 @@ bool ReadBufferFromRemoteFSGather::readImpl()
if (result)
{
file_offset_of_buffer_end += current_buf->available();
nextimpl_working_buffer_offset = current_buf->offset();
chassert(current_buf->available());
chassert(blobs_to_read.size() != 1 || file_offset_of_buffer_end == current_buf->getFileOffsetOfBufferEnd());
@ -238,6 +247,7 @@ void ReadBufferFromRemoteFSGather::reset()
current_object = StoredObject();
current_buf_idx = {};
current_buf.reset();
resetWorkingBuffer();
}
off_t ReadBufferFromRemoteFSGather::seek(off_t offset, int whence)