Home
last modified time | relevance | path

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

/external/grpc-grpc/test/core/iomgr/
Dresource_quota_test.cc159 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_simple_async_alloc()
182 GPR_ASSERT(gpr_event_wait( in test_async_alloc_blocked_by_size()
186 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_async_alloc_blocked_by_size()
209 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_scavenge()
223 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_scavenge()
248 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_scavenge_blocked()
257 GPR_ASSERT(gpr_event_wait( in test_scavenge_blocked()
264 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_scavenge_blocked()
289 GPR_ASSERT(gpr_event_wait(&ev, grpc_timeout_seconds_to_deadline(5)) != in test_blocked_until_scheduled_reclaim()
306 GPR_ASSERT(gpr_event_wait(&reclaim_done, in test_blocked_until_scheduled_reclaim()
[all …]
Dcombiner_test.cc50 GPR_ASSERT(gpr_event_wait(&done, grpc_timeout_seconds_to_deadline(5)) != in test_execute_one()
110 GPR_ASSERT(gpr_event_wait(&ta[i].done, in test_execute_many()
141 GPR_ASSERT(gpr_event_wait(&got_in_finally, in test_execute_finally()
Dresolve_address_posix_test.cc62 GPR_ASSERT(gpr_event_wait(&args->ev, test_deadline())); in args_finish()
Dresolve_address_test.cc61 GPR_ASSERT(gpr_event_wait(&args->ev, test_deadline())); in args_finish()
/external/grpc-grpc/test/core/client_channel/resolvers/
Dfake_resolver_test.cc137 GPR_ASSERT(gpr_event_wait(&on_res_arg.ev, in test_fake_resolver()
150 GPR_ASSERT(gpr_event_wait(&on_res_arg.ev, in test_fake_resolver()
168 GPR_ASSERT(gpr_event_wait(&on_res_arg.ev, in test_fake_resolver()
180 GPR_ASSERT(gpr_event_wait(&on_res_arg.ev, in test_fake_resolver()
193 GPR_ASSERT(gpr_event_wait(&on_res_arg.ev, in test_fake_resolver()
203 GPR_ASSERT(gpr_event_wait(&on_res_arg.ev, in test_fake_resolver()
Ddns_resolver_connectivity_test.cc108 if (gpr_event_wait(ev, grpc_timeout_seconds_to_deadline(1))) return true; in wait_loop()
Ddns_resolver_cooldown_test.cc128 GPR_ASSERT(gpr_event_wait(&args->ev, test_deadline())); in iomgr_args_finish()
/external/grpc-grpc/test/core/surface/
Dcompletion_queue_threading_test.cc149 GPR_ASSERT(gpr_event_wait(opt->phase1, ten_seconds_time())); in producer_thread()
158 GPR_ASSERT(gpr_event_wait(opt->phase2, ten_seconds_time())); in producer_thread()
180 GPR_ASSERT(gpr_event_wait(opt->phase1, ten_seconds_time())); in consumer_thread()
186 GPR_ASSERT(gpr_event_wait(opt->phase2, ten_seconds_time())); in consumer_thread()
240 gpr_event_wait(&options[i].on_started, ten_seconds_time()); in test_threading()
250 GPR_ASSERT(gpr_event_wait(&options[i].on_phase1_done, ten_seconds_time())); in test_threading()
265 GPR_ASSERT(gpr_event_wait(&options[i].on_finished, ten_seconds_time())); in test_threading()
Dconcurrent_connectivity_test.cc226 gpr_event_wait(&args.ready, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in run_concurrent_connectivity_test()
Dpublic_headers_must_be_c89.c282 printf("%lx", (unsigned long) gpr_event_wait); in main()
/external/grpc-grpc/test/core/gpr/
Dmpscq_test.cc70 gpr_event_wait(a->start, gpr_inf_future(GPR_CLOCK_REALTIME)); in test_thread()
124 gpr_event_wait(pa->start, gpr_inf_future(GPR_CLOCK_REALTIME)); in pull_thread()
Darena_test.cc88 gpr_event_wait(&a->ev_start, gpr_inf_future(GPR_CLOCK_REALTIME)); in concurrent_test_body()
Dsync_test.cc357 GPR_ASSERT(gpr_event_wait(&m->event, deadline) == nullptr); in inc_with_1ms_delay_event()
446 GPR_ASSERT(gpr_event_wait(&m->event, gpr_inf_future(GPR_CLOCK_REALTIME)) == in refcheck()
/external/grpc-grpc/test/core/bad_client/
Dbad_client.cc125 gpr_event_wait(&done_write, grpc_timeout_seconds_to_deadline(5))); in grpc_run_client_side_validator()
234 GPR_ASSERT(gpr_event_wait(&a.done_thd, grpc_timeout_seconds_to_deadline(1))); in grpc_run_bad_client_test()
/external/grpc-grpc/src/core/lib/gpr/
Dsync.cc73 void* gpr_event_wait(gpr_event* ev, gpr_timespec abs_deadline) { in gpr_event_wait() function
/external/grpc-grpc/
Dgrpc.def224 gpr_event_wait
/external/grpc-grpc/test/cpp/end2end/
Dshutdown_test.cc150 gpr_event_wait(&ev_, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in TEST_P()
Dend2end_test.cc1108 gpr_event_wait(&ev, gpr_inf_future(GPR_CLOCK_REALTIME)); in TEST_P()
/external/grpc-grpc/test/core/end2end/tests/
Dconnectivity.cc71 gpr_event_wait(&ce.started, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in test_connectivity()
/external/grpc-grpc/include/grpc/support/
Dsync.h131 GPRAPI void* gpr_event_wait(gpr_event* ev, gpr_timespec abs_deadline);
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc200 gpr_event_wait(&done_, gpr_inf_future(GPR_CLOCK_REALTIME)); in ~Stream()
450 gpr_event_wait(bm_done, gpr_inf_future(GPR_CLOCK_REALTIME)); in BM_TransportStreamSend()
/external/grpc-grpc/test/core/end2end/
Dbad_server_response_test.cc290 gpr_event_wait(&ev, gpr_inf_future(GPR_CLOCK_REALTIME)); in run_test()
/external/grpc-grpc/test/cpp/naming/
Dresolver_component_test.cc182 GPR_ASSERT(gpr_event_wait(&args->ev, TestDeadline())); in ArgsFinish()
/external/grpc-grpc/test/cpp/qps/
Dclient.h355 while (!gpr_event_wait( in ThreadFunc()
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_grpc_imports.generated.h712 #define gpr_event_wait gpr_event_wait_import macro