| /external/tensorflow/tensorflow/python/data/experimental/service/ |
| D | server_lib.py | 143 self._server = _pywrap_server_lib.TF_DATA_NewDispatchServer(
146 self._server.start()
158 self._server.start()
175 self._server.join()
190 self._server.bound_port())
199 self._server.stop()
210 return "localhost:{0}".format(self._server.bound_port())
214 return self._server.num_workers()
312 self._server = _pywrap_server_lib.TF_DATA_NewWorkerServer(
315 self._server.start()
[all …]
|
| /external/autotest/client/cros/ |
| D | httpd.py | 175 self._server = ThreadedHTTPServer(('', port), FormHandler)
176 self.config_server(self._server, docroot, wait_urls, url_handlers)
180 self._server.docroot = docroot
181 self._server._urls = set()
182 self._server._wait_urls = wait_urls
183 self._server._url_handlers = url_handlers
184 self._server._form_entries = {}
186 target=self._server.serve_forever)
199 self._server._urls.add(url)
219 self._server._wait_urls[url] = (matchParams, e)
[all …]
|
| D | dhcp_test_base.py | 165 self._server = None
168 self._server = None
178 self._server = dhcp_test_server.DhcpTestServer(
180 self._server.start()
181 if not self._server.is_healthy:
193 if self._server is not None:
194 self._server.stop()
221 return self._server
|
| D | dhcpv6_test_base.py | 129 self._server = None
146 self._server = dhcpv6_test_server.Dhcpv6TestServer(
148 self._server.start()
158 if self._server is not None:
159 self._server.stop()
186 return self._server
|
| D | xmlrpc_server.py | 125 self._server = six.moves.xmlrpc_server.SimpleXMLRPCServer(
127 self._server.register_introspection_functions()
133 self._server.timeout = 0.5
154 self._server.register_instance(delegate)
166 self._server.handle_request()
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | source_remote_test.py | 53 cls._server) = grpc_debug_test_server.start_server_on_separate_thread(
65 cls._server.stop_server().wait()
73 self._server.clear_data()
98 tb = self._server.query_op_traceback("a")
100 tb = self._server.query_op_traceback("b")
102 tb = self._server.query_op_traceback("x")
107 self._server.query_origin_stack()[-1])
111 self._server.query_source_file_line(__file__, a_lineno))
116 self._server.query_source_file_line(tf_trace_file_path, 0)
118 self._server.query_call_types())
[all …]
|
| D | session_debug_grpc_test.py | 103 cls._server) = grpc_debug_test_server.start_server_on_separate_thread()
108 cls._server.stop_server().wait()
260 self._server.request_watch("u/read", 0, "DebugIdentity")
268 self.assertTrue(self._server.query_op_traceback("u"))
269 self.assertTrue(self._server.query_op_traceback("u/read"))
270 self.assertTrue(self._server.query_op_traceback("v"))
271 self.assertTrue(self._server.query_op_traceback("v/read"))
272 self.assertTrue(self._server.query_op_traceback("w"))
279 first_line, self._server.query_source_file_line(__file__, 1))
281 self._server.clear_data()
[all …]
|
| /external/parameter-framework/upstream/remote-processor/ |
| D | BackgroundRemoteProcessorServer.cpp | 35 : _server(new CRemoteProcessorServer(bindAddress)), mCommandHandler(std::move(commandHandler)) in BackgroundRemoteProcessorServer()
41 if (!_server->start(error)) { in start()
46 _server.get(), std::ref(*mCommandHandler)); in start()
57 _server->stop(); in stop()
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | __init__.py | 15 from grpc_testing._server import _server
19 return _server.server_from_descriptor_to_servicers(descriptors_to_servicers,
|
| D | _server.py | 19 from grpc_testing._server import _handler
20 from grpc_testing._server import _rpc
21 from grpc_testing._server import _server_rpc
22 from grpc_testing._server import _service
23 from grpc_testing._server import _servicer_context
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _not_found_test.py | 27 self._server = implementations.server({})
28 port = self._server.add_insecure_port('[::]:0')
31 self._server.start()
34 self._server.stop(0).wait()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _empty_message_test.py | 90 self._server = test_common.test_server()
91 self._server.add_generic_rpc_handlers((_GenericHandler(),))
92 port = self._server.add_insecure_port('[::]:0')
93 self._server.start()
97 self._server.stop(0)
|
| D | _compression_test.py | 74 self._server = test_common.test_server()
75 self._server.add_generic_rpc_handlers((_GenericHandler(),))
76 self._port = self._server.add_insecure_port('[::]:0')
77 self._server.start()
|
| D | _channel_close_test.py | 99 self._server = test_common.test_server(
101 self._server.add_generic_rpc_handlers((_GENERIC_HANDLER,))
102 self._port = self._server.add_insecure_port('[::]:0')
103 self._server.start()
106 self._server.stop(None)
|
| D | _metadata_test.py | 178 self._server = test_common.test_server()
179 self._server.add_generic_rpc_handlers((_GenericHandler(
181 port = self._server.add_insecure_port('[::]:0')
182 self._server.start()
187 self._server.stop(0)
|
| D | _invocation_defects_test.py | 208 self._server = test_common.test_server()
209 port = self._server.add_insecure_port('[::]:0')
210 self._server.add_generic_rpc_handlers((_GenericHandler(self._handler),))
211 self._server.start()
216 self._server.stop(0)
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/health_check/ |
| D | _health_servicer_test.py | 37 self._server = test_common.test_server()
38 port = self._server.add_insecure_port('[::]:0')
39 health_pb2_grpc.add_HealthServicer_to_server(servicer, self._server)
40 self._server.start()
|
| /external/autotest/client/common_lib/cros/ |
| D | chromedriver.py | 85 self._server = chromedriver_server(CHROMEDRIVER_EXE_PATH,
103 self.driver = webdriver.Remote(command_executor=self._server.url,
123 if hasattr(self, '_server') and self._server:
124 self._server.close()
125 del self._server
|
| /external/autotest/client/site_tests/policy_ProxySettings/ |
| D | policy_ProxySettings.py | 82 self._server = ThreadedProxyServer(server_address, ProxyHandler)
83 self._thread = threading.Thread(target=self._server.serve_forever)
91 self._server.server_close()
96 return self._server.requests_received
100 self._server.requests_received = []
|
| /external/autotest/client/site_tests/network_ProxyResolver/ |
| D | network_ProxyResolver.py | 83 self._server = ThreadedHitServer(server_address, ProxyHandler)
84 self._thread = threading.Thread(target=self._server.serve_forever)
92 self._server.shutdown()
93 self._server.socket.close()
98 return self._server.reset_hits()
104 return self._server.hits()
|
| /external/tensorflow/tensorflow/python/training/ |
| D | server_lib.py | 148 self._server = c_api.TF_NewServer(self._server_def.SerializeToString())
159 c_api.TF_ServerStop(self._server)
169 self._server = None
178 c_api.TF_ServerStart(self._server)
189 c_api.TF_ServerJoin(self._server)
218 return c_api.TF_ServerTarget(self._server)
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/reflection/ |
| D | _reflection_servicer_test.py | 54 self._server = test_common.test_server()
55 reflection.enable_server_reflection(_SERVICE_NAMES, self._server)
56 port = self._server.add_insecure_port('[::]:0')
57 self._server.start()
|
| /external/tensorflow/tensorflow/python/distribute/cluster_resolver/tpu/ |
| D | tpu_cluster_resolver.py | 407 self._server = server_lib.Server({'local': ['0.0.0.0:0']},
412 target = compat.as_bytes(self._server.target)
414 assert len(splits) == 3, self._server.target
415 assert splits[0] == compat.as_bytes('grpc'), self._server.target
|
| /external/autotest/server/cros/servo/ |
| D | pdtester.py | 79 self._server = servod_proxy
101 self._server.set(control_name, value)
110 return self._server.get(control_name)
|
| D | servo.py | 587 def _server(self): member in Servo
635 self._server.hwinit()
668 version = self._server.get_version()
975 return self._server.get_board()
982 return self._server.get_base_board()
1022 self._server.doc(ctrl_name)
1054 return self._server.get(ctrl_name)
1096 self._server.set(ctrl_name, ctrl_value)
1108 return self._server.set_get_all(controls)
1297 servo_type = self._server.get_version()
[all …]
|