Index: net/test/embedded_test_server/http_request.cc |
diff --git a/net/test/embedded_test_server/http_request.cc b/net/test/embedded_test_server/http_request.cc |
index 3156e5134faa29cfe86586bc03d8ecbcef7ea137..7e41adc3ddc24fc8471e257120d22c995f445930 100644 |
--- a/net/test/embedded_test_server/http_request.cc |
+++ b/net/test/embedded_test_server/http_request.cc |
@@ -10,6 +10,7 @@ |
#include "base/strings/string_util.h" |
#include "base/strings/string_number_conversions.h" |
#include "base/strings/string_split.h" |
+#include "net/http/http_chunked_decoder.h" |
namespace net { |
namespace test_server { |
@@ -140,6 +141,13 @@ HttpRequestParser::ParseResult HttpRequestParser::ParseHeaders() { |
http_request_->headers["Content-Length"], |
&declared_content_length_); |
DCHECK(success) << "Malformed Content-Length header's value."; |
+ } else if (http_request_->headers.count("Transfer-Encoding") > 0) { |
+ if (http_request_->headers["Transfer-Encoding"] == "chunked") { |
+ http_request_->has_content = true; |
+ chunked_decoder_.reset(new HttpChunkedDecoder()); |
+ state_ = STATE_CONTENT; |
+ return WAITING; |
+ } |
} |
if (declared_content_length_ == 0) { |
// No content data, so parsing is finished. |
@@ -155,6 +163,21 @@ HttpRequestParser::ParseResult HttpRequestParser::ParseHeaders() { |
HttpRequestParser::ParseResult HttpRequestParser::ParseContent() { |
const size_t available_bytes = buffer_.size() - buffer_position_; |
+ if (chunked_decoder_.get()) { |
+ std::string result; |
+ result.append(buffer_.data() + buffer_position_, available_bytes); |
+ int bytes_written = chunked_decoder_->FilterBuf( |
+ &result[0], static_cast<int>(result.size())); |
mmenke
2015/02/12 18:22:48
&result[0] -> result.data()
|
+ buffer_position_ += available_bytes; |
xunjieli
2015/02/12 16:54:52
I know why I was having issue with FilterBuf. we s
mmenke
2015/02/12 18:22:48
FilterBuf will parse everything you give it, up to
xunjieli
2015/02/12 22:15:45
I guess one benefit of using result is that we won
|
+ http_request_->content.append(result.data(), bytes_written); |
+ if (chunked_decoder_->reached_eof()) { |
+ state_ = STATE_ACCEPTED; |
+ return ACCEPTED; |
+ } |
+ state_ = STATE_CONTENT; |
+ return WAITING; |
+ } |
+ |
const size_t fetch_bytes = std::min( |
available_bytes, |
declared_content_length_ - http_request_->content.size()); |