Home
last modified time | relevance | path

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

123456

/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dtag.pxd.pxi18 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)
Dtag.pyx.pxi18 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):
Dcompletion_queue.pxd.pxi16 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)
Dcompletion_queue.pyx.pxi23 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/
Dcompletion_queue_test.cc38 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()
Dcompletion_queue_threading_test.cc39 grpc_event ev; in shutdown_and_destroy()
77 grpc_event ev; in test_too_many_plucks()
176 grpc_event ev; in consumer_thread()
Dsequential_connectivity_test.cc47 grpc_event ev = grpc_completion_queue_next( in server_thread_func()
84 grpc_event ev = grpc_completion_queue_next( in run_test()
Dnum_external_connectivity_watchers_test.cc53 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/
Devent_string.cc34 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()
Devent_string.h29 std::string grpc_event_string(grpc_event* ev);
Dcompletion_queue.cc208 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/
Devent_string.cc29 static void addhdr(gpr_strvec* buf, grpc_event* ev) { in addhdr()
43 char* grpc_event_string(grpc_event* ev) { in grpc_event_string()
Devent_string.h27 char* grpc_event_string(grpc_event* ev);
Dcompletion_queue.cc195 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/
Drb_completion_queue.c34 grpc_event event;
74 grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag, in rb_completion_queue_pluck()
Drb_completion_queue.h33 grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag,
/external/grpc-grpc/test/core/end2end/
Dcq_verifier_uv.cc79 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()
Dcq_verifier_internal.h30 grpc_event cq_verifier_next_event(cq_verifier* v, int timeout_seconds);
Dcq_verifier.cc225 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/
Dverify_peer_options.cc90 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()
Dserver_ssl_common.cc108 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/
Dgrpc_types.h461 typedef struct grpc_event { struct
473 } grpc_event; argument
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/
Dgrpc_types.h533 typedef struct grpc_event { struct
546 } grpc_event; argument
/external/grpc-grpc/test/core/end2end/tests/
Dcancel_with_status.cc59 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/
Dgrpc_types.h533 typedef struct grpc_event { struct
546 } grpc_event; argument

123456