|
|
|
@ -93,12 +93,9 @@ static void end_test(grpc_end2end_test_fixture *f) { |
|
|
|
|
shutdown_server(f); |
|
|
|
|
shutdown_client(f); |
|
|
|
|
|
|
|
|
|
grpc_completion_queue_shutdown(f->server_cq); |
|
|
|
|
drain_cq(f->server_cq); |
|
|
|
|
grpc_completion_queue_destroy(f->server_cq); |
|
|
|
|
grpc_completion_queue_shutdown(f->client_cq); |
|
|
|
|
drain_cq(f->client_cq); |
|
|
|
|
grpc_completion_queue_destroy(f->client_cq); |
|
|
|
|
grpc_completion_queue_shutdown(f->cq); |
|
|
|
|
drain_cq(f->cq); |
|
|
|
|
grpc_completion_queue_destroy(f->cq); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/* Cancel before invoke */ |
|
|
|
@ -109,7 +106,7 @@ static void test_cancel_before_invoke(grpc_end2end_test_config config, |
|
|
|
|
grpc_call *c; |
|
|
|
|
grpc_end2end_test_fixture f = begin_test(config, __FUNCTION__, NULL, NULL); |
|
|
|
|
gpr_timespec deadline = five_seconds_time(); |
|
|
|
|
cq_verifier *v_client = cq_verifier_create(f.client_cq); |
|
|
|
|
cq_verifier *cqv = cq_verifier_create(f.cq); |
|
|
|
|
grpc_metadata_array initial_metadata_recv; |
|
|
|
|
grpc_metadata_array trailing_metadata_recv; |
|
|
|
|
grpc_metadata_array request_metadata_recv; |
|
|
|
@ -122,7 +119,7 @@ static void test_cancel_before_invoke(grpc_end2end_test_config config, |
|
|
|
|
grpc_byte_buffer *request_payload = |
|
|
|
|
grpc_byte_buffer_create(&request_payload_slice, 1); |
|
|
|
|
|
|
|
|
|
c = grpc_channel_create_call(f.client, f.client_cq, "/foo", |
|
|
|
|
c = grpc_channel_create_call(f.client, f.cq, "/foo", |
|
|
|
|
"foo.test.google.fr", deadline); |
|
|
|
|
GPR_ASSERT(c); |
|
|
|
|
|
|
|
|
@ -156,8 +153,8 @@ static void test_cancel_before_invoke(grpc_end2end_test_config config, |
|
|
|
|
op++; |
|
|
|
|
GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(c, ops, test_ops, tag(1))); |
|
|
|
|
|
|
|
|
|
cq_expect_completion(v_client, tag(1), GRPC_OP_OK); |
|
|
|
|
cq_verify(v_client); |
|
|
|
|
cq_expect_completion(cqv, tag(1), GRPC_OP_OK); |
|
|
|
|
cq_verify(cqv); |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(status == GRPC_STATUS_CANCELLED); |
|
|
|
|
|
|
|
|
@ -172,7 +169,7 @@ static void test_cancel_before_invoke(grpc_end2end_test_config config, |
|
|
|
|
|
|
|
|
|
grpc_call_destroy(c); |
|
|
|
|
|
|
|
|
|
cq_verifier_destroy(v_client); |
|
|
|
|
cq_verifier_destroy(cqv); |
|
|
|
|
end_test(&f); |
|
|
|
|
config.tear_down_data(&f); |
|
|
|
|
} |
|
|
|
|