Home
last modified time | relevance | path

Searched refs:GRPC_OP_COMPLETE (Results 1 – 25 of 106) sorted by relevance

12345

/third_party/grpc/test/core/end2end/fuzzers/
Dserver_fuzzer.cc86 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()
Dclient_fuzzer.cc128 case GRPC_OP_COMPLETE: in LLVMFuzzerTestOneInput()
141 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in LLVMFuzzerTestOneInput()
/third_party/grpc/test/core/bad_ssl/
Dserver_common.cc77 .type == GRPC_OP_COMPLETE); in bad_ssl_run()
88 case GRPC_OP_COMPLETE: in bad_ssl_run()
/third_party/grpc/test/core/bad_connection/
Dclose_fd_test.cc155 .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/
Dcq_verifier.cc190 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/
Dconcurrent_connectivity_test.cc88 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()
Dnum_external_connectivity_watchers_test.cc60 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()
Dsequential_connectivity_test.cc58 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/
Dstranded_event_test.cc173 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/
Devent_string.cc54 case GRPC_OP_COMPLETE: in grpc_event_string()
/third_party/grpc/test/core/handshake/
Dverify_peer_options.cc103 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/
Dcompletion_queue_cc.cc60 case GRPC_OP_COMPLETE: in AsyncNextInternal()
/third_party/grpc/test/core/fling/
Dserver.cc242 .type == GRPC_OP_COMPLETE); in main()
255 case GRPC_OP_COMPLETE: in main()
/third_party/grpc/src/core/tsi/alts/handshaker/
Dalts_shared_resource.cc42 GPR_ASSERT(event.type == GRPC_OP_COMPLETE); in thread_worker()
/third_party/grpc/test/core/end2end/tests/
Dno_op.cc65 .type == GRPC_OP_COMPLETE); in shutdown_server()
Dcancel_in_a_vacuum.cc70 .type == GRPC_OP_COMPLETE); in shutdown_server()
Dempty_batch.cc67 .type == GRPC_OP_COMPLETE); in shutdown_server()
Dresource_quota_server.cc66 .type == GRPC_OP_COMPLETE); in shutdown_server()
239 GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); in resource_quota_server()
Dnegative_deadline.cc68 .type == GRPC_OP_COMPLETE); in shutdown_server()
Dbad_hostname.cc67 .type == GRPC_OP_COMPLETE); in shutdown_server()
Dcancel_before_invoke.cc68 .type == GRPC_OP_COMPLETE); in shutdown_server()
Dauthority_not_supported.cc65 .type == GRPC_OP_COMPLETE); in shutdown_server()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_cq_multiple_threads.cc182 GRPC_OP_COMPLETE); in BM_Cq_Throughput()
/third_party/grpc/test/core/tsi/alts/handshaker/
Dalts_concurrent_connectivity_test.cc180 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/
DGRPCCompletionQueue.m65 case GRPC_OP_COMPLETE:

12345