diff options
author | 2017-01-03 09:49:07 -0800 | |
---|---|---|
committer | 2017-01-03 09:49:07 -0800 | |
commit | 0b09341461451caaee6bc65bcc41c4a829bfa065 (patch) | |
tree | 5db2bc41669d37d330e3076c82c678e3e297124c /test/core/end2end/tests/filter_causes_close.c | |
parent | 36d374681ae254a4269fec3aa7e5dc7dbb43a768 (diff) | |
parent | aef521c6f9df8d36ae927a4504d055e1d376bfa6 (diff) |
Merge branch 'cleanup_closures' into slice_with_exec_ctx_and_new_closures
Diffstat (limited to 'test/core/end2end/tests/filter_causes_close.c')
-rw-r--r-- | test/core/end2end/tests/filter_causes_close.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/test/core/end2end/tests/filter_causes_close.c b/test/core/end2end/tests/filter_causes_close.c index f51c0a9307..45f623c5c7 100644 --- a/test/core/end2end/tests/filter_causes_close.c +++ b/test/core/end2end/tests/filter_causes_close.c @@ -217,9 +217,9 @@ static void recv_im_ready(grpc_exec_ctx *exec_ctx, void *arg, GRPC_STATUS_PERMISSION_DENIED, &message); grpc_call_next_op(exec_ctx, elem, op); } - grpc_exec_ctx_sched( + grpc_closure_sched( exec_ctx, calld->recv_im_ready, - GRPC_ERROR_CREATE_REFERENCING("Forced call to close", &error, 1), NULL); + GRPC_ERROR_CREATE_REFERENCING("Forced call to close", &error, 1)); } static void start_transport_stream_op(grpc_exec_ctx *exec_ctx, @@ -228,7 +228,8 @@ static void start_transport_stream_op(grpc_exec_ctx *exec_ctx, call_data *calld = elem->call_data; if (op->recv_initial_metadata != NULL) { calld->recv_im_ready = op->recv_initial_metadata_ready; - op->recv_initial_metadata_ready = grpc_closure_create(recv_im_ready, elem); + op->recv_initial_metadata_ready = + grpc_closure_create(recv_im_ready, elem, grpc_schedule_on_exec_ctx); } grpc_call_next_op(exec_ctx, elem, op); } |