/third_party/grpc/src/php/ext/grpc/ |
D | completion_queue.c | 21 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()
|
D | server.c | 45 grpc_server_shutdown_and_notify(p->wrapped, completion_queue, NULL); 47 grpc_completion_queue_pluck(completion_queue, NULL, 90 grpc_server_register_completion_queue(server->wrapped, completion_queue, in PHP_METHOD() 115 completion_queue, completion_queue, NULL); in PHP_METHOD() 121 event = grpc_completion_queue_pluck(completion_queue, NULL, in PHP_METHOD()
|
D | completion_queue.h | 31 extern grpc_completion_queue *completion_queue;
|
D | call.c | 246 completion_queue, method_slice, in PHP_METHOD() 457 grpc_completion_queue_pluck(completion_queue, call->wrapped, in PHP_METHOD()
|
D | channel.c | 555 deadline->wrapped, completion_queue, in PHP_METHOD() 558 grpc_completion_queue_pluck(completion_queue, NULL, in PHP_METHOD()
|
/third_party/boost/libs/asio/doc/overview/ |
D | proactor.dot | 33 completion_queue 77 async_processor -> completion_queue 85 async_event_demuxer -> completion_queue
|
/third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
D | cygrpc_test.py | 41 completion_queue = cygrpc.CompletionQueue() 42 del completion_queue 64 completion_queue = cygrpc.CompletionQueue() 65 server.register_completion_queue(completion_queue) 72 completion_queue = cygrpc.CompletionQueue() 80 server.register_completion_queue(completion_queue) 83 server.shutdown(completion_queue, shutdown_tag) 84 event = completion_queue.poll() 89 del completion_queue
|
D | test_utilities.py | 50 def __init__(self, completion_queue, deadline): argument 52 self).__init__(lambda: completion_queue.poll(deadline=deadline))
|
D | _cancel_many_calls_test.py | 54 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 | _read_some_but_not_all_responses_test.py | 28 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 | _common.py | 43 def __init__(self, condition, completion_queue): argument 45 self._completion_queue = completion_queue
|
/third_party/grpc/src/python/grpcio/grpc/ |
D | _server.py | 765 def __init__(self, completion_queue, server, generic_handlers, argument 768 self.completion_queue = completion_queue 804 state.server.request_call(state.completion_queue, state.completion_queue, 871 event = state.completion_queue.poll(timeout) 886 state.server.shutdown(state.completion_queue, _SHUTDOWN_TAG) 949 completion_queue = cygrpc.CompletionQueue() 951 server.register_completion_queue(completion_queue) 952 self._state = _ServerState(completion_queue, server, generic_handlers,
|
/third_party/grpc/src/core/lib/surface/ |
D | channel.cc | 381 grpc_completion_queue* completion_queue, in grpc_channel_create_call() argument 388 channel, parent_call, propagation_mask, completion_queue, nullptr, in grpc_channel_create_call() 474 grpc_completion_queue* completion_queue, void* registered_call_handle, in grpc_channel_create_registered_call() argument 486 (channel, parent_call, (unsigned)propagation_mask, completion_queue, in grpc_channel_create_registered_call() 493 channel, parent_call, propagation_mask, completion_queue, nullptr, in grpc_channel_create_registered_call()
|
/third_party/grpc/src/python/grpcio/grpc/_cython/ |
D | cygrpc.pxd | 24 include "_cygrpc/completion_queue.pxd.pxi" 48 include "_cygrpc/aio/completion_queue.pxd.pxi"
|
D | cygrpc.pyx | 45 include "_cygrpc/completion_queue.pyx.pxi" 76 include "_cygrpc/aio/completion_queue.pyx.pxi"
|
/third_party/grpc/doc/core/ |
D | grpc-cq.md | 5 Code: [completion_queue.cc](https://github.com/grpc/grpc/blob/v1.15.1/src/core/lib/surface/completi…
|
D | grpc-polling-engines.md | 68 …ter is **invalid** and should not be used anymore. See the code in `completion_queue.cc` to see ho…
|
/third_party/grpc/include/grpc/ |
D | grpc.h | 218 grpc_completion_queue* completion_queue, grpc_slice method, 232 grpc_completion_queue* completion_queue, void* registered_call_handle,
|
/third_party/grpc/src/ruby/ext/grpc/ |
D | rb_grpc_imports.generated.h | 149 …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…
|
/third_party/grpc/ |
D | BUILD.gn | 1122 "src/core/lib/surface/completion_queue.cc", 1123 "src/core/lib/surface/completion_queue.h", 1259 "include/grpc++/completion_queue.h", 1278 "include/grpc++/impl/codegen/completion_queue.h", 1336 "include/grpcpp/completion_queue.h", 1361 "include/grpcpp/impl/codegen/completion_queue.h",
|
D | BUILD | 178 "include/grpc++/completion_queue.h", 225 "include/grpcpp/completion_queue.h", 794 "src/core/lib/surface/completion_queue.cc", 933 "src/core/lib/surface/completion_queue.h", 2208 "include/grpc++/impl/codegen/completion_queue.h", 2248 "include/grpcpp/impl/codegen/completion_queue.h",
|
D | gRPC-C++.podspec | 84 'include/grpcpp/completion_queue.h', 115 'include/grpcpp/impl/codegen/completion_queue.h', 563 'src/core/lib/surface/completion_queue.h', 1050 'src/core/lib/surface/completion_queue.h',
|
D | CMakeLists.txt | 1700 src/core/lib/surface/completion_queue.cc 2330 src/core/lib/surface/completion_queue.cc 2599 include/grpc++/completion_queue.h 2618 include/grpc++/impl/codegen/completion_queue.h 2678 include/grpcpp/completion_queue.h 2709 include/grpcpp/impl/codegen/completion_queue.h 3293 include/grpc++/completion_queue.h 3312 include/grpc++/impl/codegen/completion_queue.h 3372 include/grpcpp/completion_queue.h 3403 include/grpcpp/impl/codegen/completion_queue.h
|
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
D | grpc.pxi | 380 grpc_completion_queue *completion_queue, grpc_slice method,
|
/third_party/grpc/tools/doxygen/ |
D | Doxyfile.c++.internal | 806 include/grpc++/completion_queue.h \ 825 include/grpc++/impl/codegen/completion_queue.h \ 940 include/grpcpp/completion_queue.h \ 971 include/grpcpp/impl/codegen/completion_queue.h \ 1816 src/core/lib/surface/completion_queue.cc \ 1817 src/core/lib/surface/completion_queue.h \
|