| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _read_some_but_not_all_responses_test.py | 28 def __init__(self, completion_queue, shutdown_tag): argument
69 def __init__(self, condition, completion_queue, due): argument
|
| D | _cancel_many_calls_test.py | 54 def __init__(self, state, completion_queue, rpc_event): argument
110 def __init__(self, condition, completion_queue, due): argument
|
| D | test_utilities.py | 50 def __init__(self, completion_queue, deadline): argument
|
| D | _common.py | 43 def __init__(self, condition, completion_queue): argument
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | completion_queue.c | 21 grpc_completion_queue *completion_queue; variable
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_cache.h | 50 ::grpc::CompletionQueue* completion_queue() const { in completion_queue() function
|
| D | grpc_remote_worker.cc | 46 ::grpc::CompletionQueue* completion_queue, in GrpcRemoteWorker()
341 ::grpc::CompletionQueue* completion_queue, in NewGrpcRemoteWorker()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | channel.cc | 381 grpc_completion_queue* completion_queue, in grpc_channel_create_call()
474 grpc_completion_queue* completion_queue, void* registered_call_handle, in grpc_channel_create_registered_call()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_client.cc | 109 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::eager::__anon9a0136ef0111::GrpcEagerClientThread
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/coordination/ |
| D | grpc_coordination_client.cc | 54 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::__anon6e0169790111::GrpcCoordinationClientThread
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | channel.cc | 389 grpc_completion_queue* completion_queue, void* registered_call_handle, in grpc_channel_create_registered_call()
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 651 def __init__(self, completion_queue, server, generic_handlers, argument
|
| /external/tensorflow/tensorflow/distribute/experimental/rpc/kernels/ |
| D | rpc_ops.cc | 383 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::rpc::GrpcPollingThread
|
| /external/bcc/libbpf-tools/x86/ |
| D | vmlinux_505.h | 14840 struct sk_buff *completion_queue; member
40091 struct sk_buff___2 *completion_queue; member
|
| D | vmlinux.h | 14840 struct sk_buff *completion_queue; member
40091 struct sk_buff___2 *completion_queue; member
|
| /external/libbpf/.github/actions/build-selftests/ |
| D | vmlinux.h | 14595 struct sk_buff *completion_queue; member
|
| /external/bcc/libbpf-tools/powerpc/ |
| D | vmlinux_510.h | 109120 struct sk_buff *completion_queue; member
|
| D | vmlinux.h | 109120 struct sk_buff *completion_queue; member
|
| /external/bcc/libbpf-tools/arm64/ |
| D | vmlinux.h | 96223 struct sk_buff *completion_queue; member
|
| D | vmlinux_510.h | 96223 struct sk_buff *completion_queue; member
|