Enable support for QUIC 13.

net/quic/quic_http_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/quic/quic_http_stream.h"
 
 #include "base/callback_helpers.h"
 #include "base/strings/stringprintf.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
@@ skipping 388 matching lines @@
   } while (next_state_ != STATE_NONE && next_state_ != STATE_OPEN &&
            rv != ERR_IO_PENDING);
 
   return rv;
 }
 
 int QuicHttpStream::DoSendHeaders() {
   if (!stream_)
     return ERR_UNEXPECTED;
 
-  if (request_.empty() && !stream_->CanWrite(
-          base::Bind(&QuicHttpStream::OnIOComplete,
-                     weak_factory_.GetWeakPtr()))) {
-    // Do not compress headers unless it is likely that they can be sent.
-    next_state_ = STATE_SEND_HEADERS;
-    return ERR_IO_PENDING;
+  if (stream_->version() <= QUIC_VERSION_12) {
+    if (request_.empty() && !stream_->CanWrite(
+            base::Bind(&QuicHttpStream::OnIOComplete,
+                       weak_factory_.GetWeakPtr()))) {
+      // Do not compress headers unless it is likely that they can be sent.
+      next_state_ = STATE_SEND_HEADERS;
+      return ERR_IO_PENDING;
+    }
+    request_ = stream_->compressor()->CompressHeadersWithPriority(
+        ConvertRequestPriorityToQuicPriority(priority_), request_headers_);
   }
-  request_ = stream_->compressor()->CompressHeadersWithPriority(
-      ConvertRequestPriorityToQuicPriority(priority_), request_headers_);
-
   // Log the actual request with the URL Request's net log.
   stream_net_log_.AddEvent(
       NetLog::TYPE_HTTP_TRANSACTION_SPDY_SEND_REQUEST_HEADERS,
       base::Bind(&SpdyHeaderBlockNetLogCallback, &request_headers_));
   // Also log to the QuicSession's net log.
   stream_->net_log().AddEvent(
       NetLog::TYPE_QUIC_HTTP_STREAM_SEND_REQUEST_HEADERS,
       base::Bind(&SpdyHeaderBlockNetLogCallback, &request_headers_));
-  request_headers_.clear();
 
   bool has_upload_data = request_body_stream_ != NULL;
 
   next_state_ = STATE_SEND_HEADERS_COMPLETE;
-  return stream_->WriteStreamData(
-      request_, !has_upload_data,
-      base::Bind(&QuicHttpStream::OnIOComplete, weak_factory_.GetWeakPtr()));
+  int rv = (stream_->version() > QUIC_VERSION_12) ?
+      stream_->WriteHeaders(request_headers_, !has_upload_data) :
+      stream_->WriteStreamData(request_, !has_upload_data,
+                               base::Bind(&QuicHttpStream::OnIOComplete,
+                                          weak_factory_.GetWeakPtr()));
+  request_headers_.clear();
+  return rv;
 }
 
 int QuicHttpStream::DoSendHeadersComplete(int rv) {
   if (rv < 0)
     return rv;
 
   next_state_ = request_body_stream_ ?
       STATE_READ_REQUEST_BODY : STATE_OPEN;
 
   return OK;
@@ skipping 101 matching lines @@
 
 void QuicHttpStream::BufferResponseBody(const char* data, int length) {
   if (length == 0)
     return;
   IOBufferWithSize* io_buffer = new IOBufferWithSize(length);
   memcpy(io_buffer->data(), data, length);
   response_body_.push_back(make_scoped_refptr(io_buffer));
 }
 
 }  // namespace net