| /external/grpc-grpc/include/grpc/ |
| D | grpc.h | 102 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_next(
107 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_pluck(
113 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_callback(
118 GRPCAPI grpc_completion_queue* grpc_completion_queue_create(
130 GRPCAPI grpc_event grpc_completion_queue_next(grpc_completion_queue* cq,
145 GRPCAPI grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
160 GRPCAPI void grpc_completion_queue_shutdown(grpc_completion_queue* cq);
164 GRPCAPI void grpc_completion_queue_destroy(grpc_completion_queue* cq);
172 grpc_completion_queue* cq);
181 grpc_completion_queue* cq, void** tag, int* ok);
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | completion_queue.h | 52 void grpc_cq_internal_ref(grpc_completion_queue* cc, const char* reason,
54 void grpc_cq_internal_unref(grpc_completion_queue* cc, const char* reason,
61 void grpc_cq_internal_ref(grpc_completion_queue* cc);
62 void grpc_cq_internal_unref(grpc_completion_queue* cc);
74 bool grpc_cq_begin_op(grpc_completion_queue* cc, void* tag);
78 void grpc_cq_end_op(grpc_completion_queue* cc, void* tag, grpc_error* error,
82 grpc_pollset* grpc_cq_pollset(grpc_completion_queue* cc);
84 bool grpc_cq_can_listen(grpc_completion_queue* cc);
86 grpc_cq_completion_type grpc_get_cq_completion_type(grpc_completion_queue* cc);
88 int grpc_get_cq_poll_num(grpc_completion_queue* cc);
[all …]
|
| D | completion_queue.cc | 189 void (*shutdown)(grpc_completion_queue* cq);
191 bool (*begin_op)(grpc_completion_queue* cq, void* tag);
192 void (*end_op)(grpc_completion_queue* cq, void* tag, grpc_error* error,
195 grpc_event (*next)(grpc_completion_queue* cq, gpr_timespec deadline,
197 grpc_event (*pluck)(grpc_completion_queue* cq, void* tag,
275 struct grpc_completion_queue { struct
295 static void cq_finish_shutdown_next(grpc_completion_queue* cq); argument
296 static void cq_finish_shutdown_pluck(grpc_completion_queue* cq);
297 static void cq_finish_shutdown_callback(grpc_completion_queue* cq);
298 static void cq_shutdown_next(grpc_completion_queue* cq);
[all …]
|
| D | completion_queue_factory.cc | 30 static grpc_completion_queue* default_create( in default_create()
60 grpc_completion_queue* grpc_completion_queue_create_for_next(void* reserved) { in grpc_completion_queue_create_for_next()
67 grpc_completion_queue* grpc_completion_queue_create_for_pluck(void* reserved) { in grpc_completion_queue_create_for_pluck()
74 grpc_completion_queue* grpc_completion_queue_create_for_callback( in grpc_completion_queue_create_for_callback()
83 grpc_completion_queue* grpc_completion_queue_create( in grpc_completion_queue_create()
|
| D | channel_ping.cc | 34 grpc_completion_queue* cq;
48 void grpc_channel_ping(grpc_channel* channel, grpc_completion_queue* cq, in grpc_channel_ping()
|
| /external/grpc-grpc/test/core/surface/ |
| D | completion_queue_test.cc | 37 static void shutdown_and_destroy(grpc_completion_queue* cc) { in shutdown_and_destroy()
91 grpc_completion_queue* cq; in test_pollset_conversion()
112 grpc_completion_queue* cc; in test_wait_empty()
135 grpc_completion_queue* cc; in test_cq_end_op()
168 grpc_completion_queue* cc; in test_cq_tls_cache_full()
210 grpc_completion_queue* cc; in test_cq_tls_cache_empty()
239 grpc_completion_queue* cc; in test_shutdown_then_next_polling()
261 grpc_completion_queue* cc; in test_shutdown_then_next_with_timeout()
283 grpc_completion_queue* cc; in test_pluck()
341 grpc_completion_queue* cc; in test_pluck_after_shutdown()
[all …]
|
| D | num_external_connectivity_watchers_test.cc | 40 grpc_completion_queue* cq) { in channel_idle_start_watch()
52 grpc_completion_queue* cq) { in channel_idle_poll_for_timeout()
76 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in run_timeouts_test()
130 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in run_channel_shutdown_before_timeout_test()
|
| D | completion_queue_threading_test.cc | 38 static void shutdown_and_destroy(grpc_completion_queue* cc) { in shutdown_and_destroy()
66 grpc_completion_queue* cc;
78 grpc_completion_queue* cc; in test_too_many_plucks()
132 grpc_completion_queue* cc;
213 grpc_completion_queue* cc = grpc_completion_queue_create_for_next(nullptr); in test_threading()
|
| D | sequential_connectivity_test.cc | 42 grpc_completion_queue* cq;
64 grpc_completion_queue* server_cq = in run_test()
73 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in run_test()
|
| D | server_test.cc | 59 grpc_completion_queue* cc = grpc_completion_queue_create_for_next(nullptr); in test_request_call_on_no_server_cq()
84 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in test_bind_server_twice()
122 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in test_bind_server_to_addr()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq.cc | 50 grpc_completion_queue* core_cq = in BM_CreateDestroyCpp2()
81 grpc_completion_queue* c_cq = cq.cq(); in BM_Pass1Cpp()
101 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in BM_Pass1Core()
120 grpc_completion_queue* cq = grpc_completion_queue_create_for_pluck(nullptr); in BM_Pluck1Core()
139 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in BM_EmptyCore()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | core_codegen_interface.h | 48 virtual grpc_completion_queue* grpc_completion_queue_create(
51 virtual grpc_completion_queue* grpc_completion_queue_create_for_next(
53 virtual grpc_completion_queue* grpc_completion_queue_create_for_pluck(
55 virtual void grpc_completion_queue_destroy(grpc_completion_queue* cq) = 0;
56 virtual grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
|
| D | core_codegen.h | 37 virtual grpc_completion_queue* grpc_completion_queue_create(
41 grpc_completion_queue* grpc_completion_queue_create_for_next(
43 grpc_completion_queue* grpc_completion_queue_create_for_pluck(
45 void grpc_completion_queue_destroy(grpc_completion_queue* cq) override;
46 grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq, void* tag,
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_completion_queue.c | 33 grpc_completion_queue* cq;
58 void grpc_rb_completion_queue_destroy(grpc_completion_queue* cq) { in grpc_rb_completion_queue_destroy()
74 grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag, in rb_completion_queue_pluck()
|
| D | rb_grpc_imports.generated.h | 104 typedef grpc_completion_queue*(*grpc_completion_queue_create_for_next_type)(void* reserved);
107 typedef grpc_completion_queue*(*grpc_completion_queue_create_for_pluck_type)(void* reserved);
110 typedef grpc_completion_queue*(*grpc_completion_queue_create_for_callback_type)(grpc_experimental_c…
113 typedef grpc_completion_queue*(*grpc_completion_queue_create_type)(const grpc_completion_queue_fact…
116 typedef grpc_event(*grpc_completion_queue_next_type)(grpc_completion_queue* cq, gpr_timespec deadli…
119 typedef grpc_event(*grpc_completion_queue_pluck_type)(grpc_completion_queue* cq, void* tag, gpr_tim…
122 typedef void(*grpc_completion_queue_shutdown_type)(grpc_completion_queue* cq);
125 typedef void(*grpc_completion_queue_destroy_type)(grpc_completion_queue* cq);
128 typedef void(*grpc_completion_queue_thread_local_cache_init_type)(grpc_completion_queue* cq);
131 typedef int(*grpc_completion_queue_thread_local_cache_flush_type)(grpc_completion_queue* cq, void**…
[all …]
|
| D | rb_completion_queue.h | 26 void grpc_rb_completion_queue_destroy(grpc_completion_queue* cq);
33 grpc_event rb_completion_queue_pluck(grpc_completion_queue* queue, void* tag,
|
| /external/grpc-grpc/test/core/end2end/ |
| D | multiple_server_queues_test.cc | 23 grpc_completion_queue* cq1; in main()
24 grpc_completion_queue* cq2; in main()
25 grpc_completion_queue* cq3; in main()
|
| D | h2_ssl_session_reuse_test.cc | 48 grpc_server* server_create(grpc_completion_queue* cq, char* server_addr) { in server_create()
94 void do_round_trip(grpc_completion_queue* cq, grpc_server* server, in do_round_trip()
208 void drain_cq(grpc_completion_queue* cq) { in drain_cq()
221 grpc_completion_queue* cq = grpc_completion_queue_create_for_next(nullptr); in TEST()
237 grpc_completion_queue* shutdown_cq = in TEST()
|
| D | cq_verifier_native.cc | 29 grpc_completion_queue* cq;
34 cq_verifier* cq_verifier_create(grpc_completion_queue* cq) { in cq_verifier_create()
|
| D | end2end_tests.h | 41 grpc_completion_queue* cq;
42 grpc_completion_queue* shutdown_cq;
|
| /external/grpc-grpc/src/cpp/common/ |
| D | core_codegen.cc | 46 grpc_completion_queue* CoreCodegen::grpc_completion_queue_create( in grpc_completion_queue_create()
52 grpc_completion_queue* CoreCodegen::grpc_completion_queue_create_for_next( in grpc_completion_queue_create_for_next()
57 grpc_completion_queue* CoreCodegen::grpc_completion_queue_create_for_pluck( in grpc_completion_queue_create_for_pluck()
62 void CoreCodegen::grpc_completion_queue_destroy(grpc_completion_queue* cq) { in grpc_completion_queue_destroy()
66 grpc_event CoreCodegen::grpc_completion_queue_pluck(grpc_completion_queue* cq, in grpc_completion_queue_pluck()
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | grpc.pxi | 145 ctypedef struct grpc_completion_queue:
332 grpc_completion_queue *grpc_completion_queue_create(
335 grpc_completion_queue *grpc_completion_queue_create_for_next(void *reserved) nogil
337 grpc_event grpc_completion_queue_next(grpc_completion_queue *cq,
340 grpc_event grpc_completion_queue_pluck(grpc_completion_queue *cq, void *tag,
343 void grpc_completion_queue_shutdown(grpc_completion_queue *cq) nogil
344 void grpc_completion_queue_destroy(grpc_completion_queue *cq) nogil
362 grpc_completion_queue *completion_queue, grpc_slice method,
368 gpr_timespec deadline, grpc_completion_queue *cq, void *tag) nogil
376 grpc_metadata_array *request_metadata, grpc_completion_queue
[all …]
|
| D | channel.pxd.pxi | 47 cdef grpc_completion_queue *c_call_completion_queue
53 cdef grpc_completion_queue *c_connectivity_completion_queue
66 cdef grpc_completion_queue *_c_completion_queue
|
| /external/grpc-grpc/test/core/bad_client/ |
| D | bad_client.cc | 44 grpc_completion_queue* cq;
92 grpc_completion_queue* client_cq) { in grpc_run_client_side_validator()
192 grpc_completion_queue* shutdown_cq; in grpc_run_bad_client_test()
193 grpc_completion_queue* client_cq; in grpc_run_bad_client_test()
312 grpc_completion_queue* cq, in server_verifier_request_call()
|
| D | bad_client.h | 33 grpc_completion_queue* cq,
94 grpc_completion_queue* cq,
|