Landing Recent QUIC changes until 9:58 AM, Sep 17, 2016 UTC

net/quic/core/quic_headers_stream.cc

 // Copyright 2013 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/quic/core/quic_headers_stream.h"
 
 #include <utility>
 
 #include "base/macros.h"
 #include "base/metrics/histogram_macros.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/stringprintf.h"
 #include "net/quic/core/quic_bug_tracker.h"
 #include "net/quic/core/quic_flags.h"
 #include "net/quic/core/quic_header_list.h"
+#include "net/quic/core/quic_server_session_base.h"
 #include "net/quic/core/quic_spdy_session.h"
 #include "net/quic/core/quic_time.h"
 #include "net/spdy/spdy_protocol.h"
 
 using base::StringPiece;
 using net::HTTP2;
 using net::SpdyFrameType;
 using std::string;
 
 namespace net {
@@ skipping 163 matching lines @@
 
   void OnSetting(SpdySettingsIds id, uint8_t flags, uint32_t value) override {
     if (!FLAGS_quic_respect_http2_settings_frame) {
       CloseConnection("SPDY SETTINGS frame received.");
       return;
     }
     switch (id) {
       case SETTINGS_HEADER_TABLE_SIZE:
         stream_->UpdateHeaderEncoderTableSize(value);
         break;
+      case SETTINGS_ENABLE_PUSH:
+        if (FLAGS_quic_enable_server_push_by_default &&
+            stream_->session()->perspective() == Perspective::IS_SERVER) {
+          // See rfc7540, Section 6.5.2.
+          if (value > 1) {
+            CloseConnection("Invalid value for SETTINGS_ENABLE_PUSH: " +
+                            base::IntToString(value));
+            return;
+          }
+          stream_->UpdateEnableServerPush(value > 0);
+          break;
+        } else {
+          CloseConnection("Unsupported field of HTTP/2 SETTINGS frame: " +
+                          base::IntToString(id));
+        }
+        break;
       // TODO(fayang): Need to support SETTINGS_MAX_HEADER_LIST_SIZE when
       // clients are actually sending it.
       default:
         CloseConnection("Unsupported field of HTTP/2 SETTINGS frame: " +
                         base::IntToString(id));
     }
   }
 
   void OnSettingsAck() override {
     if (!FLAGS_quic_respect_http2_settings_frame) {
@@ skipping 377 matching lines @@
     std::unique_ptr<HpackDebugVisitor> visitor) {
   spdy_framer_.SetDecoderHeaderTableDebugVisitor(
       std::unique_ptr<HeaderTableDebugVisitor>(new HeaderTableDebugVisitor(
           session()->connection()->helper()->GetClock(), std::move(visitor))));
 }
 
 void QuicHeadersStream::UpdateHeaderEncoderTableSize(uint32_t value) {
   spdy_framer_.UpdateHeaderEncoderTableSize(value);
 }
 
+void QuicHeadersStream::UpdateEnableServerPush(bool value) {
+  spdy_session_->set_server_push_enabled(value);
+}
+
 bool QuicHeadersStream::OnDataFrameHeader(QuicStreamId stream_id,
                                           size_t length,
                                           bool fin) {
   if (!spdy_session_->force_hol_blocking()) {
     return false;
   }
   if (!IsConnected()) {
     return true;
   }
   DVLOG(1) << "DATA frame header for stream " << stream_id << " length "
@@ skipping 16 matching lines @@
     return true;
   }
   frame_len_ -= len;
   // Ignore fin_ while there is more data coming, if frame_len_ > 0.
   spdy_session_->OnStreamFrameData(stream_id, data, len,
                                    frame_len_ > 0 ? false : fin_);
   return true;
 }
 
 }  // namespace net