| /external/rust/crates/grpcio/src/ |
| D | cq.rs | 188 pub struct CompletionQueue { struct
189 handle: Arc<CompletionQueueHandle>, argument
193 impl CompletionQueue { impl
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()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | completion_queue.h | 64 class CompletionQueue; variable
99 CompletionQueue() in CompletionQueue() function
238 CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
|
| D | client_unary_call.h | 32 class CompletionQueue; variable
|
| D | client_callback.h | 35 class CompletionQueue; variable
|
| D | channel_interface.h | 29 class CompletionQueue; variable
|
| D | async_unary_call.h | 32 class CompletionQueue; variable
|
| D | server_context.h | 73 class CompletionQueue; variable
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | channel_interface.h | 55 class CompletionQueue; variable
155 ::grpc::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal()
|
| D | completion_queue.h | 106 CompletionQueue() in CompletionQueue() function
246 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
|
| D | intercepted_channel.h | 25 class CompletionQueue; variable
|
| D | call.h | 25 class CompletionQueue; variable
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | channel_interface.h | 55 class CompletionQueue; variable
155 ::grpc::CompletionQueue* /*cq*/, size_t /*interceptor_pos*/) { in CreateCallInternal()
|
| D | completion_queue.h | 106 CompletionQueue() in CompletionQueue() function
246 explicit CompletionQueue(const grpc_completion_queue_attributes& attributes) { in CompletionQueue() function
|
| D | intercepted_channel.h | 25 class CompletionQueue; variable
|
| D | call.h | 25 class CompletionQueue; variable
|
| /external/rust/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()
|
| /external/grpc-grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 31 class CompletionQueue; variable
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | completion_queue.pxd.pxi | 22 cdef class CompletionQueue: class
|
| D | completion_queue.pyx.pxi | 70 cdef class CompletionQueue: class
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 35 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
|
| /external/grpc-grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 35 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue() function in grpc::CompletionQueue
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_async.cc | 56 CompletionQueue*, ServerCompletionQueue*, void*)> in AsyncQpsServerTest() argument
|
| /external/rust/crates/grpcio/src/call/ |
| D | server.rs | 94 cq: &CompletionQueue, in handle_stream_req()
119 pub fn handle_unary_req(self, rc: RequestCallContext, _: &CompletionQueue) { in handle_unary_req()
246 cq: &CompletionQueue, in handle()
784 pub fn execute_unimplemented(ctx: RequestContext, cq: CompletionQueue) { in execute_unimplemented()
797 cq: &CompletionQueue, in execute()
|
| /external/grpc-grpc/test/cpp/cocoapods/generic/ |
| D | generic.mm | 102 - (void)verify_ok:(grpc::CompletionQueue*)cq i:(int)i expect_ok:(bool)expect_ok {
|