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

Sending progress in HTTP headers (continued) [#CLICKHOUSE-32].

Browse Source
This commit is contained in:
Alexey Milovidov 2017-01-23 11:22:46 +03:00
parent 6894df0304
commit 18782e1473
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dbms/include/DB/IO/WriteBufferFromHTTPServerResponse.h
View File

@ -79,7 +79,6 @@ private:
setResponseDefaultHeaders(response); setResponseDefaultHeaders(response);
std::tie(response_header_ostr, response_body_ostr) = response.beginSend(); std::tie(response_header_ostr, response_body_ostr) = response.beginSend();
out_raw.emplace(*response_body_ostr);
} }
} }
@ -117,11 +116,13 @@ private:
ErrorCodes::LOGICAL_ERROR); ErrorCodes::LOGICAL_ERROR);
/// Use memory allocated for the outer buffer in the buffer pointed to by out. This avoids extra allocation and copy. /// Use memory allocated for the outer buffer in the buffer pointed to by out. This avoids extra allocation and copy.
out_raw.emplace(*response_body_ostr);
deflating_buf.emplace(out_raw.value(), compression_method, compression_level, working_buffer.size(), working_buffer.begin()); deflating_buf.emplace(out_raw.value(), compression_method, compression_level, working_buffer.size(), working_buffer.begin());
out = &deflating_buf.value(); out = &deflating_buf.value();
} }
else else
{ {
out_raw.emplace(*response_body_ostr, working_buffer.size(), working_buffer.begin());
out = &out_raw.value(); out = &out_raw.value();
} }
} }