Searched defs:completion_queue (Results 1 – 10 of 10) sorted by relevance
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | completion_queue.c | 21 grpc_completion_queue *completion_queue; variable
|
| /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/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_client.cc | 123 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::eager::__anon22cba6b30111::GrpcEagerClientCache::GrpcEagerClientThread
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_cache.cc | 124 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::__anonab8e586b0111::GrpcWorkerCache::GrpcWorkerCacheThread
|
| D | grpc_remote_worker.cc | 47 ::grpc::CompletionQueue* completion_queue, in GrpcRemoteWorker()
310 ::grpc::CompletionQueue* completion_queue, in NewGrpcRemoteWorker()
|
| /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
|