mir/kea
2
0
Fork 0
mirror of https://gitlab.isc.org/isc-projects/kea synced 2025-09-02 06:55:16 +00:00
Code Issues Releases Wiki Activity

[#3490] Fixed clients for large bodies

Browse Source
This commit is contained in:
Francis Dupont
2024-07-23 17:00:32 +02:00
committed by Razvan Becheriu
parent 9bb4630cdb
commit dcd26dbbc1
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/lib/http/testutils/test_http_client.h
View File

@@ -166,9 +166,10 @@ public:
} }
// Remove the part of the request which has been sent. // Remove the part of the request which has been sent.
if (bytes_transferred > 0 && (request.size() <= bytes_transferred)) { if (bytes_transferred >= request.size()) {
request.erase(0, bytes_transferred); bytes_transferred = request.size();
} }
request.erase(0, bytes_transferred);
// Continue sending request data if there are still some data to be // Continue sending request data if there are still some data to be
// sent. // sent.
@@ -212,9 +213,11 @@ public:
buf_.data() + bytes_transferred); buf_.data() + bytes_transferred);
} }
// Two consecutive new lines end the part of the response we're // Two consecutive new lines end headers, " } ]" sequence
// expecting. // end large response we're expecting.
if (response_.find("\r\n\r\n", 0) != std::string::npos) { if ((response_.find("\r\n\r\n", 0) != std::string::npos) &&
((response_.size() < 1000) ||
(response_.rfind(" } ]") == (response_.size() - 4)))) {
receive_done_ = true; receive_done_ = true;
io_service_->stop(); io_service_->stop();
} else { } else {
@@ -430,9 +433,10 @@ public:
} }
// Remove the part of the request which has been sent. // Remove the part of the request which has been sent.
if (bytes_transferred > 0 && (request.size() <= bytes_transferred)) { if (bytes_transferred >= request.size()) {
request.erase(0, bytes_transferred); bytes_transferred = request.size();
} }
request.erase(0, bytes_transferred);
// Continue sending request data if there are still some data to be // Continue sending request data if there are still some data to be
// sent. // sent.
@@ -476,9 +480,11 @@ public:
buf_.data() + bytes_transferred); buf_.data() + bytes_transferred);
} }
// Two consecutive new lines end the part of the response we're // Two consecutive new lines end headers, " } ]" sequence
// expecting. // end large response we're expecting.
if (response_.find("\r\n\r\n", 0) != std::string::npos) { if ((response_.find("\r\n\r\n", 0) != std::string::npos) &&
((response_.size() < 1000) ||
(response_.rfind(" } ]") == (response_.size() - 4)))) {
receive_done_ = true; receive_done_ = true;
io_service_->stop(); io_service_->stop();
} else { } else {