From 2df30b144748dda434aa0002d636220e1f3aa87b Mon Sep 17 00:00:00 2001
From: Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>
Date: Thu, 3 Nov 2016 16:29:04 +0900
Subject: [PATCH] Support 1xx non-final response

---
 src/HttpConnection.cc | 14 +++++++++++++-
 src/HttpConnection.h  |  4 ++++
 2 files changed, 17 insertions(+), 1 deletion(-)

diff --git a/src/HttpConnection.cc b/src/HttpConnection.cc
index d29f4a30..77cb9d27 100644
--- a/src/HttpConnection.cc
+++ b/src/HttpConnection.cc
@@ -68,6 +68,11 @@ HttpRequestEntry::HttpRequestEntry(std::unique_ptr<HttpRequest> httpRequest)
 {
 }
 
+void HttpRequestEntry::resetHttpHeaderProcessor()
+{
+  proc_ = make_unique<HttpHeaderProcessor>(HttpHeaderProcessor::CLIENT_PARSER);
+}
+
 std::unique_ptr<HttpRequest> HttpRequestEntry::popHttpRequest()
 {
   return std::move(httpRequest_);
@@ -151,9 +156,16 @@ std::unique_ptr<HttpResponse> HttpConnection::receiveResponse()
                   socketRecvBuffer_->getBufferLength())) {
     A2_LOG_INFO(
         fmt(MSG_RECEIVE_RESPONSE, cuid_, proc->getHeaderString().c_str()));
+    auto result = proc->getResult();
+    if (result->getStatusCode() / 100 == 1) {
+      socketRecvBuffer_->drain(proc->getLastBytesProcessed());
+      outstandingHttpRequests_.front()->resetHttpHeaderProcessor();
+      return nullptr;
+    }
+
     auto httpResponse = make_unique<HttpResponse>();
     httpResponse->setCuid(cuid_);
-    httpResponse->setHttpHeader(proc->getResult());
+    httpResponse->setHttpHeader(std::move(result));
     httpResponse->setHttpRequest(
         outstandingHttpRequests_.front()->popHttpRequest());
     socketRecvBuffer_->drain(proc->getLastBytesProcessed());
diff --git a/src/HttpConnection.h b/src/HttpConnection.h
index 205dd9ba..54da32d1 100644
--- a/src/HttpConnection.h
+++ b/src/HttpConnection.h
@@ -62,6 +62,10 @@ private:
 public:
   HttpRequestEntry(std::unique_ptr<HttpRequest> httpRequest);
 
+  // Resets proc_ by recreating the object.  Thus any object obtained
+  // by getHttpRequest() before this call is invalidated.
+  void resetHttpHeaderProcessor();
+
   const std::unique_ptr<HttpRequest>& getHttpRequest() const
   {
     return httpRequest_;