| /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 | 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
|
| 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 …]
|
| /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/ |
| 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()
|
| D | FileIdleMonitor.java | 52 public FileIdleMonitor(Duration timeout, Runnable callback, File... files) { in FileIdleMonitor() argument
53 this(Executors::newSingleThreadScheduledExecutor, timeout, callback, files); in FileIdleMonitor()
59 Duration timeout, in FileIdleMonitor() argument
63 mTimeout = timeout; in FileIdleMonitor()
|
| /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 | fastboot.py | 60 timeout=60): argument
65 timeout=timeout)
67 result = job.run(command, ignore_status=True, 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 | 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 | sniffer.py | 244 def wait_for_capture(self, timeout=None): argument
282 def __init__(self, sniffer, timeout=None): argument
284 self._timeout = timeout
|
| /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/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 …]
|
| /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/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/controllers/attenuator_lib/minicircuits/ |
| D | http.py | 46 def open(self, host, port=80, timeout=2): argument
57 self._timeout = timeout
117 timeout=self._timeout)
143 timeout=self._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/car/ |
| D | car_media_utils.py | 42 def verifyEventReceived(log, device, event, timeout): argument
57 device.ed.pop_event(event, timeout)
70 timeout=1.0): argument
87 return verifyEventReceived(log, toDevice, expctEvent, timeout)
|
| /tools/tradefederation/core/src/com/android/tradefed/device/ |
| D | IWifiHelper.java | 117 boolean waitForIp(long timeout) throws DeviceNotAvailableException; in waitForIp() argument
172 boolean waitForWifiEnabled(long timeout) throws DeviceNotAvailableException; in waitForWifiEnabled() argument
189 boolean waitForWifiDisabled(long timeout) throws DeviceNotAvailableException; in waitForWifiDisabled() argument
|
| /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/test/connectivity/acts/tests/google/bt/power/ |
| D | SetupBTPairingTest.py | 47 timeout = float(self.user_params["socket_timeout_secs"])
55 sock.settimeout(timeout)
60 except socket.timeout:
|
| /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)
|