| /external/grpc-grpc/test/core/iomgr/ |
| D | resource_quota_test.cc | 48 gpr_event_set(static_cast<gpr_event*>(a), (void*)1); in set_event_cb()
50 grpc_closure* set_event(gpr_event* ev) { in set_event()
154 gpr_event ev; in test_simple_async_alloc()
176 gpr_event ev; in test_async_alloc_blocked_by_size()
204 gpr_event ev; in test_scavenge()
218 gpr_event ev; in test_scavenge()
242 gpr_event ev; in test_scavenge_blocked()
284 gpr_event ev; in test_blocked_until_scheduled_reclaim()
293 gpr_event reclaim_done; in test_blocked_until_scheduled_reclaim()
301 gpr_event ev; in test_blocked_until_scheduled_reclaim()
[all …]
|
| D | combiner_test.cc | 36 gpr_event_set(static_cast<gpr_event*>(value), (void*)1); in set_event_to_true()
43 gpr_event done; in test_execute_one()
58 gpr_event done;
118 static gpr_event got_in_finally;
|
| D | resolve_address_posix_test.cc | 42 gpr_event ev;
|
| D | resolve_address_test.cc | 40 gpr_event ev;
|
| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync.cc | 50 static struct sync_array_s* hash(gpr_event* ev) { in hash()
54 void gpr_event_init(gpr_event* ev) { in gpr_event_init()
59 void gpr_event_set(gpr_event* ev, void* value) { in gpr_event_set()
69 void* gpr_event_get(gpr_event* ev) { in gpr_event_get()
73 void* gpr_event_wait(gpr_event* ev, gpr_timespec abs_deadline) { in gpr_event_wait()
|
| /external/grpc-grpc/test/core/surface/ |
| D | completion_queue_threading_test.cc | 125 gpr_event on_started;
126 gpr_event* phase1;
127 gpr_event on_phase1_done;
128 gpr_event* phase2;
129 gpr_event on_finished;
211 gpr_event phase1 = GPR_EVENT_INIT; in test_threading()
212 gpr_event phase2 = GPR_EVENT_INIT; in test_threading()
|
| D | concurrent_connectivity_test.cc | 92 gpr_event ready;
|
| /external/grpc-grpc/test/core/bad_client/ |
| D | bad_client.cc | 47 gpr_event done_thd;
61 gpr_event* done_write = static_cast<gpr_event*>(arg); in set_done_write()
74 gpr_event* read_done = static_cast<gpr_event*>(arg); in set_read_done()
94 gpr_event done_write; in grpc_run_client_side_validator()
141 gpr_event read_done_event; in grpc_run_client_side_validator()
|
| /external/grpc-grpc/include/grpc/support/ |
| D | sync.h | 112 GPRAPI void gpr_event_init(gpr_event* ev);
117 GPRAPI void gpr_event_set(gpr_event* ev, void* value);
124 GPRAPI void* gpr_event_get(gpr_event* ev);
131 GPRAPI void* gpr_event_wait(gpr_event* ev, gpr_timespec abs_deadline);
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | dns_resolver_connectivity_test.cc | 101 gpr_event_set(static_cast<gpr_event*>(ev), (void*)1); in on_done()
105 static bool wait_loop(int deadline_seconds, gpr_event* ev) { in wait_loop()
157 gpr_event ev1; in main()
167 gpr_event ev2; in main()
|
| D | fake_resolver_test.cc | 56 gpr_event ev;
|
| D | dns_resolver_cooldown_test.cc | 51 gpr_event ev;
|
| /external/grpc-grpc/test/core/gpr/ |
| D | mpscq_test.cc | 63 gpr_event* start;
78 gpr_event start; in test_mt()
119 gpr_event* start;
147 gpr_event start; in test_mt_multipop()
|
| D | arena_test.cc | 82 gpr_event ev_start;
|
| D | sync_test.cc | 159 gpr_event event;
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | shutdown_test.cc | 47 explicit TestServiceImpl(gpr_event* ev) : ev_(ev) {} in TestServiceImpl()
58 gpr_event* ev_;
115 gpr_event ev_;
|
| /external/grpc-grpc/test/core/end2end/ |
| D | bad_server_response_test.cc | 236 gpr_event* signal_when_done;
258 test_tcp_server* server, gpr_event* signal_when_done) { in poll_server_until_read_done()
276 gpr_event ev; in run_test()
|
| /external/grpc-grpc/test/cpp/naming/ |
| D | resolver_component_test.cc | 156 gpr_event ev;
254 void OpenAndCloseSocketsStressLoop(int dummy_port, gpr_event* done_ev) { in OpenAndCloseSocketsStressLoop()
309 void OpenAndCloseSocketsStressLoop(int dummy_port, gpr_event* done_ev) { in OpenAndCloseSocketsStressLoop()
465 gpr_event done_ev; in TEST()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | sync_generic.h | 30 } gpr_event; typedef
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 252 gpr_event done_;
387 std::vector<std::unique_ptr<gpr_event>> done_events;
420 gpr_event* bm_done = new gpr_event; in BM_TransportStreamSend()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | connectivity.cc | 31 gpr_event started;
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_grpc_imports.generated.h | 701 typedef void(*gpr_event_init_type)(gpr_event* ev);
704 typedef void(*gpr_event_set_type)(gpr_event* ev, void* value);
707 typedef void*(*gpr_event_get_type)(gpr_event* ev);
710 typedef void*(*gpr_event_wait_type)(gpr_event* ev, gpr_timespec abs_deadline);
|
| /external/grpc-grpc/test/core/handshake/ |
| D | server_ssl_common.cc | 45 static gpr_event client_handshake_complete;
|
| D | verify_peer_options.cc | 48 static gpr_event client_handshake_complete;
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client.h | 397 gpr_event start_requests_;
|