Mirror/Crow
1
0
Fork 0
mirror of https://github.com/CrowCpp/Crow.git synced 2024-06-07 21:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Performance fix for non-static streaming data

Browse Source
This commit is contained in:
Felix 2023-12-06 21:37:14 +01:00 committed by gittiver
parent 4f3f5deaaa
commit ae8643a1b6
1 changed files with 7 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
include/crow/http_connection.h
View File

@ -436,26 +436,16 @@ namespace crow
cancel_deadline_timer(); cancel_deadline_timer();
if (res.body.length() > 0) if (res.body.length() > 0)
{ {
std::string buf; std::vector<asio::const_buffer> buffers{1};
std::vector<asio::const_buffer> buffers; const uint8_t *data = reinterpret_cast<const uint8_t*>(res.body.data());
size_t length = res.body.length();
while (res.body.length() > 16384) for(size_t transferred = 0; transferred < length;)
{ {
//buf.reserve(16385); size_t to_transfer = std::min(16385UL, length-transferred);
buf = res.body.substr(0, 16384); buffers[0] = asio::const_buffer(data+transferred, to_transfer);
res.body = res.body.substr(16384);
buffers.clear();
buffers.push_back(asio::buffer(buf));
do_write_sync(buffers); do_write_sync(buffers);
transferred += to_transfer;
} }
// Collect whatever is left (less than 16KB) and send it down the socket
// buf.reserve(is.length());
buf = res.body;
res.body.clear();
buffers.clear();
buffers.push_back(asio::buffer(buf));
do_write_sync(buffers);
} }
if (close_connection_) if (close_connection_)
{ {