Landing Recent QUIC changes until 8/26/2015 19:47 UTC.

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"
 #ifdef TEMP_INSTRUMENTATION_473893
 #include "base/debug/alias.h"
 #endif
@@ skipping 201 matching lines @@
 void QuicSession::OnWindowUpdateFrame(const QuicWindowUpdateFrame& frame) {
   // Stream may be closed by the time we receive a WINDOW_UPDATE, so we can't
   // assume that it still exists.
   QuicStreamId stream_id = frame.stream_id;
   if (stream_id == kConnectionLevelId) {
     // This is a window update that applies to the connection, rather than an
     // individual stream.
     DVLOG(1) << ENDPOINT << "Received connection level flow control window "
                             "update with byte offset: "
              << frame.byte_offset;
-    if (flow_controller_.UpdateSendWindowOffset(frame.byte_offset)) {
-      // Connection level flow control window has increased, so blocked streams
-      // can write again.
-      // TODO(ianswett): I suspect this can be delayed until the packet
-      // processing is complete.
-      if (!FLAGS_quic_dont_write_when_flow_unblocked) {
-        OnCanWrite();
-      }
-    }
+    flow_controller_.UpdateSendWindowOffset(frame.byte_offset);
     return;
   }
   ReliableQuicStream* stream = GetStream(stream_id);
   if (stream) {
     stream->OnWindowUpdateFrame(frame);
   }
 }
 
 void QuicSession::OnBlockedFrame(const QuicBlockedFrame& frame) {
   // TODO(rjshade): Compare our flow control receive windows for specified
@@ skipping 528 matching lines @@
   base::debug::StackTrace stack_trace = stack_trace_;
 
   base::debug::Alias(&liveness);
   base::debug::Alias(&stack_trace);
 
   CHECK_EQ(ALIVE, liveness);
 #endif
 }
 
 }  // namespace net