Reset stream if HTTP/2 response status is invalid.

net/spdy/spdy_stream.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/spdy/spdy_stream.h"
 
 #include <algorithm>
 #include <limits>
 #include <utility>
 
@@ skipping 14 matching lines @@
 #include "net/spdy/platform/api/spdy_estimate_memory_usage.h"
 #include "net/spdy/platform/api/spdy_string_piece.h"
 #include "net/spdy/spdy_buffer_producer.h"
 #include "net/spdy/spdy_http_utils.h"
 #include "net/spdy/spdy_session.h"
 
 namespace net {
 
 namespace {
 
-enum StatusHeader {
-  STATUS_HEADER_NOT_INCLUDED = 0,
-  STATUS_HEADER_DOES_NOT_START_WITH_NUMBER = 1,
-  STATUS_HEADER_IS_NUMBER = 2,
-  STATUS_HEADER_HAS_STATUS_TEXT = 3,
-  STATUS_HEADER_MAX = STATUS_HEADER_HAS_STATUS_TEXT
-};
-
-StatusHeader ParseStatusHeaderImpl(const SpdyHeaderBlock& response_headers,
-                                   int* status) {
-  SpdyHeaderBlock::const_iterator it = response_headers.find(":status");
-  if (it == response_headers.end())
-    return STATUS_HEADER_NOT_INCLUDED;
-
-  // Save status in |*status| even if some text follows the status code.
-  SpdyStringPiece status_string = it->second;
-  SpdyStringPiece::size_type end = status_string.find(' ');
-  if (!StringToInt(status_string.substr(0, end), status))
-    return STATUS_HEADER_DOES_NOT_START_WITH_NUMBER;
-
-  return end == SpdyStringPiece::npos ? STATUS_HEADER_IS_NUMBER
-                                      : STATUS_HEADER_HAS_STATUS_TEXT;
-}
-
-StatusHeader ParseStatusHeader(const SpdyHeaderBlock& response_headers,
-                               int* status) {
-  StatusHeader status_header = ParseStatusHeaderImpl(response_headers, status);
-  UMA_HISTOGRAM_ENUMERATION("Net.Http2ResponseStatusHeader", status_header,
-                            STATUS_HEADER_MAX + 1);
-  return status_header;
-}
-
 std::unique_ptr<base::Value> NetLogSpdyStreamErrorCallback(
     SpdyStreamId stream_id,
     int status,
     const std::string* description,
     NetLogCaptureMode /* capture_mode */) {
   std::unique_ptr<base::DictionaryValue> dict(new base::DictionaryValue());
   dict->SetInteger("stream_id", static_cast<int>(stream_id));
   dict->SetInteger("status", status);
   dict->SetString("description", *description);
   return std::move(dict);
@@ skipping 327 matching lines @@
 }
 
 void SpdyStream::SetRequestTime(base::Time t) {
   request_time_ = t;
 }
 
 void SpdyStream::OnHeadersReceived(const SpdyHeaderBlock& response_headers,
                                    base::Time response_time,
                                    base::TimeTicks recv_first_byte_time) {
   switch (response_state_) {
-    case READY_FOR_HEADERS: {
+    case READY_FOR_HEADERS:
       // No header block has been received yet.
       DCHECK(response_headers_.empty());
-      int status;
-      switch (ParseStatusHeader(response_headers, &status)) {
-        case STATUS_HEADER_NOT_INCLUDED: {
+
+      {
+        SpdyHeaderBlock::const_iterator it = response_headers.find(":status");
+        if (it == response_headers.end()) {
           const std::string error("Response headers do not include :status.");
           LogStreamError(ERR_SPDY_PROTOCOL_ERROR, error);
           session_->ResetStream(stream_id_, ERROR_CODE_PROTOCOL_ERROR, error);
           return;
         }
-        case STATUS_HEADER_DOES_NOT_START_WITH_NUMBER: {
+
+        int status;
+        if (!StringToInt(it->second, &status)) {
           const std::string error("Cannot parse :status.");
           LogStreamError(ERR_SPDY_PROTOCOL_ERROR, error);
           session_->ResetStream(stream_id_, ERROR_CODE_PROTOCOL_ERROR, error);
           return;
         }
-        // Intentional fallthrough for the following two cases,
-        // to maintain compatibility with broken servers that include
-        // status text in the response.
-        case STATUS_HEADER_IS_NUMBER:
-        case STATUS_HEADER_HAS_STATUS_TEXT:
-          // Ignore informational headers.
-          // TODO(bnc): Add support for 103 Early Hints,
-          // https://crbug.com/671310.
-          if (status / 100 == 1) {
-            return;
-          }
+
+        // Ignore informational headers.
+        // TODO(bnc): Add support for 103 Early Hints, https://crbug.com/671310.
+        if (status / 100 == 1) {
+          return;
+        }
       }
 
       response_state_ = READY_FOR_DATA_OR_TRAILERS;
 
       switch (type_) {
         case SPDY_BIDIRECTIONAL_STREAM:
         case SPDY_REQUEST_RESPONSE_STREAM:
           // A bidirectional stream or a request/response stream is ready for
           // the response headers only after request headers are sent.
           if (io_state_ == STATE_IDLE) {
@@ skipping 17 matching lines @@
           break;
       }
 
       DCHECK_NE(io_state_, STATE_IDLE);
 
       response_time_ = response_time;
       recv_first_byte_time_ = recv_first_byte_time;
       SaveResponseHeaders(response_headers);
 
       break;
-    }
+
     case READY_FOR_DATA_OR_TRAILERS:
       // Second header block is trailers.
       if (type_ == SPDY_PUSH_STREAM) {
         const std::string error("Trailers not supported for push stream.");
         LogStreamError(ERR_SPDY_PROTOCOL_ERROR, error);
         session_->ResetStream(stream_id_, ERROR_CODE_PROTOCOL_ERROR, error);
         return;
       }
 
       response_state_ = TRAILERS_RECEIVED;
@@ skipping 463 matching lines @@
       description = base::StringPrintf("Unknown state 0x%08X (%u)", state,
                                        state);
       break;
   }
   return description;
 }
 
 #undef STATE_CASE
 
 }  // namespace net