diff options
| author |  kpayson64 <kpayson@google.com> | 2018-07-30 11:39:34 -0700 |
|---|---|---|
| committer | kpayson64 <kpayson@google.com> | 2018-07-30 11:47:20 -0700 |
| commit | d4c5c84f96cc49c615cef6dbb755fb3c8675ca28 (patch) | |
| tree | 3a5bc8292bf21eae8bcb288523cc8ea57f8e3880 /src/core | |
| parent | 190badb1806c6fc34a4d39669e625ba4719e5f26 (diff) | |
Immediately run write closures for failed stream
Diffstat (limited to 'src/core')
| -rw-r--r-- | src/core/ext/transport/chttp2/transport/chttp2_transport.cc | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc index 9ad271753c..bd6fec6fbe 100644 --- a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc +++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc @@ -1208,7 +1208,7 @@ void grpc_chttp2_complete_closure_step(grpc_chttp2_transport* t, grpc_error_add_child(closure->error_data.error, error); } if (closure->next_data.scratch < CLOSURE_BARRIER_FIRST_REF_BIT) { - if ((t->write_state == GRPC_CHTTP2_WRITE_STATE_IDLE) || + if (s->seen_error || (t->write_state == GRPC_CHTTP2_WRITE_STATE_IDLE) || !(closure->next_data.scratch & CLOSURE_BARRIER_MAY_COVER_WRITE)) { GRPC_CLOSURE_RUN(closure, closure->error_data.error); } else { |