Home
last modified time | relevance | path

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

12

/third_party/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.c45 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()
Dcompletion_queue.h31 extern grpc_completion_queue *completion_queue;
Dcall.c246 completion_queue, method_slice, in PHP_METHOD()
457 grpc_completion_queue_pluck(completion_queue, call->wrapped, in PHP_METHOD()
Dchannel.c555 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/
Dproactor.dot33 completion_queue
77 async_processor -> completion_queue
85 async_event_demuxer -> completion_queue
/third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/
Dcygrpc_test.py41 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
Dtest_utilities.py50 def __init__(self, completion_queue, deadline): argument
52 self).__init__(lambda: completion_queue.poll(deadline=deadline))
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_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_common.py43 def __init__(self, condition, completion_queue): argument
45 self._completion_queue = completion_queue
/third_party/grpc/src/python/grpcio/grpc/
D_server.py765 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/
Dchannel.cc381 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/
Dcygrpc.pxd24 include "_cygrpc/completion_queue.pxd.pxi"
48 include "_cygrpc/aio/completion_queue.pxd.pxi"
Dcygrpc.pyx45 include "_cygrpc/completion_queue.pyx.pxi"
76 include "_cygrpc/aio/completion_queue.pyx.pxi"
/third_party/grpc/doc/core/
Dgrpc-cq.md5 Code: [completion_queue.cc](https://github.com/grpc/grpc/blob/v1.15.1/src/core/lib/surface/completi…
Dgrpc-polling-engines.md68 …ter is **invalid** and should not be used anymore. See the code in `completion_queue.cc` to see ho…
/third_party/grpc/include/grpc/
Dgrpc.h218 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/
Drb_grpc_imports.generated.h149 …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/
DBUILD.gn1122 "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",
DBUILD178 "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",
DgRPC-C++.podspec84 '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',
DCMakeLists.txt1700 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/
Dgrpc.pxi380 grpc_completion_queue *completion_queue, grpc_slice method,
/third_party/grpc/tools/doxygen/
DDoxyfile.c++.internal806 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 \

12