| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call.cc | 66 void* got_tag; in CliCall() local
68 cq_.Next(&got_tag, &ok); in CliCall()
78 void* got_tag; in Write() local
85 cq_.Next(&got_tag, &ok); in Write()
91 void* got_tag; in Read() local
97 if (!cq_.Next(&got_tag, &ok) || !ok) { in Read()
115 void* got_tag; in WritesDone() local
119 cq_.Next(&got_tag, &ok); in WritesDone()
149 void* got_tag; in ReadAndMaybeNotifyWrite() local
154 bool cq_result = cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
[all …]
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 136 void* got_tag; in SendRpc() local
138 EXPECT_TRUE(LoopForTag(&got_tag, &ok)); in SendRpc()
140 EXPECT_EQ(detag(got_tag), 2); in SendRpc()
148 EXPECT_TRUE(LoopForTag(&got_tag, &ok)); in SendRpc()
150 tagsum += detag(got_tag); in SendRpc()
151 tagprod *= detag(got_tag); in SendRpc()
153 EXPECT_TRUE(LoopForTag(&got_tag, &ok)); in SendRpc()
155 tagsum += detag(got_tag); in SendRpc()
156 tagprod *= detag(got_tag); in SendRpc()
|
| D | async_end2end_test.cc | 90 void* got_tag; in Next() local
91 EXPECT_TRUE(cq->Next(&got_tag, &ok)); in Next()
92 GotTag(got_tag, ok, ignore_ok); in Next()
93 return detag(got_tag); in Next()
98 CompletionQueue* cq, void** got_tag, bool* ok, T deadline, in DoOnceThenAsyncNext() argument
101 return cq->AsyncNext(got_tag, ok, deadline); in DoOnceThenAsyncNext()
104 return cq->DoThenAsyncNext(lambda, got_tag, ok, deadline); in DoOnceThenAsyncNext()
126 void* got_tag; in Verify() local
127 EXPECT_EQ(cq->AsyncNext(&got_tag, &ok, deadline), in Verify()
132 void* got_tag; in Verify() local
[all …]
|
| D | raw_end2end_test.cc | 70 void* got_tag; in Next() local
71 EXPECT_TRUE(cq->Next(&got_tag, &ok)); in Next()
72 GotTag(got_tag, ok, ignore_ok); in Next()
73 return detag(got_tag); in Next()
86 void GotTag(void* got_tag, bool ok, bool ignore_ok) { in GotTag() argument
87 auto it = expectations_.find(got_tag); in GotTag()
|
| D | filter_end2end_test.cc | 56 void* got_tag; in verify_ok() local
57 EXPECT_TRUE(cq->Next(&got_tag, &ok)); in verify_ok()
59 EXPECT_EQ(tag(i), got_tag); in verify_ok()
|
| D | generic_end2end_test.cc | 53 void* got_tag; in verify_ok() local
54 EXPECT_TRUE(cq->Next(&got_tag, &ok)); in verify_ok()
56 EXPECT_EQ(tag(i), got_tag); in verify_ok()
|
| D | thread_stress_test.cc | 376 void* got_tag; in AsyncCompleteRpc() local
378 if (!cq_.Next(&got_tag, &ok)) break; in AsyncCompleteRpc()
379 AsyncClientCall* call = static_cast<AsyncClientCall*>(got_tag); in AsyncCompleteRpc()
|
| D | hybrid_end2end_test.cc | 48 void* got_tag; in VerifyReturnSuccess() local
50 EXPECT_TRUE(cq->Next(&got_tag, &ok)); in VerifyReturnSuccess()
51 EXPECT_EQ(tag(i), got_tag); in VerifyReturnSuccess()
|
| /external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/ |
| D | ViewController.mm | 48 void* got_tag;
54 cq_.Next(&got_tag, &ok);
55 if (!ok || got_tag != tag(1)) {
62 cq_.Next(&got_tag, &ok);
63 if (!ok || got_tag != tag(2)) {
69 cq_.Next(&got_tag, &ok);
70 if (!ok || got_tag != tag(3)) {
77 cq_.Next(&got_tag, &ok);
78 if (!ok || got_tag != tag(4)) {
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_client.cc | 77 void* got_tag; in SayHello() local
82 GPR_ASSERT(cq.Next(&got_tag, &ok)); in SayHello()
86 GPR_ASSERT(got_tag == (void*)1); in SayHello()
|
| D | greeter_async_client2.cc | 72 void* got_tag; in AsyncCompleteRpc() local
76 while (cq_.Next(&got_tag, &ok)) { in AsyncCompleteRpc()
78 AsyncClientCall* call = static_cast<AsyncClientCall*>(got_tag); in AsyncCompleteRpc()
|
| D | README.md | 189 void* got_tag;
191 cq.Next(&got_tag, &ok);
192 if (ok && got_tag == (void*)1) {
230 void* got_tag;
232 cq.Next(&got_tag, &ok);
233 if (ok && got_tag == (void*)1) {
243 void* got_tag;
245 cq.Next(&got_tag, &ok);
246 if (ok && got_tag == (void*)2) {
|
| /external/tensorflow/tensorflow/core/profiler/rpc/client/ |
| D | profiler_client.cc | 133 void* got_tag = nullptr; in WaitForCompletion() local
138 bool success = cq_.Next(&got_tag, &ok); in WaitForCompletion()
139 if (!success || !ok || got_tag == nullptr) { in WaitForCompletion()
148 DCHECK_EQ(got_tag, &status_on_completion_); in WaitForCompletion()
|
| /external/rust/crates/quiche/deps/boringssl/src/crypto/fipsmodule/modes/ |
| D | gcm_test.cc | 97 std::vector<uint8_t> got_tag(tag.size()); in TEST() local
98 CRYPTO_gcm128_tag(&ctx, got_tag.data(), got_tag.size()); in TEST()
99 EXPECT_EQ(Bytes(tag), Bytes(got_tag)); in TEST()
|
| /external/boringssl/src/crypto/fipsmodule/modes/ |
| D | gcm_test.cc | 97 std::vector<uint8_t> got_tag(tag.size()); in TEST() local
98 CRYPTO_gcm128_tag(&ctx, got_tag.data(), got_tag.size()); in TEST()
99 EXPECT_EQ(Bytes(tag), Bytes(got_tag)); in TEST()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 175 void* got_tag; in ~AsyncQpsServerTest() local
176 while ((*cq)->Next(&got_tag, &ok)) in ~AsyncQpsServerTest()
205 void* got_tag; in ThreadFunc() local
206 if (!srv_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) { in ThreadFunc()
212 ctx = detag(got_tag); in ThreadFunc()
230 &got_tag, &ok, gpr_inf_future(GPR_CLOCK_REALTIME))); in ThreadFunc()
|
| D | client_async.cc | 196 void* got_tag; in ~AsyncClient() local
198 while ((*cq)->Next(&got_tag, &ok)) { in ~AsyncClient()
199 delete ClientRpcContext::detag(got_tag); in ~AsyncClient()
258 void* got_tag; in ThreadFunc() local
263 if (!cli_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) { in ThreadFunc()
268 ClientRpcContext* ctx = ProcessTag(thread_idx, got_tag); in ThreadFunc()
283 &got_tag, &ok, gpr_inf_future(GPR_CLOCK_REALTIME))) { in ThreadFunc()
287 ctx = ProcessTag(thread_idx, got_tag); in ThreadFunc()
|
| /external/grpc-grpc/test/cpp/cocoapods/generic/ |
| D | generic.mm | 104 void* got_tag;
105 XCTAssertTrue(cq->Next(&got_tag, &ok));
107 XCTAssertEqual(tag(i), got_tag);
|