Searched refs:cli_cq (Results 1 – 1 of 1) sorted by relevance
| /external/grpc-grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 1209 CompletionQueue cli_cq; in TestClientStreamingServerCancel() local
1212 stub_->AsyncRequestStream(&cli_ctx, &recv_response, &cli_cq, tag(1))); in TestClientStreamingServerCancel()
1219 std::thread t1([&cli_cq] { Verifier().Expect(1, true).Verify(&cli_cq); }); in TestClientStreamingServerCancel()
1242 std::thread cli_thread([&cli_cq, &cli_stream, &expected_client_cq_result, in TestClientStreamingServerCancel()
1251 .Verify(&cli_cq, ignore_client_cq_result); in TestClientStreamingServerCancel()
1257 .Verify(&cli_cq, ignore_client_cq_result); in TestClientStreamingServerCancel()
1328 Verifier().Expect(10, true).Verify(&cli_cq); in TestClientStreamingServerCancel()
1332 cli_cq.Shutdown(); in TestClientStreamingServerCancel()
1335 while (cli_cq.Next(&dummy_tag, &dummy_ok)) { in TestClientStreamingServerCancel()
1365 CompletionQueue cli_cq; in TestServerStreamingServerCancel() local
[all …]
|