diff options
| author |  David Garcia Quintas <dgq@google.com> | 2016-12-07 10:50:30 -0800 |
|---|---|---|
| committer | David G. Quintas <dgq@google.com> | 2016-12-07 17:02:07 -0800 |
| commit | ec7ba3931741f349b59f531d35677891a0a24baf (patch) | |
| tree | 2bd16c46420b7946f6e99d2d999f4d33dd8798e5 | |
| parent | 3da4188176eb76a1a786249ac840b0a83242e397 (diff) | |
PR comments
| -rw-r--r-- | src/core/ext/transport/chttp2/transport/chttp2_transport.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.c b/src/core/ext/transport/chttp2/transport/chttp2_transport.c index 72711d69dc..6bc054866b 100644 --- a/src/core/ext/transport/chttp2/transport/chttp2_transport.c +++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.c @@ -1622,8 +1622,10 @@ void grpc_chttp2_mark_stream_closed(grpc_exec_ctx *exec_ctx, if (s->id != 0) { remove_stream(exec_ctx, t, s->id, removal_error(GRPC_ERROR_REF(error), s, "Stream removed")); + } else { + /* Purge streams waiting on concurrency still waiting for id assignment */ + grpc_chttp2_list_remove_waiting_for_concurrency(t, s); } - grpc_chttp2_list_remove_waiting_for_concurrency(t, s); GRPC_CHTTP2_STREAM_UNREF(exec_ctx, s, "chttp2"); } GRPC_ERROR_UNREF(error); |