Home
last modified time | relevance | path

Searched refs:GRPC_QUEUE_TIMEOUT (Results 1 – 25 of 35) sorted by relevance

12

/external/grpc-grpc/src/ruby/ext/grpc/
Drb_completion_queue.c49 if (next_call->event.type != GRPC_QUEUE_TIMEOUT || in grpc_rb_completion_queue_pluck_no_gil()
81 next_call.event.type = GRPC_QUEUE_TIMEOUT; in rb_completion_queue_pluck()
98 } while (next_call.interrupted && next_call.event.type == GRPC_QUEUE_TIMEOUT); in rb_completion_queue_pluck()
/external/grpc-grpc/test/core/end2end/
Dcq_verifier.cc195 case GRPC_QUEUE_TIMEOUT: in expectation_to_strvec()
244 case GRPC_QUEUE_TIMEOUT: in verify_matches()
255 if (ev.type == GRPC_QUEUE_TIMEOUT) { in cq_verify()
297 if (ev.type != GRPC_QUEUE_TIMEOUT) { in cq_verify_empty_timeout()
Dcq_verifier_uv.cc89 ev.type == GRPC_QUEUE_TIMEOUT) { in cq_verifier_next_event()
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dcompletion_queue.pyx.pxi39 if (c_event.type != GRPC_QUEUE_TIMEOUT or
51 if c_event.type == GRPC_QUEUE_TIMEOUT:
53 return None, ConnectivityEvent(GRPC_QUEUE_TIMEOUT, False, None)
/external/grpc-grpc/test/core/bad_client/tests/
Dunknown_frame.cc31 .type == GRPC_QUEUE_TIMEOUT); in verifier()
Dbadreq.cc37 .type == GRPC_QUEUE_TIMEOUT); in verifier()
Dconnection_prefix.cc27 .type == GRPC_QUEUE_TIMEOUT); in verifier()
Dwindow_overflow.cc50 .type == GRPC_QUEUE_TIMEOUT); in verifier()
Dsimple_request.cc121 .type == GRPC_QUEUE_TIMEOUT); in failure_verifier()
Dserver_registered_method.cc74 .type == GRPC_QUEUE_TIMEOUT); in verifier_fails()
Dinitial_settings_frame.cc30 .type == GRPC_QUEUE_TIMEOUT); in verifier()
Dheaders.cc31 .type == GRPC_QUEUE_TIMEOUT); in verifier()
/external/grpc-grpc/src/core/lib/surface/
Devent_string.cc52 case GRPC_QUEUE_TIMEOUT: in grpc_event_string()
Dcompletion_queue.cc371 (event)->type != GRPC_QUEUE_TIMEOUT)) { \
1024 ret.type = GRPC_QUEUE_TIMEOUT;
1042 ret.type = GRPC_QUEUE_TIMEOUT;
1260 ret.type = GRPC_QUEUE_TIMEOUT;
1269 ret.type = GRPC_QUEUE_TIMEOUT;
1284 ret.type = GRPC_QUEUE_TIMEOUT;
/external/grpc-grpc/src/cpp/common/
Dcompletion_queue_cc.cc58 case GRPC_QUEUE_TIMEOUT: in AsyncNextInternal()
/external/grpc-grpc/test/core/surface/
Dcompletion_queue_test.cc126 GPR_ASSERT(event.type == GRPC_QUEUE_TIMEOUT); in test_wait_empty()
194 GPR_ASSERT(ev.type == GRPC_QUEUE_TIMEOUT); in test_cq_tls_cache_full()
203 GPR_ASSERT(ev.type == GRPC_QUEUE_TIMEOUT); in test_cq_tls_cache_full()
Dcompletion_queue_threading_test.cc107 GPR_ASSERT(ev.type == GRPC_QUEUE_TIMEOUT); in test_too_many_plucks()
201 case GRPC_QUEUE_TIMEOUT: in consumer_thread()
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dcompletion_queue.h324 if (ev.type == GRPC_QUEUE_TIMEOUT) return; in TryPluck()
339 if (ev.type == GRPC_QUEUE_TIMEOUT || ev.type == GRPC_QUEUE_SHUTDOWN) { in TryPluck()
/external/grpc-grpc/test/core/bad_ssl/
Dserver_common.cc96 case GRPC_QUEUE_TIMEOUT: in bad_ssl_run()
/external/grpc-grpc/test/core/bad_client/
Dbad_client.cc155 .type == GRPC_QUEUE_TIMEOUT); in grpc_run_client_side_validator()
178 .type == GRPC_QUEUE_TIMEOUT); in grpc_run_client_side_validator()
/external/grpc-grpc/test/core/end2end/fuzzers/
Dserver_fuzzer.cc86 case GRPC_QUEUE_TIMEOUT: in LLVMFuzzerTestOneInput()
Dclient_fuzzer.cc127 case GRPC_QUEUE_TIMEOUT: in LLVMFuzzerTestOneInput()
/external/grpc-grpc/include/grpc/impl/codegen/
Dgrpc_types.h453 GRPC_QUEUE_TIMEOUT, enumerator
/external/grpc-grpc/test/core/handshake/
Dserver_ssl_common.cc109 GPR_ASSERT(ev.type == GRPC_QUEUE_TIMEOUT); in server_thread()
Dverify_peer_options.cc91 GPR_ASSERT(ev.type == GRPC_QUEUE_TIMEOUT); in server_thread()

12