Home
last modified time | relevance | path

Searched refs:server_completion_queue (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
D_cancel_many_calls_test.py94 def _serve(state, server, server_completion_queue, thread_pool): argument
97 server.request_call(call_completion_queue, server_completion_queue,
99 rpc_event = server_completion_queue.poll()
105 server_completion_queue.poll()
146 server_completion_queue = cygrpc.CompletionQueue()
153 server.register_completion_queue(server_completion_queue)
164 server_completion_queue,
219 server.shutdown(server_completion_queue, _SERVER_SHUTDOWN_TAG)
Dcygrpc_test.py99 self.server_completion_queue = cygrpc.CompletionQueue()
106 self.server.register_completion_queue(self.server_completion_queue)
138 del self.server_completion_queue
185 self.server_completion_queue, self.server_completion_queue,
220 request_event = self.server_completion_queue.poll(deadline=DEADLINE)
256 server_event = self.server_completion_queue.poll(deadline=DEADLINE)
322 self.server.request_call(self.server_completion_queue,
323 self.server_completion_queue,
343 request_event = self.server_completion_queue.poll(deadline=DEADLINE)
348 self.server_completion_queue,
D_common.py98 self.server_completion_queue = cygrpc.CompletionQueue()
100 self.server.register_completion_queue(self.server_completion_queue)
109 self.server_completion_queue)
121 self.server.shutdown(self.server_completion_queue,
D_read_some_but_not_all_responses_test.py114 server_completion_queue = cygrpc.CompletionQueue()
119 server.register_completion_queue(server_completion_queue)
126 server_driver = _ServerDriver(server_completion_queue,
152 server_completion_queue,
226 server.shutdown(server_completion_queue, server_shutdown_tag)
D_no_messages_single_server_completion_queue_test.py34 self.server_completion_queue, self.server_completion_queue,
D_no_messages_server_completion_queue_per_call_test.py39 server_call_completion_queue, self.server_completion_queue,