diff options
| author |  Nicolas Noble <nicolasnoble@users.noreply.github.com> | 2015-07-09 16:49:26 -0700 |
|---|---|---|
| committer | Nicolas Noble <nicolasnoble@users.noreply.github.com> | 2015-07-09 16:49:26 -0700 |
| commit | 909f3b4c4d1e0d7ffad3a339194962831db69aa2 (patch) | |
| tree | f3355041871480af1d917542aa03afee4665cb6d | |
| parent | 20aae902aa92d083a0a86928ead67a9ee3f40556 (diff) | |
| parent | f8c90504428734ed31429f2186a573006af891b0 (diff) | |
Merge pull request #2312 from ctiller/help-help-im-stuck-and-i-cant-reach-my-tcp-connection
Handle settings frame making a stream writable
| -rw-r--r-- | src/core/transport/chttp2_transport.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/core/transport/chttp2_transport.c b/src/core/transport/chttp2_transport.c index 322ff39820..ac399e4a1d 100644 --- a/src/core/transport/chttp2_transport.c +++ b/src/core/transport/chttp2_transport.c @@ -876,11 +876,19 @@ static void update_global_window(void *args, gpr_uint32 id, void *stream) { grpc_chttp2_stream *s = stream; grpc_chttp2_transport_global *transport_global = &t->global; grpc_chttp2_stream_global *stream_global = &s->global; + int was_zero; + int is_zero; GRPC_CHTTP2_FLOWCTL_TRACE_STREAM("settings", transport_global, stream_global, outgoing_window, t->parsing.initial_window_update); + was_zero = stream_global->outgoing_window <= 0; stream_global->outgoing_window += t->parsing.initial_window_update; + is_zero = stream_global->outgoing_window <= 0; + + if (was_zero && !is_zero) { + grpc_chttp2_list_add_writable_stream(transport_global, stream_global); + } } static void read_error_locked(grpc_chttp2_transport *t) { |