Home
last modified time | relevance | path

Searched refs:GRPC_QUEUE_SHUTDOWN (Results 1 – 25 of 118) sorted by relevance

12345

/third_party/grpc/test/core/end2end/fuzzers/
Dserver_fuzzer.cc84 case GRPC_QUEUE_SHUTDOWN: in LLVMFuzzerTestOneInput()
127 } while (ev.type != GRPC_QUEUE_SHUTDOWN && in LLVMFuzzerTestOneInput()
129 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in LLVMFuzzerTestOneInput()
Dclient_fuzzer.cc126 case GRPC_QUEUE_SHUTDOWN: in LLVMFuzzerTestOneInput()
147 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in LLVMFuzzerTestOneInput()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dcompletion_queue.pyx.pxi51 elif c_event.type == GRPC_QUEUE_SHUTDOWN:
53 return None, ConnectivityEvent(GRPC_QUEUE_SHUTDOWN, False, None)
85 if event.completion_type == GRPC_QUEUE_SHUTDOWN:
102 while self.poll().type != GRPC_QUEUE_SHUTDOWN:
/third_party/grpc/test/core/surface/
Dcompletion_queue_test.cc46 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in shutdown_and_destroy()
52 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in shutdown_and_destroy()
255 GPR_ASSERT(event.type == GRPC_QUEUE_SHUTDOWN); in test_shutdown_then_next_polling()
278 GPR_ASSERT(event.type == GRPC_QUEUE_SHUTDOWN); in test_shutdown_then_next_with_timeout()
357 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in test_pluck_after_shutdown()
Dnum_external_connectivity_watchers_test.cc111 .type == GRPC_QUEUE_SHUTDOWN); in run_timeouts_test()
151 .type == GRPC_QUEUE_SHUTDOWN); in run_channel_shutdown_before_timeout_test()
Dsequential_connectivity_test.cc134 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
138 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
Dcompletion_queue_threading_test.cc59 GPR_ASSERT(ev.type == GRPC_QUEUE_SHUTDOWN); in shutdown_and_destroy()
198 case GRPC_QUEUE_SHUTDOWN: in consumer_thread()
/third_party/grpc/src/objective-c/GRPCClient/private/GRPCCore/
DGRPCCompletionQueue.m69 case GRPC_QUEUE_SHUTDOWN:
83 // This makes the completion queue produce a GRPC_QUEUE_SHUTDOWN event *after*
/third_party/grpc/src/core/lib/surface/
Devent_string.cc51 case GRPC_QUEUE_SHUTDOWN: in grpc_event_string()
/third_party/grpc/src/cpp/common/
Dcompletion_queue_cc.cc58 case GRPC_QUEUE_SHUTDOWN: in AsyncNextInternal()
/third_party/grpc/src/core/tsi/alts/handshaker/
Dalts_shared_resource.cc39 if (event.type == GRPC_QUEUE_SHUTDOWN) { in thread_worker()
/third_party/grpc/test/core/bad_ssl/
Dserver_common.cc92 case GRPC_QUEUE_SHUTDOWN: in bad_ssl_run()
/third_party/grpc/test/core/end2end/tests/
Dno_op.cc56 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dshutdown_finishes_tags.cc56 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dcancel_in_a_vacuum.cc61 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dempty_batch.cc58 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dbad_hostname.cc58 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dnegative_deadline.cc59 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dcancel_with_status.cc62 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
Dauthority_not_supported.cc56 } while (ev.type != GRPC_QUEUE_SHUTDOWN); in drain_cq()
/third_party/grpc/test/core/end2end/
Dcq_verifier.cc195 case GRPC_QUEUE_SHUTDOWN: in ExpectationString()
229 case GRPC_QUEUE_SHUTDOWN: in verify_matches()
Dno_server_test.cc100 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
Dconnection_refused_test.cc122 .type != GRPC_QUEUE_SHUTDOWN) in run_test()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_cq_multiple_threads.cc131 GRPC_QUEUE_SHUTDOWN) { in teardown()
/third_party/grpc/test/core/transport/chttp2/
Dtoo_many_pings_test.cc172 .type != GRPC_QUEUE_SHUTDOWN) in TEST()

12345