Send BLOCKED frame directly from ReliableQuicStream.

net/quic/quic_session.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_session.h"
 
 #include "base/stl_util.h"
 #include "net/quic/crypto/proof_verifier.h"
 #include "net/quic/quic_connection.h"
 #include "net/quic/quic_headers_stream.h"
@@ skipping 546 matching lines @@
     DCHECK(!has_pending_handshake_);
     has_pending_handshake_ = true;
     // TODO(jar): Be sure to use the highest priority for the crypto stream,
     // perhaps by adding a "special" priority for it that is higher than
     // kHighestPriority.
     priority = kHighestPriority;
   }
   write_blocked_streams_.PushBack(id, priority);
 }
 
-void QuicSession::MarkFlowControlBlocked(QuicStreamId id,
-                                         QuicPriority priority) {
-  ReliableQuicStream* stream = GetStream(id);
-  if (stream == NULL) {
-    LOG(DFATAL) << "Trying to mark nonexistent stream " << id
-                << " flow control blocked.";
-    return;
-  }
-
-  // Send a BLOCKED frame to peer.
-  connection()->SendBlocked(id);
-}
-
 bool QuicSession::HasDataToWrite() const {
   return write_blocked_streams_.HasWriteBlockedStreams() ||
       connection_->HasQueuedData();
 }
 
 bool QuicSession::GetSSLInfo(SSLInfo* ssl_info) const {
   NOTIMPLEMENTED();
   return false;
 }
 
 void QuicSession::PostProcessAfterData() {
   STLDeleteElements(&closed_streams_);
   closed_streams_.clear();
 }
 
 }  // namespace net