diff options
| author |  Craig Tiller <ctiller@google.com> | 2016-05-09 11:23:05 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2016-05-09 11:23:05 -0700 |
| commit | 86df5a8521d22e66e07ab00c735668cb4e07381f (patch) | |
| tree | 14b68f3c1ad9cadd4c82d66f3e19ced57133731f /test/core/end2end/tests/filter_causes_close.c | |
| parent | 91472967c7134003229ecc881f361a2c2a4b7ea2 (diff) | |
Fix filter_causes_close
Diffstat (limited to 'test/core/end2end/tests/filter_causes_close.c')
| -rw-r--r-- | test/core/end2end/tests/filter_causes_close.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/test/core/end2end/tests/filter_causes_close.c b/test/core/end2end/tests/filter_causes_close.c index 405e75294d..8fd847b878 100644 --- a/test/core/end2end/tests/filter_causes_close.c +++ b/test/core/end2end/tests/filter_causes_close.c @@ -175,7 +175,7 @@ static void test_request(grpc_end2end_test_config config) { cq_verify(cqv); GPR_ASSERT(status == GRPC_STATUS_PERMISSION_DENIED); - GPR_ASSERT(0 == strcmp(details, "Random failure that's not preventable.")); + GPR_ASSERT(0 == strcmp(details, "Failure that's not preventable.")); gpr_free(details); grpc_metadata_array_destroy(&initial_metadata_recv); @@ -209,14 +209,16 @@ static void recv_im_ready(grpc_exec_ctx *exec_ctx, void *arg, if (error == GRPC_ERROR_NONE) { // close the stream with an error. gpr_slice message = - gpr_slice_from_copied_string("Random failure that's not preventable."); + gpr_slice_from_copied_string("Failure that's not preventable."); grpc_transport_stream_op op; memset(&op, 0, sizeof(op)); grpc_transport_stream_op_add_close(&op, GRPC_STATUS_PERMISSION_DENIED, &message); grpc_call_next_op(exec_ctx, elem, &op); } - calld->recv_im_ready->cb(exec_ctx, calld->recv_im_ready->cb_arg, false); + grpc_exec_ctx_push( + exec_ctx, calld->recv_im_ready, + GRPC_ERROR_CREATE_REFERENCING("Forced call to close", &error, 1), NULL); } static void start_transport_stream_op(grpc_exec_ctx *exec_ctx, |