Remove the QuicChromiumClientStream::Delegate::HasSendHeadersComplete()

net/quic/chromium/quic_chromium_client_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_chromium_client_stream.h"
 
 #include <utility>
 
 #include "base/bind_helpers.h"
 #include "base/callback_helpers.h"
@@ skipping 11 matching lines @@
 namespace net {
 
 QuicChromiumClientStream::QuicChromiumClientStream(
     QuicStreamId id,
     QuicClientSessionBase* session,
     const NetLogWithSource& net_log)
     : QuicSpdyStream(id, session),
       net_log_(net_log),
       delegate_(nullptr),
       headers_delivered_(false),
+      initial_headers_sent_(false),
       session_(session),
       can_migrate_(true),
       weak_factory_(this) {}
 
 QuicChromiumClientStream::~QuicChromiumClientStream() {
   if (delegate_)
     delegate_->OnClose();
 }
 
 void QuicChromiumClientStream::OnInitialHeadersComplete(
@@ skipping 84 matching lines @@
     QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener) {
   if (!session()->IsCryptoHandshakeConfirmed()) {
     auto entry = header_block.find(":method");
     DCHECK(entry != header_block.end());
     DCHECK_NE("POST", entry->second);
   }
   net_log_.AddEvent(
       NetLogEventType::QUIC_CHROMIUM_CLIENT_STREAM_SEND_REQUEST_HEADERS,
       base::Bind(&QuicRequestNetLogCallback, id(), &header_block,
                  QuicSpdyStream::priority()));
-  return QuicSpdyStream::WriteHeaders(std::move(header_block), fin,
-                                      std::move(ack_listener));
+  size_t len = QuicSpdyStream::WriteHeaders(std::move(header_block), fin,
+                                            std::move(ack_listener));
+  initial_headers_sent_ = true;
+  return len;
 }
 
 SpdyPriority QuicChromiumClientStream::priority() const {
-  if (delegate_ && delegate_->HasSendHeadersComplete()) {
-    return QuicSpdyStream::priority();
-  }
-  return net::kV3HighestPriority;
+  return initial_headers_sent_ ? QuicSpdyStream::priority()
+                               : kV3HighestPriority;
 }
 
 int QuicChromiumClientStream::WriteStreamData(
     QuicStringPiece data,
     bool fin,
     const CompletionCallback& callback) {
   // We should not have data buffered.
   DCHECK(!HasBufferedData());
   // Writes the data, or buffers it.
   WriteOrBufferData(data, fin, nullptr);
@@ skipping 118 matching lines @@
 
 void QuicChromiumClientStream::DisableConnectionMigration() {
   can_migrate_ = false;
 }
 
 bool QuicChromiumClientStream::IsFirstStream() {
   return id() == kHeadersStreamId + 2;
 }
 
 }  // namespace net