HomeSort by relevance Sort by last modified time
    Searched refs:server_completion_queue (Results 1 - 6 of 6) sorted by null

  /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
_common.py 98 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,
_cancel_many_calls_test.py 94 def _serve(state, server, server_completion_queue, thread_pool):
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)
cygrpc_test.py 99 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
    [all...]
_read_some_but_not_all_responses_test.py 114 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)
_no_messages_single_server_completion_queue_test.py 34 self.server_completion_queue, self.server_completion_queue,
_no_messages_server_completion_queue_per_call_test.py 39 server_call_completion_queue, self.server_completion_queue,

Completed in 928 milliseconds