diff options
author | 2017-12-04 08:45:22 -0800 | |
---|---|---|
committer | 2017-12-04 08:45:22 -0800 | |
commit | a92428bc85381bac5767688813fcaa9a6dbf586b (patch) | |
tree | 3b692073823c34263d26a2dd7384cfc175d95f7d /src/core/ext | |
parent | e109ddf89f966b1f99290ec15a14ec3859049099 (diff) |
Move chttp2 cleanup code into close_transport_locked().
Diffstat (limited to 'src/core/ext')
-rw-r--r-- | src/core/ext/transport/chttp2/transport/chttp2_transport.cc | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc index 607fbf306a..3a2c4b6d1b 100644 --- a/src/core/ext/transport/chttp2/transport/chttp2_transport.cc +++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.cc @@ -651,6 +651,11 @@ static void close_transport_locked(grpc_exec_ctx* exec_ctx, GPR_ASSERT(t->write_state == GRPC_CHTTP2_WRITE_STATE_IDLE); grpc_endpoint_shutdown(exec_ctx, t->ep, GRPC_ERROR_REF(error)); } + if (t->notify_on_receive_settings != nullptr) { + GRPC_CLOSURE_SCHED(exec_ctx, t->notify_on_receive_settings, + GRPC_ERROR_CANCELLED); + t->notify_on_receive_settings = nullptr; + } GRPC_ERROR_UNREF(error); } @@ -1823,11 +1828,6 @@ static void perform_transport_op_locked(grpc_exec_ctx* exec_ctx, if (op->disconnect_with_error != GRPC_ERROR_NONE) { close_transport_locked(exec_ctx, t, op->disconnect_with_error); - if (t->notify_on_receive_settings != nullptr) { - GRPC_CLOSURE_SCHED(exec_ctx, t->notify_on_receive_settings, - GRPC_ERROR_CANCELLED); - t->notify_on_receive_settings = nullptr; - } } GRPC_CLOSURE_RUN(exec_ctx, op->on_consumed, GRPC_ERROR_NONE); |