| /tools/test/connectivity/acts/framework/tests/controllers/ |
| D | iperf_server_test.py | 101 server = IPerfServer('port')
103 full_file_path = server._get_full_file_path()
125 server = IPerfServer('port')
126 server._get_full_file_path = lambda _: MOCK_LOGFILE_PATH
127 server.start()
129 self.assertTrue(server.started)
136 server = IPerfServer('port')
137 server._get_full_file_path = lambda _: MOCK_LOGFILE_PATH
139 server.start()
140 server.stop()
[all …]
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/net/ |
| D | socket_test_utils.py | 58 def listen_accept_android_socket(client, server, client_fd, server_fd, argument
70 server.droid.listenSocket(server_fd)
72 sock = server.droid.acceptSocket(server_fd)
77 def send_recv_data_android_sockets(client, server, client_fd, server_fd, argument
98 recv_msg = server.droid.recvDataOverSocket(server_fd)
99 server.log.info("Received message: %s" % recv_msg)
137 def send_recv_data_datagram_sockets(client, server, client_sock, server_sock, argument
159 recv_msg = server.droid.recvDataOverDatagramSocket(server_sock)
160 server.log.info("Received message: %s" % recv_msg)
171 def _accept_socket(server, server_ip, server_port, server_sock, q): argument
[all …]
|
| /tools/trebuchet/trebuchet/user-switch-analyzer/ |
| D | README.md | 10 `./gradlew :trebuchet:system-server-analyzer:run --args="<trace_file> [-u user_Id] [-o output_filen…
35 com.android.server.policy.PermissionPolicyService 136.691 ms
36 com.android.server.role.RoleManagerService 13.945 ms
37 com.android.server.voiceinteraction.VoiceInteractionManagerService 10.931 ms
38 com.android.server.locksettings.LockSettingsService$Lifecycle 2.052 ms
39 com.android.server.devicepolicy.DevicePolicyManagerService$Lifecycle 1.231 ms
41 com.android.server.om.OverlayManagerService 253.871 ms
42 com.android.server.inputmethod.InputMethodManagerService$Lifecycle 10.970 ms
43 com.android.server.usb.UsbService$Lifecycle 1.021 ms
44 com.android.server.media.MediaSessionService 0.522 ms
[all …]
|
| /tools/netsim/src/core/ |
| D | server.h | 24 namespace netsim::server {
28 GrpcServer(std::unique_ptr<grpc::Server> server, std::uint32_t port) in GrpcServer() argument
29 : server(std::move(server)), port(port) {} in GrpcServer()
31 void Shutdown() const { server->Shutdown(); } in Shutdown()
35 std::unique_ptr<grpc::Server> server;
|
| D | server.cc | 40 namespace netsim::server { namespace
68 std::unique_ptr<grpc::Server> server(builder.BuildAndStart()); in RunGrpcServer() local
69 if (server == nullptr) { in RunGrpcServer()
76 return std::make_pair(std::move(server), in RunGrpcServer()
|
| /tools/treble/hacksaw/bind/ |
| D | remoteserver_test.go | 31 server := NewServer(fakeBinder)
45 if err := server.BindReadOnly(&bindROArgs, &bindROReply); err != nil {
64 if err := server.BindReadWrite(&bindRWArgs, &bindRWReply); err != nil {
72 err = server.List(&listArgs, &listReply)
91 if err := server.Unbind(&unbindArgs, &unbindReply); err != nil {
97 err = server.List(&listArgs, &listReply)
|
| /tools/netsim/rust/daemon/src/grpc_server/ |
| D | server.rs | 32 let mut server = ServerBuilder::new(env) in start() localVariable
38 let port = server.add_listening_port(addr.clone(), ServerCredentials::insecure()).unwrap(); in start()
39 server.start(); in start()
41 (server, port) in start()
|
| D | mod.rs | 17 pub(crate) mod server; module
|
| /tools/netsim/testing/mobly/ |
| D | ble_utils.py | 327 client: android_device.AndroidDevice, server: android_device.AndroidDevice
344 server.server_callback = server.mbs.bleStartServer([SERVICE])
345 start_server_result = server.server_callback.waitAndGet('onServiceAdded', 30)
357 server.log.info('BLE server started')
372 server_event = server.server_callback.waitAndGet('onConnectionStateChange')
386 client: android_device.AndroidDevice, server: android_device.AndroidDevice
408 server.mbs.bleStopServer()
409 server.log.info('BLE server stopped')
503 client: android_device.AndroidDevice, server: android_device.AndroidDevice
524 server_write_operation_result = server.server_callback.waitAndGet(
[all …]
|
| /tools/netsim/rust/daemon/src/ |
| D | rust_main.rs | 130 let mut server: Option<String> = None; in run_netsimd_connector() localVariable
133 server = get_server_address(instance); in run_netsimd_connector()
134 if server.is_some() { in run_netsimd_connector()
141 if server.is_none() { in run_netsimd_connector()
145 let server = server.unwrap(); in run_netsimd_connector() localVariable
147 info!("Starting in Connector mode to {}", server.as_str()); in run_netsimd_connector()
148 crate::transport::fd::run_fd_connector(&fd_startup, server.as_str()) in run_netsimd_connector()
|
| D | service.rs | 19 use crate::http_server::server::run_http_server;
116 let (server, port) = crate::grpc_server::server::start(netsim_grpc_port); in run_grpc_server()
117 self.rust_grpc_server = Some(server); in run_grpc_server()
196 self.rust_grpc_server.as_mut().map(|server| server.shutdown()); in shut_down()
|
| /tools/netsim/src/backend/ |
| D | grpc_client.cc | 67 auto server = std::string(server_rust); in StreamPackets() local
69 server_ = server; in StreamPackets()
70 channel_ = grpc::CreateChannel(server, grpc::InsecureChannelCredentials()); in StreamPackets()
77 } else if (server_ != server) { in StreamPackets()
|
| /tools/netsim/rust/frontend/src/ |
| D | netsim_test_server.rs | 100 let mut server = ServerBuilder::new(env) in main() localVariable
105 let port = server.add_listening_port("127.0.0.1:50051", ServerCredentials::insecure()).unwrap(); in main()
106 server.start(); in main()
116 let _ = block_on(server.shutdown()); in main()
|
| /tools/netsim/rust/frontend/ |
| D | Cargo.toml | 18 ##name = "server"
19 ##path = "src/server.rs"
|
| /tools/tradefederation/core/javatests/com/android/tradefed/monitoring/ |
| D | LabResourceDeviceMonitorTest.java | 94 Server server = in testServerStartAndShutdown() local
103 mMonitor.setServer(server); in testServerStartAndShutdown()
104 server.start(); in testServerStartAndShutdown()
110 Assert.assertTrue("server should be shutdown after monitor stop", server.isShutdown()); in testServerStartAndShutdown()
111 server.awaitTermination(); in testServerStartAndShutdown()
|
| /tools/netsim/ui/ |
| D | web-dev-server.config.mjs | 1 // import { hmrPlugin, presets } from '@open-wc/dev-server-hmr';
6 export default /** @type {import('@web/dev-server').DevServerConfig} */ ({
|
| D | README.md | 11 The netsimd web server must be up and running.
34 Command for running local web development server:
40 Local web server will be served in `http://localhost:8000/web/`
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/abstract_devices/ |
| D | wmm_transceiver.py | 373 for server in self._iperf_servers:
374 server.stop()
552 for server in self._iperf_servers:
553 if self._iperf_servers[server] == AVAILABLE:
554 reserved_server = server
587 server = self._iperf_server_ports[server_port]
588 server.stop()
589 self._iperf_servers[server] = AVAILABLE
|
| /tools/netsim/src/frontend/ |
| D | frontend_client_stub.cc | 39 auto server = "localhost:" + port.value(); in NewFrontendClient() local
41 grpc::CreateChannel(server, grpc::InsecureChannelCredentials()); in NewFrontendClient()
|
| D | frontend_client.cc | 43 std::string server) { in NewFrontendStub() argument
44 if (server == "") { in NewFrontendStub()
48 grpc::CreateChannel(server, grpc::InsecureChannelCredentials()); in NewFrontendStub()
262 std::unique_ptr<FrontendClient> NewFrontendClient(const std::string &server) { in NewFrontendClient() argument
263 auto stub = NewFrontendStub(server); in NewFrontendClient()
|
| /tools/tradefederation/core/global_configuration/com/android/tradefed/config/ |
| D | IGlobalConfiguration.java | 294 public void setTradefedFeatureServer(TradefedFeatureServer server); in setTradefedFeatureServer() argument
297 public void setInvocationServer(TestInvocationManagementServer server); in setInvocationServer() argument
300 public void setDeviceManagementServer(DeviceManagementGrpcServer server); in setDeviceManagementServer() argument
|
| /tools/netsim/rust/cli/src/ |
| D | lib.rs | 189 let server = match (args.vsock, args.port) { in rust_main() localVariable
194 let_cxx_string!(server = server); in rust_main()
195 let client = new_frontend_client(&server); in rust_main()
197 if !server.is_empty() { in rust_main()
|
| /tools/asuite/atest/test_runners/ |
| D | atest_tf_test_runner.py | 386 server = self._start_socket_server()
388 test_infos, extra_args, server.getsockname()[1]
398 partial(self._start_monitor, server, subproc, reporter, extra_args),
400 server.close()
406 def _start_monitor(self, server, tf_subproc, reporter, extra_args): argument
415 inputs = [server]
423 if socket_object is server:
530 server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
531 server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
533 server.bind((SOCKET_HOST, 0))
[all …]
|
| /tools/netsim/rust/daemon/src/http_server/ |
| D | mod.rs | 18 pub(crate) mod server; module
|
| /tools/tradefederation/core/src/com/android/tradefed/command/ |
| D | CommandRunner.java | 248 TradefedFeatureServer server = new TradefedFeatureServer(); in startFeatureSever() local
249 server.start(); in startFeatureSever()
250 GlobalConfiguration.getInstance().setTradefedFeatureServer(server); in startFeatureSever()
|