/third_party/grpc/test/core/end2end/fuzzers/ |
D | server_fuzzer.cc | 86 case GRPC_OP_COMPLETE: in LLVMFuzzerTestOneInput() 117 } while (ev.type != GRPC_OP_COMPLETE && in LLVMFuzzerTestOneInput() 119 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in LLVMFuzzerTestOneInput()
|
D | client_fuzzer.cc | 128 case GRPC_OP_COMPLETE: in LLVMFuzzerTestOneInput() 141 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in LLVMFuzzerTestOneInput()
|
/third_party/grpc/test/core/bad_ssl/ |
D | server_common.cc | 77 .type == GRPC_OP_COMPLETE); in bad_ssl_run() 88 case GRPC_OP_COMPLETE: in bad_ssl_run()
|
/third_party/grpc/test/core/bad_connection/ |
D | close_fd_test.cc | 155 .type == GRPC_OP_COMPLETE); in shutdown_server() 275 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_server_recv() 314 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_server_recv() 333 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_server_recv() 450 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_server_send() 470 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_server_send() 514 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_server_send() 525 if (event.type == GRPC_OP_COMPLETE) { in _test_close_before_server_send() 655 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in _test_close_before_client_send()
|
/third_party/grpc/test/core/end2end/ |
D | cq_verifier.cc | 190 case GRPC_OP_COMPLETE: in ExpectationString() 222 case GRPC_OP_COMPLETE: in verify_matches() 304 add(v, file, line, GRPC_OP_COMPLETE, tag, true, success); in cq_expect_completion() 309 add(v, file, line, GRPC_OP_COMPLETE, tag, false, false); in cq_expect_completion_any_status()
|
/third_party/grpc/test/core/surface/ |
D | concurrent_connectivity_test.cc | 88 GRPC_OP_COMPLETE); in create_loop_destroy() 115 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in server_thread() 279 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in watches_with_short_timeouts()
|
D | num_external_connectivity_watchers_test.cc | 60 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in channel_idle_poll_for_timeout() 144 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in run_channel_shutdown_before_timeout_test()
|
D | sequential_connectivity_test.cc | 58 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in server_thread_func() 120 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in run_test()
|
/third_party/grpc/test/core/iomgr/ |
D | stranded_event_test.cc | 173 if (event.type != GRPC_OP_COMPLETE || !event.success) { in ReceiveInitialMetadata() 205 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in FinishCall() 253 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in AcceptThread() 269 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in AcceptThread()
|
/third_party/grpc/src/core/lib/surface/ |
D | event_string.cc | 54 case GRPC_OP_COMPLETE: in grpc_event_string()
|
/third_party/grpc/test/core/handshake/ |
D | verify_peer_options.cc | 103 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in server_thread() 184 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in verify_peer_options_test()
|
/third_party/grpc/src/cpp/common/ |
D | completion_queue_cc.cc | 60 case GRPC_OP_COMPLETE: in AsyncNextInternal()
|
/third_party/grpc/test/core/fling/ |
D | server.cc | 242 .type == GRPC_OP_COMPLETE); in main() 255 case GRPC_OP_COMPLETE: in main()
|
/third_party/grpc/src/core/tsi/alts/handshaker/ |
D | alts_shared_resource.cc | 42 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in thread_worker()
|
/third_party/grpc/test/core/end2end/tests/ |
D | no_op.cc | 65 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
D | cancel_in_a_vacuum.cc | 70 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
D | empty_batch.cc | 67 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
D | resource_quota_server.cc | 66 .type == GRPC_OP_COMPLETE); in shutdown_server() 239 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in resource_quota_server()
|
D | negative_deadline.cc | 68 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
D | bad_hostname.cc | 67 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
D | cancel_before_invoke.cc | 68 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
D | authority_not_supported.cc | 65 .type == GRPC_OP_COMPLETE); in shutdown_server()
|
/third_party/grpc/test/cpp/microbenchmarks/ |
D | bm_cq_multiple_threads.cc | 182 GRPC_OP_COMPLETE); in BM_Cq_Throughput()
|
/third_party/grpc/test/core/tsi/alts/handshaker/ |
D | alts_concurrent_connectivity_test.cc | 180 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in PollUntilShutdown() 245 ASSERT_EQ(ev.type, GRPC_OP_COMPLETE) in ConnectLoop()
|
/third_party/grpc/src/objective-c/GRPCClient/private/GRPCCore/ |
D | GRPCCompletionQueue.m | 65 case GRPC_OP_COMPLETE:
|