aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/ext
diff options
context:
space:
mode:
authorGravatar Mark D. Roth <roth@google.com>2017-12-04 08:45:22 -0800
committerGravatar Mark D. Roth <roth@google.com>2017-12-04 08:45:22 -0800
commita92428bc85381bac5767688813fcaa9a6dbf586b (patch)
tree3b692073823c34263d26a2dd7384cfc175d95f7d /src/core/ext
parente109ddf89f966b1f99290ec15a14ec3859049099 (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.cc10
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);