diff options
| author |  Yang Gao <yangg@google.com> | 2015-09-03 16:43:34 -0700 |
|---|---|---|
| committer | Yang Gao <yangg@google.com> | 2015-09-03 16:43:34 -0700 |
| commit | 2b5255e3dafb970c2ad6b9a8382d2a7d8165a9e6 (patch) | |
| tree | b3da9bff35bf0c26304b459544bf7326a8a45e4f /src/core/transport/chttp2 | |
| parent | 51bfda063a903c15429cede9ab9dab4c355b7c9a (diff) | |
| parent | 93ddc61c1084e2c312edf00ac7c7cf6d5f8d8aa3 (diff) | |
Merge pull request #3190 from ctiller/daisy-dukes
Fix flow control issues
Diffstat (limited to 'src/core/transport/chttp2')
| -rw-r--r-- | src/core/transport/chttp2/writing.c | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/core/transport/chttp2/writing.c b/src/core/transport/chttp2/writing.c index 2c8c48f47b..ac79044e08 100644 --- a/src/core/transport/chttp2/writing.c +++ b/src/core/transport/chttp2/writing.c @@ -113,6 +113,10 @@ int grpc_chttp2_unlocking_check_writes( if (!stream_global->read_closed && stream_global->unannounced_incoming_window > 0) { + GPR_ASSERT(stream_writing->announce_window == 0); + GRPC_CHTTP2_FLOWCTL_TRACE_STREAM( + "write", transport_writing, stream_writing, announce_window, + stream_global->unannounced_incoming_window); stream_writing->announce_window = stream_global->unannounced_incoming_window; GRPC_CHTTP2_FLOWCTL_TRACE_STREAM( @@ -196,6 +200,9 @@ static void finalize_outbuf(grpc_chttp2_transport_writing *transport_writing) { &transport_writing->outbuf, grpc_chttp2_window_update_create(stream_writing->id, stream_writing->announce_window)); + GRPC_CHTTP2_FLOWCTL_TRACE_STREAM( + "write", transport_writing, stream_writing, announce_window, + -(gpr_int64)stream_writing->announce_window); stream_writing->announce_window = 0; } if (stream_writing->send_closed == GRPC_SEND_CLOSED_WITH_RST_STREAM) { |