Searched refs:AsyncNext (Results 1 – 12 of 12) sorted by relevance
| /third_party/grpc/test/cpp/common/ |
| D | alarm_test.cc | 43 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
61 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
80 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
162 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
180 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
196 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
213 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
231 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(10)); in TEST()
247 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
263 cq.AsyncNext(&output_tag, &ok, grpc_timeout_seconds_to_deadline(1)); in TEST()
[all …]
|
| /third_party/grpc/test/cpp/codegen/ |
| D | codegen_test_full.cc | 32 cq.AsyncNext(&tag, &ok, gpr_time_0(GPR_CLOCK_REALTIME)); in TEST_F()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | completion_queue_impl.h | 196 NextStatus AsyncNext(void** tag, bool* ok, const T& deadline) { in AsyncNext() function
222 return AsyncNext(tag, ok, deadline); in DoThenAsyncNext()
|
| D | completion_queue.h | 195 NextStatus AsyncNext(void** tag, bool* ok, const T& deadline) { in AsyncNext() function
221 return AsyncNext(tag, ok, deadline); in DoThenAsyncNext()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 86 auto r = cq_->AsyncNext(tag, ok, gpr_time_0(GPR_CLOCK_REALTIME)); in LoopForTag()
|
| D | interceptors_util.h | 239 return cq->AsyncNext(got_tag, ok, deadline); in DoOnceThenAsyncNext()
|
| D | cfstream_test.cc | 200 auto ret = cq_.AsyncNext(tag, ok, deadline); in CQNext()
|
| D | async_end2end_test.cc | 105 return cq->AsyncNext(got_tag, ok, deadline); in DoOnceThenAsyncNext()
131 EXPECT_EQ(cq->AsyncNext(&got_tag, &ok, deadline), in Verify()
137 EXPECT_EQ(cq->AsyncNext(&got_tag, &ok, deadline), in Verify()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_client.cc | 113 auto r = cq_.AsyncNext(&tag, &success, deadline); in WorkerEntry()
|
| D | cache_grpc_server.cc | 99 auto r = cq_->AsyncNext(&tag, &success, deadline); in HandleRequest()
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 790 switch (server_cq_->AsyncNext(tag, ok, deadline)) { in PollForWork()
1253 shutdown_cq.AsyncNext(&tag, &ok, deadline); in ShutdownInternal()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 244 fixture->cq()->AsyncNext(t, ok, gpr_inf_past(GPR_CLOCK_MONOTONIC))) { in TrickleCQNext()
|