/tools/acloud/internal/lib/ |
D | ssh.py | 36 def _SshCallWait(cmd, timeout=None): argument 53 if timeout: 55 timer = threading.Timer(timeout, process.kill) 58 if timeout: 63 def _SshCall(cmd, timeout=None): argument 80 if timeout: 82 timer = threading.Timer(timeout, process.kill) 85 if timeout: 90 def _SshLogOutput(cmd, timeout=None, show_output=False): argument 113 if timeout: [all …]
|
/tools/tradefederation/core/src/com/android/tradefed/device/cloud/ |
D | RemoteFileUtil.java | 49 long timeout, in fetchRemoteFile() argument 58 remoteInstance, options, runUtil, timeout, remoteFilePath, localFile)) { in fetchRemoteFile() 84 long timeout, in fetchRemoteFile() argument 92 timeout, in fetchRemoteFile() 114 long timeout, in fetchRemoteDir() argument 122 timeout, in fetchRemoteDir() 143 long timeout, in fetchRemoteDir() argument 154 timeout, in fetchRemoteDir() 185 long timeout, in pushFileToRemote() argument 193 timeout, in pushFileToRemote() [all …]
|
/tools/tradefederation/core/common_util/com/android/tradefed/util/ |
D | RunUtil.java | 145 public CommandResult runTimedCmd(final long timeout, final String... command) { in runTimedCmd() argument 146 return runTimedCmd(timeout, null, null, command); in runTimedCmd() 153 public CommandResult runTimedCmd(final long timeout, OutputStream stdout, in runTimedCmd() argument 156 CommandStatus status = runTimed(timeout, osRunnable, true); in runTimedCmd() 181 long timeout, long retryInterval, int attempts, String... command) { in runTimedCmdRetry() argument 185 result = runTimedCmd(timeout, command); in runTimedCmdRetry() 244 public CommandResult runTimedCmdWithInput(final long timeout, String input, in runTimedCmdWithInput() argument 246 return runTimedCmdWithInput(timeout, input, ArrayUtil.list(command)); in runTimedCmdWithInput() 253 public CommandResult runTimedCmdWithInput(final long timeout, String input, in runTimedCmdWithInput() argument 256 CommandStatus status = runTimed(timeout, osRunnable, true); in runTimedCmdWithInput() [all …]
|
D | IRunUtil.java | 107 public CommandResult runTimedCmd(final long timeout, final String... command); in runTimedCmd() argument 121 final long timeout, OutputStream stdout, OutputStream stderr, final String... command); in runTimedCmd() argument 133 public CommandResult runTimedCmdRetry(final long timeout, long retryInterval, in runTimedCmdRetry() argument 145 public CommandResult runTimedCmdSilently(final long timeout, final String... command); in runTimedCmdSilently() argument 158 public CommandResult runTimedCmdSilentlyRetry(final long timeout, long retryInterval, in runTimedCmdSilentlyRetry() argument 170 CommandResult runTimedCmdWithInput(long timeout, String input, String... command); in runTimedCmdWithInput() argument 181 CommandResult runTimedCmdWithInput(long timeout, String input, List<String> command); in runTimedCmdWithInput() argument 194 long timeout, @Nullable File inputRedirect, String... command); in runTimedCmdWithInputRedirect() argument 262 public CommandStatus runTimed(long timeout, IRunUtil.IRunnableResult runnable, in runTimed() argument
|
/tools/test/connectivity/acts/framework/acts/controllers/buds_lib/test_actions/ |
D | apollo_acts.py | 89 def wait_for_bluetooth_disconnection(self, timeout=60): argument 105 if (time.time() - ini_time) > timeout: 354 def wait_for_magic_pairing_notification(self, android_act, timeout=60): argument 373 if time.time() - start_time > timeout: 381 def start_magic_pairing(self, android_act, timeout=30, retries=3): argument 384 BISTO_MP_CONNECT_TEXT, timeout=timeout) 387 timeout = 30 392 if time.time() - connect_start_time > timeout: 395 self.logger.info('Timeout(s): %s' % timeout) 429 timeout=DEFAULT_TIMEOUT, argument [all …]
|
/tools/test/connectivity/acts/framework/acts/controllers/ |
D | iperf_client.py | 122 def start(self, ip, iperf_args, tag, timeout=3600, iperf_binary=None): argument 142 def start(self, ip, iperf_args, tag, timeout=3600, iperf_binary=None): argument 188 def start(self, ip, iperf_args, tag, timeout=3600, iperf_binary=None): argument 223 self._ssh_session.exec_command(iperf_cmd, timeout=timeout)) 229 timeout=timeout) 236 except socket.timeout: 269 def start(self, ip, iperf_args, tag, timeout=3600, iperf_binary=None): argument 295 timeout=timeout)
|
D | adb.py | 154 def _exec_cmd(self, cmd, ignore_status=False, timeout=DEFAULT_ADB_TIMEOUT): argument 168 result = job.run(cmd, ignore_status=True, timeout=timeout) 261 def shell(self, command, ignore_status=False, timeout=DEFAULT_ADB_TIMEOUT): argument 266 timeout=timeout) 274 timeout=DEFAULT_ADB_PULL_TIMEOUT): argument 276 'pull', command, ignore_status=ignore_status, timeout=timeout)
|
D | android_device.py | 930 self.adb.wait_for_device(timeout=WAIT_FOR_DEVICE_TIMEOUT) 952 out = self.adb.shell("bugreportz", timeout=BUG_REPORT_TIMEOUT) 961 " > {}".format(full_out_path), timeout=BUG_REPORT_TIMEOUT) 964 self.adb.wait_for_device(timeout=WAIT_FOR_DEVICE_TIMEOUT) 1011 "%s %s" % (device_path, host_path), timeout=PULL_TIMEOUT) 1062 timeout=PULL_TIMEOUT, 1074 timeout=PULL_TIMEOUT, 1100 timeout=PULL_TIMEOUT, 1132 timeout=IPERF_TIMEOUT, argument 1154 timeout=IPERF_TIMEOUT): argument [all …]
|
D | fuchsia_device.py | 288 def reboot(self, timeout=60): argument 317 timeout=FUCHSIA_RECONNECT_AFTER_REBOOT_TIME, 334 if initial_ping_elapsed_time > timeout: 339 timeout=FUCHSIA_RECONNECT_AFTER_REBOOT_TIME). 363 if elapsed_time > timeout: 380 timeout=3600, argument 405 ssh_conn.exec_command(test_cmd, timeout=timeout)) 420 def ping(self, dest_ip, count=3, interval=1000, timeout=1000, size=25): argument 447 (count, interval, timeout, size, dest_ip)) 557 "killall %s" % process_name, timeout=CHANNEL_OPEN_TIMEOUT) [all …]
|
D | arduino_wifi_dongle.py | 314 def ip_address(self, exp_result=True, timeout=READ_TIMEOUT): argument 327 while time.time() < curr_time + timeout: 334 def wifi_status(self, exp_result=True, timeout=READ_TIMEOUT): argument 342 while time.time() < curr_time + timeout: 349 def wifi_scan(self, exp_result=True, timeout=READ_TIMEOUT): argument 364 while time.time() < curr_time + timeout: 379 def ping_status(self, exp_result=True, timeout=READ_TIMEOUT): argument 387 while time.time() < curr_time + timeout:
|
D | fastboot.py | 60 timeout=60): argument 65 timeout=timeout) 67 result = job.run(command, ignore_status=True, timeout=timeout)
|
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
D | event_dispatcher.py | 84 event_obj = self._rpc_client.eventWait(60000, timeout=120) 178 def pop_event(self, event_name, timeout=DEFAULT_TIMEOUT): argument 209 if timeout: 210 return e_queue.get(True, timeout) 212 elif timeout == 0: 219 timeout, event_name)) 224 timeout=DEFAULT_TIMEOUT, argument 251 deadline = time.time() + timeout 278 timeout, event_name)) 280 def pop_events(self, regex_pattern, timeout, freq=1): argument [all …]
|
D | rpc_client.py | 231 def rpc(self, method, *args, timeout=None, retries=3): argument 252 if timeout: 253 connection.set_timeout(timeout) 287 except socket.timeout as err: 292 method, ticket, timeout or SOCKET_TIMEOUT) 301 if timeout:
|
/tools/test/connectivity/acts/framework/acts/controllers/ap_lib/ |
D | hostapd.py | 56 def start(self, config, timeout=60, additional_parameters=None): argument 93 self._wait_for_process(timeout=timeout) 94 self._wait_for_interface(timeout=timeout) 119 def _wait_for_process(self, timeout=60): argument 129 while time.time() - start_time < timeout and not self.is_alive(): 133 def _wait_for_interface(self, timeout=60): argument 142 while time.time() - start_time < timeout:
|
D | dhcp_server.py | 65 def start(self, config, timeout=60): argument 96 self._wait_for_process(timeout=timeout) 97 self._wait_for_server(timeout=timeout) 122 def _wait_for_process(self, timeout=60): argument 132 while time.time() - start_time < timeout and not self.is_alive(): 138 def _wait_for_server(self, timeout=60): argument 147 while time.time() - start_time < timeout:
|
D | radvd.py | 69 def start(self, config, timeout=60): argument 101 self._wait_for_process(timeout=timeout) 126 def _wait_for_process(self, timeout=60): argument 136 while time.time() - start_time < timeout and not self.is_alive():
|
/tools/tradefederation/core/src/com/android/tradefed/util/sl4a/ |
D | Sl4aEventDispatcher.java | 46 public Sl4aEventDispatcher(Sl4aClient client, long timeout) { in Sl4aEventDispatcher() argument 50 mTimeout = timeout; in Sl4aEventDispatcher() 117 public EventSl4aObject popEvent(String name, long timeout) { in popEvent() argument 118 long deadline = System.currentTimeMillis() + timeout; in popEvent() 130 CLog.e("Timeout after waiting %sms for event '%s'", timeout, name); in popEvent() 143 long timeout) { in waitForEvent() argument 144 long deadline = System.currentTimeMillis() + timeout; in waitForEvent() 156 CLog.e("Timeout after waiting %sms for event '%s'", timeout, name); in waitForEvent()
|
/tools/tradefederation/core/src/com/android/tradefed/util/ |
D | DeviceConcurrentUtil.java | 55 public static <T> T joinFuture(String taskDesc, Future<T> task, long timeout) in joinFuture() argument 58 T ret = task.get(timeout, TimeUnit.MILLISECONDS); in joinFuture() 94 public ShellCommandCallable(ITestDevice device, String command, long timeout) { in ShellCommandCallable() argument 97 mTimeout = timeout; in ShellCommandCallable() 106 public ShellCommandCallable<V> setTimeout(long timeout) { in setTimeout() argument 107 mTimeout = timeout; in setTimeout()
|
/tools/test/connectivity/acts/framework/acts/controllers/rohdeschwarz_lib/ |
D | cmw500_cellular_simulator.py | 548 def wait_until_attached(self, timeout=120): argument 556 self.cmw.wait_for_attached_state(timeout=timeout) 562 def wait_until_communication_state(self, timeout=120): argument 570 self.cmw.wait_for_rrc_state(cmw500.LTE_CONN_RESP, timeout=timeout) 576 def wait_until_idle_state(self, timeout=120): argument 584 self.cmw.wait_for_rrc_state(cmw500.LTE_IDLE_RESP, timeout=timeout)
|
/tools/test/connectivity/acts/framework/acts/test_utils/abstract_devices/ |
D | wlan_device.py | 138 def ping(self, dest_ip, count=3, interval=1000, timeout=1000, size=25): argument 222 def ping(self, dest_ip, count=3, interval=1000, timeout=1000, size=25): argument 226 timeout=timeout) 295 def ping(self, dest_ip, count=3, interval=1000, timeout=1000, size=25): argument 299 timeout=timeout,
|
/tools/tradefederation/core/test_framework/com/android/tradefed/targetprep/ |
D | InstrumentationPreparer.java | 188 void setTimeout(int timeout) { in setTimeout() argument 189 setShellTimeout(timeout); in setTimeout() 192 void setShellTimeout(long timeout) { in setShellTimeout() argument 193 mShellTimeout = timeout; in setShellTimeout() 196 void setTestTimeout(int timeout) { in setTestTimeout() argument 197 mTestTimeout = timeout; in setTestTimeout()
|
/tools/test/connectivity/acts/framework/acts/test_utils/tel/ |
D | tel_test_utils.py | 951 timeout=MAX_WAIT_TIME_AIRPLANEMODE_EVENT, 1040 timeout=wait_time, 1075 timeout=MAX_WAIT_TIME_CALLEE_RINGING, argument 1096 end_time = time.time() + timeout 1141 timeout=MAX_WAIT_TIME_ACCEPT_CALL_TO_OFFHOOK_EVENT, argument 1160 end_time = time.time() + timeout 1191 timeout=MAX_WAIT_TIME_ACCEPT_CALL_TO_OFFHOOK_EVENT): argument 1211 timeout=timeout, 1231 timeout=MAX_WAIT_TIME_CALLEE_RINGING, argument 1263 timeout=timeout): [all …]
|
/tools/test/connectivity/acts/framework/acts/controllers/utils_lib/commands/ |
D | shell.py | 44 def run(self, command, timeout=3600): argument 65 return self._runner.run(command_str, timeout=timeout) 190 def kill(self, identifier, timeout=10): argument 212 signal_duration = timeout / len(signal_queue)
|
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/aware/ |
D | aware_test_utils.py | 46 def wait_for_event(ad, event_name, timeout=EVENT_TIMEOUT): argument 60 event = ad.ed.pop_event(event_name, timeout) 68 def wait_for_event_with_keys(ad, event_name, timeout=EVENT_TIMEOUT, argument 92 event = ad.ed.wait_for_event(event_name, filter_callbacks, timeout, 102 def fail_on_event(ad, event_name, timeout=EVENT_TIMEOUT): argument 114 event = ad.ed.pop_event(event_name, timeout) 123 def fail_on_event_with_keys(ad, event_name, timeout=EVENT_TIMEOUT, *keyvalues): argument 145 event = ad.ed.wait_for_event(event_name, filter_callbacks, timeout, 156 def verify_no_more_events(ad, timeout=EVENT_TIMEOUT): argument 165 event = ad.ed.pop_events('.*', timeout, freq=0) [all …]
|
/tools/tradefederation/core/isolation/com/android/tradefed/isolation/ |
D | IsolationRunner.java | 171 public RunnerConfig(int port, String address, int timeout) { in RunnerConfig() argument 184 if (timeout > 0) { in RunnerConfig() 185 mTimeout = timeout; in RunnerConfig() 232 int timeout = -1; in parseFlags() local 241 timeout = Integer.parseInt(timeoutStr); in parseFlags() 244 return new RunnerConfig(port, address, timeout); in parseFlags()
|