|
|
|
@ -181,7 +181,7 @@ static void simple_request_body(grpc_end2end_test_fixture f) { |
|
|
|
|
grpc_server_request_call(f.server, &s, &call_details, |
|
|
|
|
&request_metadata_recv, f.cq, f.cq, tag(101)); |
|
|
|
|
GPR_ASSERT(GRPC_CALL_OK == error); |
|
|
|
|
cq_expect_completion(cqv, tag(101), 1); |
|
|
|
|
CQ_EXPECT_COMPLETION(cqv, tag(101), 1); |
|
|
|
|
cq_verify(cqv); |
|
|
|
|
|
|
|
|
|
peer = grpc_call_get_peer(s); |
|
|
|
@ -213,8 +213,8 @@ static void simple_request_body(grpc_end2end_test_fixture f) { |
|
|
|
|
error = grpc_call_start_batch(s, ops, (size_t)(op - ops), tag(102), NULL); |
|
|
|
|
GPR_ASSERT(GRPC_CALL_OK == error); |
|
|
|
|
|
|
|
|
|
cq_expect_completion(cqv, tag(102), 1); |
|
|
|
|
cq_expect_completion(cqv, tag(1), 1); |
|
|
|
|
CQ_EXPECT_COMPLETION(cqv, tag(102), 1); |
|
|
|
|
CQ_EXPECT_COMPLETION(cqv, tag(1), 1); |
|
|
|
|
cq_verify(cqv); |
|
|
|
|
|
|
|
|
|
GPR_ASSERT(status == GRPC_STATUS_UNIMPLEMENTED); |
|
|
|
|