thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: Server: feature development. [#METR-15090]

Browse Source
This commit is contained in:
Alexey Arno 2015-04-07 02:21:20 +03:00
parent 5312a1b17d
commit c7a4225f0e
2 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbms/include/DB/IO/WriteBufferAIO.h
View File

@ -40,7 +40,7 @@ private:
///
void nextImpl() override;
/// Ждать окончания текущей асинхронной задачи.
void waitForAIOCompletion();
bool waitForAIOCompletion();
/// Менять местами основной и дублирующий буферы.
void swapBuffers() noexcept;
///

24
dbms/src/IO/WriteBufferAIO.cpp
View File

@ -136,7 +136,8 @@ void WriteBufferAIO::sync()
void WriteBufferAIO::flush()
{
next();
waitForAIOCompletion();
if (waitForAIOCompletion())
finalize();
}
void WriteBufferAIO::nextImpl()
@ -144,7 +145,8 @@ void WriteBufferAIO::nextImpl()
if (!offset())
return;
waitForAIOCompletion();
if (waitForAIOCompletion())
finalize();
swapBuffers();
prepare();
@ -195,10 +197,10 @@ void WriteBufferAIO::nextImpl()
is_pending_write = true;
}
void WriteBufferAIO::waitForAIOCompletion()
bool WriteBufferAIO::waitForAIOCompletion()
{
if (!is_pending_write)
return;
return false;
while (io_getevents(aio_context.ctx, events.size(), events.size(), &events[0], nullptr) < 0)
{
@ -212,13 +214,7 @@ void WriteBufferAIO::waitForAIOCompletion()
is_pending_write = false;
bytes_written = events[0].res;
if (bytes_written < bytes_to_write)
{
got_exception = true;
throw Exception("Asynchronous write error on file " + filename, ErrorCodes::AIO_WRITE_ERROR);
}
finalize();
return true;
}
void WriteBufferAIO::swapBuffers() noexcept
@ -423,6 +419,12 @@ void WriteBufferAIO::prepare()
void WriteBufferAIO::finalize()
{
if (bytes_written < bytes_to_write)
{
got_exception = true;
throw Exception("Asynchronous write error on file " + filename, ErrorCodes::AIO_WRITE_ERROR);
}
bytes_written -= truncation_count;
off_t pos_offset = bytes_written - (pos_in_file - request.aio_offset);