/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 | 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 | 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()
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
D | event_string.cc | 34 static void addhdr(grpc_event* ev, std::vector<std::string>* buf) { in addhdr() 44 std::string grpc_event_string(grpc_event* ev) { in grpc_event_string()
|
D | event_string.h | 29 std::string grpc_event_string(grpc_event* ev);
|
D | completion_queue.cc | 208 grpc_event (*next)(grpc_completion_queue* cq, gpr_timespec deadline, 210 grpc_event (*pluck)(grpc_completion_queue* cq, void* tag, 393 static grpc_event cq_next(grpc_completion_queue* cq, gpr_timespec deadline, 396 static grpc_event cq_pluck(grpc_completion_queue* cq, void* tag, 967 static grpc_event cq_next(grpc_completion_queue* cq, gpr_timespec deadline, 971 grpc_event ret; 1133 grpc_event grpc_completion_queue_next(grpc_completion_queue* cq, 1208 static grpc_event cq_pluck(grpc_completion_queue* cq, void* tag, 1212 grpc_event ret; 1328 grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq, void* tag,
|
/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()
|
/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; argument
|
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/ |
D | grpc_types.h | 533 typedef struct grpc_event { struct 546 } grpc_event; argument
|
/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()
|
/external/rust/crates/grpcio-sys/grpc/include/grpc/impl/codegen/ |
D | grpc_types.h | 533 typedef struct grpc_event { struct 546 } grpc_event; argument
|