Split QuicChromiumClientStreamDelegate::OnHeadersAvailable into

net/quic/chromium/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/chromium/quic_http_stream.h"
 
 #include <utility>
 
 #include "base/auto_reset.h"
 #include "base/callback_helpers.h"
@@ skipping 415 matching lines @@
       ConnectionInfoFromQuicVersion(quic_session()->GetQuicVersion());
   quic_session()->PopulateNetErrorDetails(details);
   if (quic_session()->IsCryptoHandshakeConfirmed())
     details->quic_connection_error = quic_connection_error_;
 }
 
 void QuicHttpStream::SetPriority(RequestPriority priority) {
   priority_ = priority;
 }
 
-void QuicHttpStream::OnHeadersAvailable(const SpdyHeaderBlock& headers,
-                                        size_t frame_len) {
+void QuicHttpStream::OnInitialHeadersAvailable(const SpdyHeaderBlock& headers,
+                                               size_t frame_len) {
+  DCHECK(!response_headers_received_);
   headers_bytes_received_ += frame_len;
 
-  // QuicHttpStream ignores trailers.
-  if (response_headers_received_) {
-    if (stream_->IsDoneReading()) {
-      // Close the read side. If the write side has been closed, this will
-      // invoke QuicHttpStream::OnClose to reset the stream.
-      stream_->OnFinRead();
-      SetResponseStatus(OK);
-    }
-    return;
-  }
-
   int rv = ProcessResponseHeaders(headers);
   if (rv != ERR_IO_PENDING && !callback_.is_null()) {
     DoCallback(rv);
   }
 }
 
+void QuicHttpStream::OnTrailingHeadersAvailable(const SpdyHeaderBlock& headers,
+                                                size_t frame_len) {
+  DCHECK(response_headers_received_);
+  headers_bytes_received_ += frame_len;
+
+  // QuicHttpStream ignores trailers.
+  if (stream_->IsDoneReading()) {
+    // Close the read side. If the write side has been closed, this will
+    // invoke QuicHttpStream::OnClose to reset the stream.
+    stream_->OnFinRead();
+    SetResponseStatus(OK);
+  }
+}
+
 void QuicHttpStream::OnDataAvailable() {
   if (callback_.is_null()) {
     // Data is available, but can't be delivered
     return;
   }
 
   CHECK(user_buffer_.get());
   CHECK_NE(0, user_buffer_len_);
   int rv = ReadAvailableData(user_buffer_.get(), user_buffer_len_);
   if (rv == ERR_IO_PENDING) {
@@ skipping 361 matching lines @@
       quic_stream_error_ != QUIC_STREAM_CONNECTION_ERROR) {
     return ERR_QUIC_PROTOCOL_ERROR;
   }
 
   DCHECK_NE(QUIC_HANDSHAKE_TIMEOUT, quic_connection_error_);
 
   return ERR_QUIC_PROTOCOL_ERROR;
 }
 
 }  // namespace net