|
|
|
@ -89,12 +89,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); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/* Request/response with metadata and payload.*/ |
|
|
|
@ -113,8 +110,7 @@ static void test_request_response_with_metadata_and_payload( |
|
|
|
|
grpc_metadata meta_s[2] = {{"key3", "val3", 4, {{NULL, NULL, NULL}}}, {"key4", "val4", 4, {{NULL, NULL, NULL}}}}; |
|
|
|
|
grpc_metadata meta_t[2] = {{"key5", "val5", 4, {{NULL, NULL, NULL}}}, {"key6", "val6", 4, {{NULL, NULL, NULL}}}}; |
|
|
|
|
grpc_end2end_test_fixture f = begin_test(config, __FUNCTION__, NULL, NULL); |
|
|
|
|
cq_verifier *v_client = cq_verifier_create(f.client_cq); |
|
|
|
|
cq_verifier *v_server = cq_verifier_create(f.server_cq); |
|
|
|
|
cq_verifier *cqv = cq_verifier_create(f.cq); |
|
|
|
|
grpc_op ops[6]; |
|
|
|
|
grpc_op *op; |
|
|
|
|
grpc_metadata_array initial_metadata_recv; |
|
|
|
@ -128,7 +124,7 @@ static void test_request_response_with_metadata_and_payload( |
|
|
|
|
size_t details_capacity = 0; |
|
|
|
|
int was_cancelled = 2; |
|
|
|
|
|
|
|
|
|
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); |
|
|
|
|
|
|
|
|
@ -164,10 +160,10 @@ static void test_request_response_with_metadata_and_payload( |
|
|
|
|
GPR_ASSERT(GRPC_CALL_OK == grpc_server_request_call(f.server, &s, |
|
|
|
|
&call_details, |
|
|
|
|
&request_metadata_recv, |
|
|
|
|
f.server_cq, f.server_cq, |
|
|
|
|
f.cq, f.cq, |
|
|
|
|
tag(101))); |
|
|
|
|
cq_expect_completion(v_server, tag(101), 1); |
|
|
|
|
cq_verify(v_server); |
|
|
|
|
cq_expect_completion(cqv, tag(101), 1); |
|
|
|
|
cq_verify(cqv); |
|
|
|
|
|
|
|
|
|
op = ops; |
|
|
|
|
op->op = GRPC_OP_SEND_INITIAL_METADATA; |
|
|
|
@ -191,11 +187,9 @@ static void test_request_response_with_metadata_and_payload( |
|
|
|
|
op++; |
|
|
|
|
GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(s, ops, op - ops, tag(102))); |
|
|
|
|
|
|
|
|
|
cq_expect_completion(v_server, tag(102), 1); |
|
|
|
|
cq_verify(v_server); |
|
|
|
|
|
|
|
|
|
cq_expect_completion(v_client, tag(1), 1); |
|
|
|
|
cq_verify(v_client); |
|
|
|
|
cq_expect_completion(cqv, tag(102), 1); |
|
|
|
|
cq_expect_completion(cqv, tag(1), 1); |
|
|
|
|
cq_verify(cqv); |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(status == GRPC_STATUS_OK); |
|
|
|
|
GPR_ASSERT(0 == strcmp(details, "xyz")); |
|
|
|
@ -219,8 +213,7 @@ static void test_request_response_with_metadata_and_payload( |
|
|
|
|
grpc_call_destroy(c); |
|
|
|
|
grpc_call_destroy(s); |
|
|
|
|
|
|
|
|
|
cq_verifier_destroy(v_client); |
|
|
|
|
cq_verifier_destroy(v_server); |
|
|
|
|
cq_verifier_destroy(cqv); |
|
|
|
|
|
|
|
|
|
grpc_byte_buffer_destroy(request_payload); |
|
|
|
|
grpc_byte_buffer_destroy(response_payload); |
|
|
|
|