| /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()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | completion_queue.h | 54 void grpc_cq_internal_ref(grpc_completion_queue* cq, const char* reason,
56 void grpc_cq_internal_unref(grpc_completion_queue* cq, const char* reason,
63 void grpc_cq_internal_ref(grpc_completion_queue* cq);
64 void grpc_cq_internal_unref(grpc_completion_queue* cq);
76 bool grpc_cq_begin_op(grpc_completion_queue* cq, void* tag);
80 void grpc_cq_end_op(grpc_completion_queue* cq, void* tag, grpc_error* error,
85 grpc_pollset* grpc_cq_pollset(grpc_completion_queue* cq);
87 bool grpc_cq_can_listen(grpc_completion_queue* cq);
89 grpc_cq_completion_type grpc_get_cq_completion_type(grpc_completion_queue* cq);
91 int grpc_get_cq_poll_num(grpc_completion_queue* cq);
[all …]
|
| D | completion_queue.cc | 202 void (*shutdown)(grpc_completion_queue* cq);
204 bool (*begin_op)(grpc_completion_queue* cq, void* tag);
205 void (*end_op)(grpc_completion_queue* cq, void* tag, grpc_error* error,
208 grpc_event (*next)(grpc_completion_queue* cq, gpr_timespec deadline,
210 grpc_event (*pluck)(grpc_completion_queue* cq, void* tag,
341 struct grpc_completion_queue { struct
361 static void cq_finish_shutdown_next(grpc_completion_queue* cq); argument
362 static void cq_finish_shutdown_pluck(grpc_completion_queue* cq);
363 static void cq_finish_shutdown_callback(grpc_completion_queue* cq);
364 static void cq_shutdown_next(grpc_completion_queue* cq);
[all …]
|
| D | server.h | 133 void RegisterCompletionQueue(grpc_completion_queue* cq);
138 grpc_completion_queue* cq, void* method_tag,
140 void SetBatchMethodAllocator(grpc_completion_queue* cq,
150 grpc_completion_queue* cq_bound_to_call,
151 grpc_completion_queue* cq_for_notification,
158 grpc_completion_queue* cq_bound_to_call,
159 grpc_completion_queue* cq_for_notification, void* tag_new);
161 void ShutdownAndNotify(grpc_completion_queue* cq, void* tag);
292 grpc_completion_queue* cq_new_ = nullptr;
327 ShutdownTag(void* tag_arg, grpc_completion_queue* cq_arg) in ShutdownTag()
[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 | server.cc | 69 RequestedCall(void* tag_arg, grpc_completion_queue* call_cq, in RequestedCall()
81 RequestedCall(void* tag_arg, grpc_completion_queue* call_cq, in RequestedCall()
98 grpc_completion_queue* const cq_bound_to_call;
324 AllocatingRequestMatcherBase(Server* server, grpc_completion_queue* cq) in AllocatingRequestMatcherBase()
350 grpc_completion_queue* cq() const { return cq_; } in cq()
357 grpc_completion_queue* const cq_;
366 AllocatingRequestMatcherBatch(Server* server, grpc_completion_queue* cq, in AllocatingRequestMatcherBatch()
393 Server* server, grpc_completion_queue* cq, RegisteredMethod* rm, in AllocatingRequestMatcherRegistered()
565 for (grpc_completion_queue* cq : cqs_) { in Start()
641 grpc_completion_queue* cq, void* method_tag, in SetRegisteredMethodAllocator()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/ |
| D | grpc.h | 106 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_next(
111 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_pluck(
117 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_callback(
122 GRPCAPI grpc_completion_queue* grpc_completion_queue_create(
134 GRPCAPI grpc_event grpc_completion_queue_next(grpc_completion_queue* cq,
149 GRPCAPI grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
164 GRPCAPI void grpc_completion_queue_shutdown(grpc_completion_queue* cq);
168 GRPCAPI void grpc_completion_queue_destroy(grpc_completion_queue* cq);
176 grpc_completion_queue* cq);
185 grpc_completion_queue* cq, void** tag, int* ok);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/ |
| D | grpc.h | 106 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_next(
111 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_pluck(
117 GRPCAPI grpc_completion_queue* grpc_completion_queue_create_for_callback(
122 GRPCAPI grpc_completion_queue* grpc_completion_queue_create(
134 GRPCAPI grpc_event grpc_completion_queue_next(grpc_completion_queue* cq,
149 GRPCAPI grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
164 GRPCAPI void grpc_completion_queue_shutdown(grpc_completion_queue* cq);
168 GRPCAPI void grpc_completion_queue_destroy(grpc_completion_queue* cq);
176 grpc_completion_queue* cq);
185 grpc_completion_queue* cq, void** tag, int* ok);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | core_codegen_interface.h | 49 virtual grpc_completion_queue* grpc_completion_queue_create(
52 virtual grpc_completion_queue* grpc_completion_queue_create_for_next(
54 virtual grpc_completion_queue* grpc_completion_queue_create_for_pluck(
56 virtual void grpc_completion_queue_shutdown(grpc_completion_queue* cq) = 0;
57 virtual void grpc_completion_queue_destroy(grpc_completion_queue* cq) = 0;
58 virtual grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
|
| D | core_codegen.h | 36 grpc_completion_queue* grpc_completion_queue_create(
40 grpc_completion_queue* grpc_completion_queue_create_for_next(
42 grpc_completion_queue* grpc_completion_queue_create_for_pluck(
44 void grpc_completion_queue_shutdown(grpc_completion_queue* cq) override;
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/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | core_codegen.h | 36 grpc_completion_queue* grpc_completion_queue_create(
40 grpc_completion_queue* grpc_completion_queue_create_for_next(
42 grpc_completion_queue* grpc_completion_queue_create_for_pluck(
44 void grpc_completion_queue_shutdown(grpc_completion_queue* cq) override;
45 void grpc_completion_queue_destroy(grpc_completion_queue* cq) override;
46 grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq, void* tag,
|
| D | core_codegen_interface.h | 49 virtual grpc_completion_queue* grpc_completion_queue_create(
52 virtual grpc_completion_queue* grpc_completion_queue_create_for_next(
54 virtual grpc_completion_queue* grpc_completion_queue_create_for_pluck(
56 virtual void grpc_completion_queue_shutdown(grpc_completion_queue* cq) = 0;
57 virtual void grpc_completion_queue_destroy(grpc_completion_queue* cq) = 0;
58 virtual grpc_event grpc_completion_queue_pluck(grpc_completion_queue* cq,
|
| /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 …]
|
| /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/rust/crates/grpcio-sys/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_shutdown(grpc_completion_queue* cq) { in grpc_completion_queue_shutdown()
66 void CoreCodegen::grpc_completion_queue_destroy(grpc_completion_queue* cq) { in grpc_completion_queue_destroy()
70 grpc_event CoreCodegen::grpc_completion_queue_pluck(grpc_completion_queue* cq, in grpc_completion_queue_pluck()
|
| /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()
|
| /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/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()
|