/tools/tradefederation/core/tests/src/com/android/tradefed/command/remote/ |
D | RemoteManagerFuncTest.java | 84 int port = mRemoteMgr.getPort(); in testAllocateFree() local 85 assertTrue(port != -1); in testAllocateFree() 86 mRemoteClient = RemoteClient.connect(port); in testAllocateFree() 102 int port = mRemoteMgr.getPort(); in testAddCommand() local 103 assertTrue(port != -1); in testAddCommand() 104 mRemoteClient = RemoteClient.connect(port); in testAddCommand() 120 int port = mRemoteMgr.getPort(); in testAddCommandFile() local 121 assertTrue(port != -1); in testAddCommandFile() 122 mRemoteClient = RemoteClient.connect(port); in testAddCommandFile() 142 int port = mRemoteMgr.getPort(); in testAllocateClose() local [all …]
|
/tools/test/connectivity/acts/framework/acts/controllers/buds_lib/ |
D | logserial.py | 67 for port in self.get_serial_ports(): 68 properties = self.get_port_properties(port=port) 85 ports_result.append(port) 88 def get_port_properties(self, port): argument 98 if port in ports: 100 port_address = ports[port][1] 105 command = 'udevadm info -q property -n {}'.format(port) 154 def port_exists(self, port): argument 163 exists = port in self.get_serial_ports() 169 port, argument [all …]
|
D | b29_lib.py | 98 self.port = b29_port[0] 110 command = '--serial={}'.format(self.port) 170 command = '--serial=%s --debug_spi=dfu --sqif_partition=8' % self.port 192 command = '--serial={} --ping={}'.format(self.port, component) 213 command = '--serial={} --charger_reset'.format(self.port)
|
/tools/test/connectivity/acts/tests/google/wifi/ |
D | WifiRvrTwTest.py | 134 port=serial.Serial(com,9600,timeout=1) 136 return port 138 def getdB(self,port): argument 144 port.write('V?;'.encode()) 145 dB=port.readline().decode() 150 def setdB(self,port,dB): argument 163 port.write(InputdB.encode()) 182 def checkdB(self,port,dB): argument 190 while self.getdB(port)!=dB and retry<10: 192 self.log.info("Current dB = "+str(self.getdB(port))) [all …]
|
D | SetupWifiNetworkTest.py | 31 port = int(self.user_params["socket_port"]) 37 server_address = ('localhost', port) 38 logging.info("Starting server socket on localhost port %s", port) 39 sock.bind(('localhost', port))
|
/tools/test/connectivity/acts/framework/acts/controllers/ |
D | iperf_server.py | 263 def __init__(self, port): argument 264 self._port = port 272 def port(self): member in IPerfServerBase 342 'IPerfServer%s' % self.port) 364 def __init__(self, port=5201): argument 365 super().__init__(port) 366 self._hinted_port = port 372 def port(self): member in IPerfServer 461 port, argument 464 super().__init__(port) [all …]
|
D | arduino_wifi_dongle.py | 132 self.port = self._get_serial_port() 166 for port in serial_ports: 167 if 'USB' not in port: 169 tty_port = '%s%s' % (DEV, port) 194 cmd = arduino + file_path + ' --upload --port ' + self.port 229 cmd = "%s %s --upload --port %s" % (arduino, tmp_file, self.port) 269 ser = Serial(self.port, BAUD_RATE)
|
D | chameleon_controller.py | 73 info = {"address": chameleon.address, "port": chameleon.port} 102 def __init__(self, ip="", port=9992): argument 105 self.port = port 106 self.address = "http://{}:{}".format(ip, self.port)
|
/tools/acloud/internal/lib/ |
D | utils.py | 769 port = tcp_socket.getsockname()[1] 771 return port 774 def CheckPortFree(port): argument 785 tcp_socket.bind(("", port)) 788 "port." % port) 811 def ReleasePort(port): argument 819 subprocess.check_call(_RELEASE_PORT_CMD % port, 844 "local_port":port["local"], 845 "target_port":port["target"]} for port in WEBRTC_PORTS_MAPPING] 993 def LaunchBrowser(ip_addr, port): argument [all …]
|
/tools/tradefederation/core/remote/src/com/android/tradefed/command/remote/ |
D | RemoteClient.java | 55 private RemoteClient(int port) throws UnknownHostException, IOException { in RemoteClient() argument 56 this(InetAddress.getLocalHost().getHostName(), port); in RemoteClient() local 67 private RemoteClient(String hostName, int port) throws UnknownHostException, IOException { in RemoteClient() argument 68 mSocket = new Socket(hostName, port); in RemoteClient() 102 public static IRemoteClient connect(int port) throws RemoteException { in connect() argument 104 return new RemoteClient(port); in connect() 118 public static IRemoteClient connect(String hostname, int port) throws RemoteException { in connect() argument 120 return new RemoteClient(hostname, port); in connect() 182 public void sendStartHandover(int port) throws RemoteException { in sendStartHandover() argument 183 sendOperation(new StartHandoverOp(port)); in sendStartHandover()
|
/tools/test/connectivity/acts_tests/tests/google/net/ |
D | IpSecTest.py | 107 port = random.randint(5000, 6000) 116 self.log.info("Port: %s" % port) 125 fd_a = sutils.open_android_socket(dut_a, domain, sock_type, ip_a, port) 126 fd_b = sutils.open_android_socket(dut_b, domain, sock_type, ip_b, port) 164 dut_a.droid.connectSocket(fd_a, ip_b, port) 170 dut_a, dut_b, fd_a, fd_b, ip_b, port) 194 dut_a, dut_b, fd_a, fd_b, ip_b, port) 228 port = dut_b.droid.getPortOfDatagramSocket(socket_b) 263 dut_a, dut_b, socket_a, socket_b, ip_b, port) 287 dut_a, dut_b, socket_a, socket_b, ip_b, port) [all …]
|
/tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ |
D | host_utils.py | 31 port = _try_bind(0, socket.SOCK_STREAM, socket.IPPROTO_TCP) 33 if port and _try_bind(port, socket.SOCK_DGRAM, socket.IPPROTO_UDP): 34 return port 37 def is_port_available(port): argument 46 return (_try_bind(port, socket.SOCK_STREAM, socket.IPPROTO_TCP) and 47 _try_bind(port, socket.SOCK_DGRAM, socket.IPPROTO_UDP)) 50 def _try_bind(port, socket_type, socket_proto): argument 54 s.bind(('', port))
|
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/ |
D | wifi_retail_ap.py | 459 port=self.ap_settings["port"]) 465 port=self.ap_settings["port"]) 473 port=self.ap_settings["port"]) 716 port=self.ap_settings["port"]) 724 port=self.ap_settings["port"]) 1020 port=self.ap_settings["port"]) 1026 port=self.ap_settings["port"]) 1034 port=self.ap_settings["port"]) 1081 port=self.ap_settings["port"]) 1087 port=self.ap_settings["port"]) [all …]
|
D | rpm_controller_utils.py | 96 port = '%s%s' % (ID, rpm_port) 97 logging.info('Turning %s port: %s' % (state, port)) 98 self.run(RPM_PROMPT, '%s %s' % (state.lower(), port)) 99 result = self.run(RPM_PROMPT, 'status %s' % port) 100 if port not in result: 101 raise RpmControllerError('Port %s doesn\'t exist' % port)
|
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
D | sl4a_manager.py | 155 port = self._get_open_listening_port() 156 if port is None: 160 return port 197 for port in possible_ports: 198 if port not in self._sl4a_ports: 199 self._sl4a_ports.add(port) 200 return int(port) 297 for port in set.union(self._sl4a_ports, ports): 298 self.adb.shell(_SL4A_CLOSE_SERVER_CMD % port)
|
/tools/tradefederation/core/src/com/android/tradefed/device/ |
D | RemoteAndroidDevice.java | 186 public boolean adbTcpConnect(String host, String port) { in adbTcpConnect() argument 188 CommandResult result = adbConnect(host, port); in adbTcpConnect() 197 if(confirmAdbTcpConnect(host, port)) { in adbTcpConnect() 212 private boolean confirmAdbTcpConnect(String host, String port) { in confirmAdbTcpConnect() argument 213 CommandResult resultConfirmation = adbConnect(host, port); in confirmAdbTcpConnect() 234 public boolean adbTcpDisconnect(String host, String port) { in adbTcpDisconnect() argument 237 String.format("%s:%s", host, port)); in adbTcpDisconnect() 286 private CommandResult adbConnect(String host, String port) { in adbConnect() argument 297 String.format("%s:%s", host, port)); in adbConnect()
|
/tools/tradefederation/core/src/com/android/tradefed/command/remote/ |
D | RemoteManager.java | 93 public void setRemoteManagerPort(int port) { in setRemoteManagerPort() argument 94 mRemoteManagerPort = port; in setRemoteManagerPort() 143 protected boolean connect(int port) { in connect() argument 144 mServerSocket = openSocket(port); in connect() 153 private ServerSocket openSocket(int port) { in openSocket() argument 155 return new ServerSocket(port); in openSocket() 330 final int port = c.getPort(); in processStartHandover() local 331 CLog.logAndDisplay(LogLevel.INFO, "Performing handover to remote TF at port %d", port); in processStartHandover() 336 if (!mScheduler.handoverShutdown(port)) { in processStartHandover()
|
/tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ssh/ |
D | settings.py | 30 port = config.get('port', 22) 38 return SshSettings(host, user, port=port, identity_file=identity_file, 62 port=22, argument 72 self.port = port 107 current_flags['-p'] = self.port
|
D | connection.py | 329 def create_ssh_tunnel(self, port, local_port=None): argument 347 if tunnel.remote_port == port: 354 '-L': '%d:localhost:%d' % (local_port, port), 368 local_port, port, tunnel_proc.pid) 369 self._tunnels.append(_Tunnel(local_port, port, tunnel_proc)) 438 port = int(self.run(free_port_cmd).stdout) 441 return port
|
/tools/tradefederation/core/tests/src/com/android/tradefed/util/net/ |
D | HttpHelperFuncTest.java | 52 final int port = backend.getPort(); // FIXME race condition in testTimeout() local 53 if (port <= 0) { in testTimeout() 64 final String url = String.format("http://localhost:%d/", port); in testTimeout() 94 final int port = backend.getPort(); // FIXME race condition in testNoTimeout() local 95 if (port <= 0) { in testNoTimeout() 106 final String url = String.format("http://localhost:%d/", port); in testNoTimeout()
|
/tools/acloud/public/actions/ |
D | common_operations.py | 138 port=constants.DEFAULT_SERIAL_PORT): argument 151 device.instance_name, port, output_file) 153 instance=device.instance_name, port=port) 154 file_name = "%s_serial_%s.log" % (device.instance_name, port) 229 serial_log_file, port=constants.DEFAULT_SERIAL_PORT)
|
/tools/tradefederation/core/isolation/com/android/tradefed/isolation/ |
D | IsolationRunner.java | 171 public RunnerConfig(int port, String address, int timeout) { in RunnerConfig() argument 172 if (port > 0) { in RunnerConfig() 173 mPort = port; in RunnerConfig() 230 int port = -1; in parseFlags() local 238 port = Integer.parseInt(portStr); in parseFlags() 244 return new RunnerConfig(port, address, timeout); in parseFlags()
|
/tools/tradefederation/core/src/com/android/tradefed/util/sl4a/ |
D | Sl4aClient.java | 87 int port = -1; in Sl4aClient() local 91 port = s.getLocalPort(); in Sl4aClient() 97 mHostPort = port; in Sl4aClient() 128 int port = -1; in startSL4A() local 132 port = s.getLocalPort(); in startSL4A() 139 Sl4aClient sl4aClient = new Sl4aClient(device, port, 9998); in startSL4A()
|
/tools/test/connectivity/acts/framework/tests/ |
D | acts_host_utils_test.py | 31 port = test_s.getsockname()[1] 33 self.assertFalse(host_utils.is_port_available(port)) 40 port = test_s.getsockname()[1] 42 self.assertFalse(host_utils.is_port_available(port))
|
/tools/test/connectivity/acts_tests/tests/google/bt/power/ |
D | SetupBTPairingTest.py | 46 port = int(self.user_params["socket_port"]) 52 server_address = ('localhost', port) 53 logging.info("Starting server socket on localhost port %s", port) 54 sock.bind(('localhost', port))
|