Home
last modified time | relevance | path

Searched refs:completion_queue (Results 1 – 25 of 32) sorted by relevance

12

/external/grpc-grpc/src/php/ext/grpc/
Dcompletion_queue.c21 grpc_completion_queue *completion_queue; variable
24 completion_queue = grpc_completion_queue_create_for_pluck(NULL); in grpc_php_init_completion_queue()
28 grpc_completion_queue_shutdown(completion_queue); in grpc_php_shutdown_completion_queue()
29 grpc_completion_queue_destroy(completion_queue); in grpc_php_shutdown_completion_queue()
Dserver.c40 grpc_server_shutdown_and_notify(p->wrapped, completion_queue, NULL);
42 grpc_completion_queue_pluck(completion_queue, NULL,
85 grpc_server_register_completion_queue(server->wrapped, completion_queue, in PHP_METHOD()
110 completion_queue, completion_queue, NULL); in PHP_METHOD()
116 event = grpc_completion_queue_pluck(completion_queue, NULL, in PHP_METHOD()
Dcompletion_queue.h27 extern grpc_completion_queue *completion_queue;
Dcall.c237 completion_queue, method_slice, in PHP_METHOD()
448 grpc_completion_queue_pluck(completion_queue, call->wrapped, in PHP_METHOD()
Dchannel.c523 deadline->wrapped, completion_queue, in PHP_METHOD()
526 grpc_completion_queue_pluck(completion_queue, NULL, in PHP_METHOD()
Dconfig.m486 channel_credentials.c completion_queue.c timeval.c server.c \
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
Dcygrpc_test.py41 completion_queue = cygrpc.CompletionQueue()
42 del completion_queue
68 completion_queue = cygrpc.CompletionQueue()
69 server.register_completion_queue(completion_queue)
76 completion_queue = cygrpc.CompletionQueue()
84 server.register_completion_queue(completion_queue)
87 server.shutdown(completion_queue, shutdown_tag)
88 event = completion_queue.poll()
93 del completion_queue
Dtest_utilities.py50 def __init__(self, completion_queue, deadline): argument
52 self).__init__(lambda: completion_queue.poll(deadline=deadline))
D_read_some_but_not_all_responses_test.py28 def __init__(self, completion_queue, shutdown_tag): argument
30 self._completion_queue = completion_queue
69 def __init__(self, condition, completion_queue, due): argument
71 self._completion_queue = completion_queue
D_cancel_many_calls_test.py54 def __init__(self, state, completion_queue, rpc_event): argument
57 self._completion_queue = completion_queue
110 def __init__(self, condition, completion_queue, due): argument
112 self._completion_queue = completion_queue
D_common.py43 def __init__(self, condition, completion_queue): argument
45 self._completion_queue = completion_queue
/external/grpc-grpc/src/python/grpcio/grpc/
D_server.py651 def __init__(self, completion_queue, server, generic_handlers, argument
654 self.completion_queue = completion_queue
686 state.server.request_call(state.completion_queue, state.completion_queue,
709 event = state.completion_queue.poll()
758 state.server.shutdown(state.completion_queue, _SHUTDOWN_TAG)
807 completion_queue = cygrpc.CompletionQueue()
809 server.register_completion_queue(completion_queue)
810 self._state = _ServerState(completion_queue, server, generic_handlers,
/external/grpc-grpc/src/python/grpcio/grpc/_cython/
DBUILD.bazel17 "_cygrpc/completion_queue.pyx.pxi",
34 "_cygrpc/completion_queue.pxd.pxi",
Dcygrpc.pxd22 include "_cygrpc/completion_queue.pxd.pxi"
Dcygrpc.pyx29 include "_cygrpc/completion_queue.pyx.pxi"
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_remote_worker.cc47 ::grpc::CompletionQueue* completion_queue, in GrpcRemoteWorker() argument
52 cq_(completion_queue), in GrpcRemoteWorker()
310 ::grpc::CompletionQueue* completion_queue, in NewGrpcRemoteWorker() argument
313 return new GrpcRemoteWorker(std::move(channel), completion_queue, in NewGrpcRemoteWorker()
Dgrpc_worker_cache.cc79 channel, threads_[AssignWorkerToThread(target)].completion_queue(), in CreateWorker()
124 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::__anon054a07220111::GrpcWorkerCache::GrpcWorkerCacheThread
Dgrpc_remote_worker.h33 ::grpc::CompletionQueue* completion_queue,
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_client.cc75 shared, threads_[AssignClientToThread(target)].completion_queue())); in GetClient()
123 ::grpc::CompletionQueue* completion_queue() { return &completion_queue_; } in completion_queue() function in tensorflow::eager::__anonb8f342aa0111::GrpcEagerClientCache::GrpcEagerClientThread
/external/grpc-grpc/include/grpc/
Dgrpc.h214 grpc_completion_queue* completion_queue, grpc_slice method,
231 grpc_completion_queue* completion_queue, void* registered_call_handle,
/external/grpc-grpc/src/core/lib/surface/
Dchannel.cc389 grpc_completion_queue* completion_queue, void* registered_call_handle, in grpc_channel_create_registered_call() argument
400 (channel, parent_call, (unsigned)propagation_mask, completion_queue, in grpc_channel_create_registered_call()
406 channel, parent_call, propagation_mask, completion_queue, nullptr, in grpc_channel_create_registered_call()
/external/grpc-grpc/
DgRPC-C++.podspec80 'include/grpcpp/completion_queue.h',
136 'include/grpcpp/impl/codegen/completion_queue.h',
471 'src/core/lib/surface/completion_queue.h',
661 'src/core/lib/surface/completion_queue.h',
DBUILD163 "include/grpc++/completion_queue.h",
210 "include/grpcpp/completion_queue.h",
803 "src/core/lib/surface/completion_queue.cc",
937 "src/core/lib/surface/completion_queue.h",
1957 "include/grpc++/impl/codegen/completion_queue.h",
1990 "include/grpcpp/impl/codegen/completion_queue.h",
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_grpc_imports.generated.h146 …all* parent_call, uint32_t propagation_mask, grpc_completion_queue* completion_queue, grpc_slice m…
155 …all* parent_call, uint32_t propagation_mask, grpc_completion_queue* completion_queue, void* regist…
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dgrpc.pxi362 grpc_completion_queue *completion_queue, grpc_slice method,

12