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

Attempt to implement streaming optimization in DiskS3.

Browse Source
This commit is contained in:
Vladimir Chebotarev 2020-07-12 16:53:08 +03:00
parent 718523b0ee
commit 67f9d8124b
1 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/IO/SeekableStreamingReadBuffer.h
View File

@ -26,9 +26,28 @@ public:
off_t seek(off_t off, int whence) override
{
swap(*nested);
off_t position = nested->seek(off, whence);
swap(*nested);
off_t position = getPosition();
if (whence == SEEK_CUR)
{
off += position;
whence = SEEK_SET;
}
if (whence == SEEK_SET && off >= position && off < position + 1024*1024)
{
swap(*nested);
nested->ignore(off - position);
swap(*nested);
position = off;
}
else
{
swap(*nested);
position = nested->seek(off, whence);
swap(*nested);
}
return position;
}