| /third_party/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):
67 cdef BatchOperationEvent event(self, grpc_event c_event):
86 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) except *
19 cdef _interpret_event(grpc_event c_event)
28 cdef _interpret_event(self, grpc_event c_event)
|
| D | completion_queue.pyx.pxi | 19 cdef grpc_event _next(grpc_completion_queue *c_completion_queue, deadline) except *:
46 cdef _interpret_event(grpc_event c_event):
63 cdef grpc_event c_event = _next(c_completion_queue, deadline)
83 cdef _interpret_event(self, grpc_event c_event):
|
| /third_party/grpc/test/core/surface/ |
| D | completion_queue_test.cc | 39 grpc_event ev; in shutdown_and_destroy()
115 grpc_event event; in test_wait_empty()
136 grpc_event ev; in test_cq_end_op()
169 grpc_event ev; in test_cq_tls_cache_full()
243 grpc_event event; in test_shutdown_then_next_polling()
265 grpc_event event; in test_shutdown_then_next_with_timeout()
284 grpc_event ev; in test_pluck()
342 grpc_event ev; in test_pluck_after_shutdown()
|
| D | completion_queue_threading_test.cc | 39 grpc_event ev; in shutdown_and_destroy()
78 grpc_event ev; in test_too_many_plucks()
177 grpc_event ev; in consumer_thread()
|
| D | num_external_connectivity_watchers_test.cc | 56 grpc_event ev = grpc_completion_queue_next( in channel_idle_poll_for_timeout()
142 grpc_event ev = grpc_completion_queue_next( in run_channel_shutdown_before_timeout_test()
|
| D | sequential_connectivity_test.cc | 56 grpc_event ev = grpc_completion_queue_next( in server_thread_func()
115 grpc_event ev = grpc_completion_queue_next( in run_test()
|
| /third_party/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,
|
| /third_party/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,
|
| /third_party/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 | 219 static void verify_matches(expectation* e, grpc_event* ev) { in verify_matches()
243 grpc_event ev = grpc_completion_queue_next(v->cq, deadline, nullptr); in cq_verify()
273 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()
|
| /third_party/grpc/test/core/handshake/ |
| D | verify_peer_options.cc | 92 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
102 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
183 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in verify_peer_options_test()
|
| D | server_ssl_common.cc | 142 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
151 grpc_event ev = grpc_completion_queue_next(cq, cq_deadline, nullptr); in server_thread()
|
| /third_party/grpc/include/grpc/impl/codegen/ |
| D | grpc_types.h | 533 typedef struct grpc_event { struct
546 } grpc_event; argument
|
| /third_party/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()
|
| /third_party/grpc/include/grpc/ |
| D | grpc.h | 134 GRPCAPI grpc_event grpc_completion_queue_next(grpc_completion_queue* cq,
149 GRPCAPI grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
|
| /third_party/grpc/test/core/bad_connection/ |
| D | close_fd_test.cc | 136 grpc_event event; in drain_cq()
194 grpc_event event; in _test_close_before_server_recv()
368 grpc_event event; in _test_close_before_server_send()
565 grpc_event event; in _test_close_before_client_send()
692 grpc_event event; in _test_close_before_call_create()
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_shared_resource.cc | 35 grpc_event event = in thread_worker()
|