| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | tag.pxd.pxi | 18 cdef object event(self, grpc_event c_event)
25 cdef ConnectivityEvent event(self, grpc_event c_event)
36 cdef RequestCallEvent event(self, grpc_event c_event)
48 cdef BatchOperationEvent event(self, grpc_event c_event)
58 cdef ServerShutdownEvent event(self, grpc_event c_event)
|
| D | tag.pyx.pxi | 18 cdef object event(self, grpc_event c_event):
27 cdef ConnectivityEvent event(self, grpc_event c_event):
43 cdef RequestCallEvent event(self, grpc_event c_event):
66 cdef BatchOperationEvent event(self, grpc_event c_event):
85 cdef ServerShutdownEvent event(self, grpc_event c_event):
|
| D | completion_queue.pxd.pxi | 16 cdef grpc_event _next(grpc_completion_queue *c_completion_queue, deadline)
19 cdef _interpret_event(grpc_event c_event)
28 cdef _interpret_event(self, grpc_event c_event)
|
| D | completion_queue.pyx.pxi | 23 cdef grpc_event _next(grpc_completion_queue *c_completion_queue, deadline):
49 cdef _interpret_event(grpc_event c_event):
66 cdef grpc_event c_event = _next(c_completion_queue, deadline)
86 cdef _interpret_event(self, grpc_event c_event):
|
| /external/grpc-grpc/test/core/surface/ |
| D | completion_queue_test.cc | 38 grpc_event ev; in shutdown_and_destroy()
114 grpc_event event; in test_wait_empty()
134 grpc_event ev; in test_cq_end_op()
167 grpc_event ev; in test_cq_tls_cache_full()
241 grpc_event event; in test_shutdown_then_next_polling()
263 grpc_event event; in test_shutdown_then_next_with_timeout()
282 grpc_event ev; in test_pluck()
340 grpc_event ev; in test_pluck_after_shutdown()
|
| D | completion_queue_threading_test.cc | 39 grpc_event ev; in shutdown_and_destroy()
77 grpc_event ev; in test_too_many_plucks()
176 grpc_event ev; in consumer_thread()
|
| D | num_external_connectivity_watchers_test.cc | 53 grpc_event ev = grpc_completion_queue_next( in channel_idle_poll_for_timeout()
144 grpc_event ev = grpc_completion_queue_next( in run_channel_shutdown_before_timeout_test()
|
| D | sequential_connectivity_test.cc | 47 grpc_event ev = grpc_completion_queue_next( in server_thread_func()
84 grpc_event ev = grpc_completion_queue_next( in run_test()
|
| D | concurrent_connectivity_test.cc | 99 grpc_event ev; in server_thread()
267 grpc_event ev = grpc_completion_queue_next(cq, poll_time, nullptr); in watches_with_short_timeouts()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | event_string.cc | 29 static void addhdr(gpr_strvec* buf, grpc_event* ev) { in addhdr()
43 char* grpc_event_string(grpc_event* ev) { in grpc_event_string()
|
| D | event_string.h | 27 char* grpc_event_string(grpc_event* ev);
|
| D | completion_queue.cc | 195 grpc_event (*next)(grpc_completion_queue* cq, gpr_timespec deadline,
197 grpc_event (*pluck)(grpc_completion_queue* cq, void* tag,
330 static grpc_event cq_next(grpc_completion_queue* cq, gpr_timespec deadline,
333 static grpc_event cq_pluck(grpc_completion_queue* cq, void* tag,
941 static grpc_event cq_next(grpc_completion_queue* cq, gpr_timespec deadline,
945 grpc_event ret;
1106 grpc_event grpc_completion_queue_next(grpc_completion_queue* cq,
1180 static grpc_event cq_pluck(grpc_completion_queue* cq, void* tag,
1184 grpc_event ret;
1300 grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq, void* tag,
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_completion_queue.c | 34 grpc_event event;
74 grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag, in rb_completion_queue_pluck()
|
| D | rb_completion_queue.h | 33 grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag,
|
| /external/grpc-grpc/test/core/end2end/ |
| D | cq_verifier_uv.cc | 79 grpc_event cq_verifier_next_event(cq_verifier* v, int timeout_seconds) { in cq_verifier_next_event()
82 grpc_event ev; in cq_verifier_next_event()
|
| D | cq_verifier_internal.h | 30 grpc_event cq_verifier_next_event(cq_verifier* v, int timeout_seconds);
|
| D | cq_verifier.cc | 225 static void verify_matches(expectation* e, grpc_event* ev) { in verify_matches()
254 grpc_event ev = grpc_completion_queue_next(v->cq, deadline, nullptr); in cq_verify()
291 grpc_event ev; in cq_verify_empty_timeout()
|
| D | cq_verifier_native.cc | 54 grpc_event cq_verifier_next_event(cq_verifier* v, int timeout_seconds) { in cq_verifier_next_event()
|
| /external/grpc-grpc/test/core/handshake/ |
| D | verify_peer_options.cc | 90 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
100 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
178 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in verify_peer_options_test()
|
| D | server_ssl_common.cc | 108 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
117 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | grpc_types.h | 461 typedef struct grpc_event { struct
473 } grpc_event; typedef
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | cancel_with_status.cc | 59 grpc_event ev; in drain_cq()
68 grpc_event ev = grpc_completion_queue_next( in shutdown_server()
|
| D | cancel_after_invoke.cc | 60 grpc_event ev; in drain_cq()
69 grpc_event ev = grpc_completion_queue_next( in shutdown_server()
|
| /external/grpc-grpc/include/grpc/ |
| D | grpc.h | 130 GRPCAPI grpc_event grpc_completion_queue_next(grpc_completion_queue* cq,
145 GRPCAPI grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
|
| /external/grpc-grpc/test/core/bad_ssl/ |
| D | server_common.cc | 49 grpc_event ev; in bad_ssl_run()
|