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

Remove dump flag from ReadBufferAIO

Browse Source
This commit is contained in:
alesapin 2020-06-09 18:01:34 +03:00
parent 30b02b20e5
commit 981462db04
2 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/IO/ReadBufferAIO.cpp
View File

@ -95,11 +95,8 @@ bool ReadBufferAIO::nextImpl()
if (profile_callback)
watch.emplace(clock_type);
if (!is_aio)
{
if (!is_pending_read)
synchronousRead();
is_aio = true;
}
else
receive();
@ -215,7 +212,9 @@ void ReadBufferAIO::synchronousRead()
void ReadBufferAIO::receive()
{
if (!waitForAIOCompletion())
return;
{
throw Exception("Trying to receive data from AIO, but nothing was queued. It's a bug", ErrorCodes::LOGICAL_ERROR);
}
finalize();
}
@ -224,8 +223,6 @@ void ReadBufferAIO::skip()
if (!waitForAIOCompletion())
return;
is_aio = false;
/// @todo I presume this assignment is redundant since waitForAIOCompletion() performs a similar one
// bytes_read = future_bytes_read.get();
if ((bytes_read < 0) || (static_cast<size_t>(bytes_read) < region_left_padding))

2
src/IO/ReadBufferAIO.h
View File

@ -100,8 +100,6 @@ private:
bool is_eof = false;
/// At least one read request was sent.
bool is_started = false;
/// Is the operation asynchronous?
bool is_aio = false;
/// Did the asynchronous operation fail?
bool aio_failed = false;