Searched refs:AsyncNext (Results 1 – 7 of 7) sorted by relevance
| /external/grpc-grpc/test/cpp/common/ |
| D | alarm_test.cc | 43 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
124 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
142 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
158 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
175 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
193 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
209 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
225 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
242 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
280 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | codegen_test_full.cc | 32 cq.AsyncNext(&tag, &ok, gpr_time_0(GPR_CLOCK_REALTIME)); in TEST_F()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | completion_queue.h | 188 NextStatus AsyncNext(void** tag, bool* ok, const T& deadline) { in AsyncNext() function
213 return AsyncNext(tag, ok, deadline); in DoThenAsyncNext()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 78 auto r = cq_->AsyncNext(tag, ok, gpr_time_0(GPR_CLOCK_REALTIME)); in LoopForTag()
|
| D | async_end2end_test.cc | 101 return cq->AsyncNext(got_tag, ok, deadline); in DoOnceThenAsyncNext()
127 EXPECT_EQ(cq->AsyncNext(&got_tag, &ok, deadline), in Verify()
133 EXPECT_EQ(cq->AsyncNext(&got_tag, &ok, deadline), in Verify()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 298 switch (server_cq_->AsyncNext(tag, ok, deadline)) { in PollForWork()
615 shutdown_cq.AsyncNext(&tag, &ok, deadline); in ShutdownInternal()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 246 fixture->cq()->AsyncNext(t, ok, gpr_inf_past(GPR_CLOCK_MONOTONIC))) { in TrickleCQNext()
|