Searched refs:GOT_EVENT (Results 1 – 12 of 12) sorted by relevance
| /third_party/grpc/test/cpp/common/ |
| D | alarm_test.cc | 45 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
63 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
82 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
167 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
182 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
197 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
215 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
233 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
249 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
265 EXPECT_EQ(status, CompletionQueue::GOT_EVENT); in TEST()
[all …]
|
| /third_party/grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 66 return GOT_EVENT; in AsyncNextInternal()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | completion_queue_impl.h | 125 GOT_EVENT, ///< Got a new event; \a tag will be filled in with its enumerator
220 return GOT_EVENT; in DoThenAsyncNext()
|
| D | completion_queue.h | 124 GOT_EVENT, ///< Got a new event; \a tag will be filled in with its enumerator
219 return GOT_EVENT; in DoThenAsyncNext()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 90 } else if (r == CompletionQueue::GOT_EVENT) { in LoopForTag()
|
| D | interceptors_util.h | 275 CompletionQueue::GOT_EVENT); in Verify()
|
| D | cfstream_test.cc | 201 if (ret == grpc::CompletionQueue::GOT_EVENT) { in CQNext()
|
| D | async_end2end_test.cc | 138 CompletionQueue::GOT_EVENT); in Verify()
160 CompletionQueue::GOT_EVENT); in Verify()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_client.cc | 114 if (r == grpc::CompletionQueue::NextStatus::GOT_EVENT) { in WorkerEntry()
|
| D | cache_grpc_server.cc | 100 if (r == grpc::CompletionQueue::NextStatus::GOT_EVENT) { in HandleRequest()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 251 case CompletionQueue::GOT_EVENT: in TrickleCQNext()
|
| /third_party/grpc/src/cpp/server/ |
| D | server_cc.cc | 795 case grpc::CompletionQueue::GOT_EVENT: in PollForWork()
|