| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio/src/ |
| D | cq.rs | 188 pub struct CompletionQueue { struct
189 handle: Arc<CompletionQueueHandle>, argument
193 impl CompletionQueue { implementation
194 pub fn new(handle: Arc<CompletionQueueHandle>, worker: Arc<WorkQueue>) -> CompletionQueue { in new()
|
| D | env.rs | 14 fn poll_queue(tx: mpsc::Sender<CompletionQueue>) { in poll_queue()
151 pub fn completion_queues(&self) -> &[CompletionQueue] { in completion_queues()
156 pub fn pick_cq(&self) -> CompletionQueue { in pick_cq()
|
| D | channel.rs | 639 cq: CompletionQueue, in new()
777 pub(crate) fn cq(&self) -> &CompletionQueue { in cq()
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/qps/ |
| H A D | server_async.cc | 57 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio/src/call/ |
| D | server.rs | 92 cq: &CompletionQueue, in handle_stream_req()
117 pub fn handle_unary_req(self, rc: RequestCallContext, _: &CompletionQueue) { in handle_unary_req()
245 cq: &CompletionQueue, in handle()
815 pub fn execute_unimplemented(ctx: RequestContext, cq: CompletionQueue) { in execute_unimplemented()
828 cq: &CompletionQueue, in execute()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpcpp/impl/ |
| D | channel_interface.h | 55 class CompletionQueue; variable
155 grpc::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal()
|
| D | intercepted_channel.h | 25 class CompletionQueue; variable
|
| D | call.h | 26 class CompletionQueue; variable
|
| /aosp_15_r20/external/grpc-grpc/include/grpcpp/impl/ |
| H A D | channel_interface.h | 55 class CompletionQueue; variable
155 grpc::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal()
|
| H A D | intercepted_channel.h | 25 class CompletionQueue; variable
|
| H A D | call.h | 26 class CompletionQueue; variable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/ |
| D | channel_interface.h | 55 class CompletionQueue; variable
155 grpc::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal()
|
| D | intercepted_channel.h | 25 class CompletionQueue; variable
|
| D | call.h | 26 class CompletionQueue; variable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio/src/task/ |
| D | callback.rs | 22 pub fn resolve(mut self, cq: &CompletionQueue, success: bool) { in resolve()
54 pub fn resolve(mut self, cq: &CompletionQueue, success: bool) { in resolve()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | completion_queue.h | 107 CompletionQueue() in CompletionQueue() function
249 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
|
| /aosp_15_r20/external/grpc-grpc/include/grpcpp/ |
| H A D | completion_queue.h | 107 CompletionQueue() in CompletionQueue() function
249 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | completion_queue.h | 107 CompletionQueue() in CompletionQueue() function
249 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| H A D | completion_queue.pxd.pxi | 26 cdef class CompletionQueue: class
|
| H A D | completion_queue.pyx.pxi | 80 cdef class CompletionQueue: class
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/cocoapods/generic/ |
| H A D | generic.mm | 102 - (void)verify_ok:(grpc::CompletionQueue*)cq i:(int)i expect_ok:(bool)expect_ok {
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 128 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
|
| /aosp_15_r20/external/grpc-grpc/src/cpp/common/ |
| H A D | completion_queue_cc.cc | 128 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
|
| /aosp_15_r20/external/grpc-grpc/include/grpcpp/generic/ |
| H A D | generic_stub.h | 35 class CompletionQueue; variable
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/ |
| D | generic_stub.h | 35 class CompletionQueue; variable
|