Send BLOCKED frame directly from ReliableQuicStream.

net/quic/reliable_quic_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/reliable_quic_stream.h"
 
 #include "base/logging.h"
 #include "net/quic/iovector.h"
 #include "net/quic/quic_session.h"
 #include "net/quic/quic_write_blocked_list.h"
@@ skipping 333 matching lines @@
 
   // How much data we are allowed to write from flow control.
   size_t send_window = SendWindowSize();
 
   // A FIN with zero data payload should not be flow control blocked.
   bool fin_with_zero_data = (fin && write_length == 0);
 
   if (IsFlowControlEnabled()) {
     if (send_window == 0 && !fin_with_zero_data) {
       // Quick return if we can't send anything.
-      session_->MarkFlowControlBlocked(id(), EffectivePriority());
+      session()->connection()->SendBlocked(id());
       return QuicConsumedData(0, false);
     }
 
     if (write_length > send_window) {
       // Don't send the FIN if we aren't going to send all the data.
       fin = false;
 
       // Writing more data would be a violation of flow control.
       write_length = send_window;
     }
@@ skipping 11 matching lines @@
     if (IsFlowControlEnabled() && write_length == send_window &&
         !fin_with_zero_data) {
       DVLOG(1) << ENDPOINT << "Stream " << id()
                << " is flow control blocked. "
                << "Send window: " << send_window
                << ", stream_bytes_written: " << stream_bytes_written_
                << ", flow_control_send_limit: "
                << flow_control_send_limit_;
       // The entire send_window has been consumed, we are now flow control
       // blocked.
-      session_->MarkFlowControlBlocked(id(), EffectivePriority());
+      session()->connection()->SendBlocked(id());
     }
     if (fin && consumed_data.fin_consumed) {
       fin_sent_ = true;
       CloseWriteSide();
     } else if (fin && !consumed_data.fin_consumed) {
       session_->MarkWriteBlocked(id(), EffectivePriority());
     }
   } else {
     session_->MarkWriteBlocked(id(), EffectivePriority());
   }
@@ skipping 87 matching lines @@
 
 uint64 ReliableQuicStream::SendWindowSize() const {
   return flow_control_send_limit_ - stream_bytes_written();
 }
 
 uint64 ReliableQuicStream::TotalReceivedBytes() const {
   return sequencer_.num_bytes_consumed() + sequencer_.num_bytes_buffered();
 }
 
 }  // namespace net