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

Fixed error [#CLICKHOUSE-2].

Browse Source
This commit is contained in:
Alexey Milovidov 2017-03-14 00:37:53 +03:00
parent bd34b62f4a
commit 79dd801348
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbms/src/Core/Progress.cpp
View File

@ -29,11 +29,11 @@ void Progress::read(ReadBuffer & in, UInt64 server_revision)
void Progress::write(WriteBuffer & out, UInt64 client_revision) const
{
writeVarUInt(rows, out);
writeVarUInt(bytes, out);
writeVarUInt(rows.load(), out);
writeVarUInt(bytes.load(), out);
if (client_revision >= DBMS_MIN_REVISION_WITH_TOTAL_ROWS_IN_PROGRESS)
writeVarUInt(total_rows, out);
writeVarUInt(total_rows.load(), out);
}
@ -43,11 +43,11 @@ void Progress::writeJSON(WriteBuffer & out) const
/// of 64-bit integers after interpretation by JavaScript.
writeCString("{\"read_rows\":\"", out);
writeText(rows, out);
writeText(rows.load(), out);
writeCString("\",\"read_bytes\":\"", out);
writeText(bytes, out);
writeText(bytes.load(), out);
writeCString("\",\"total_rows\":\"", out);
writeText(total_rows, out);
writeText(total_rows.load(), out);
writeCString("\"}", out);
}