/external/dbus/dbus/ |
D | dbus-timeout.c | 68 DBusTimeout *timeout; in _dbus_timeout_new() local 70 timeout = dbus_new0 (DBusTimeout, 1); in _dbus_timeout_new() 71 if (timeout == NULL) in _dbus_timeout_new() 74 timeout->refcount = 1; in _dbus_timeout_new() 75 timeout->interval = interval; in _dbus_timeout_new() 77 timeout->handler = handler; in _dbus_timeout_new() 78 timeout->handler_data = data; in _dbus_timeout_new() 79 timeout->free_handler_data_function = free_data_function; in _dbus_timeout_new() 81 timeout->enabled = TRUE; in _dbus_timeout_new() 83 return timeout; in _dbus_timeout_new() [all …]
|
D | dbus-mainloop.c | 77 DBusTimeout *timeout; member 85 timeout_callback_new (DBusTimeout *timeout) in timeout_callback_new() argument 93 cb->timeout = timeout; in timeout_callback_new() 391 DBusTimeout *timeout) in _dbus_loop_add_timeout() argument 395 tcb = timeout_callback_new (timeout); in _dbus_loop_add_timeout() 415 DBusTimeout *timeout) in _dbus_loop_remove_timeout() argument 425 if (this->timeout == timeout) in _dbus_loop_remove_timeout() 438 _dbus_warn ("could not find timeout %p to remove\n", timeout); in _dbus_loop_remove_timeout() 448 int *timeout) in check_timeout() argument 460 interval = dbus_timeout_get_interval (tcb->timeout); in check_timeout() [all …]
|
/external/okhttp/okio/okio/src/test/java/okio/ |
D | AsyncTimeoutTest.java | 44 a.timeout( 250, TimeUnit.MILLISECONDS); in setUp() 45 b.timeout( 500, TimeUnit.MILLISECONDS); in setUp() 46 c.timeout( 750, TimeUnit.MILLISECONDS); in setUp() 47 d.timeout(1000, TimeUnit.MILLISECONDS); in setUp() 51 AsyncTimeout timeout = new RecordingAsyncTimeout(); in zeroTimeoutIsNoTimeout() local 52 timeout.timeout(0, TimeUnit.MILLISECONDS); in zeroTimeoutIsNoTimeout() 53 timeout.enter(); in zeroTimeoutIsNoTimeout() 55 assertFalse(timeout.exit()); in zeroTimeoutIsNoTimeout() 135 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineOnly() local 136 timeout.deadline(250, TimeUnit.MILLISECONDS); in deadlineOnly() [all …]
|
/external/chromium-trace/catapult/devil/devil/android/sdk/ |
D | adb_wrapper.py | 76 raw_version = AdbWrapper._RunAdbCmd(['version'], timeout=2, retries=0) 241 def _RunAdbCmd(cls, args, timeout=None, retries=None, device_serial=None, argument 265 def _RunDeviceAdbCmd(self, args, timeout, retries, check_error=True): argument 278 return self._RunAdbCmd(args, timeout=timeout, retries=retries, 282 def _IterRunDeviceAdbCmd(self, args, timeout): argument 293 self._BuildAdbCmd(args, self._device_serial), timeout=timeout) 327 def KillServer(cls, timeout=DEFAULT_TIMEOUT, retries=DEFAULT_RETRIES): argument 328 cls._RunAdbCmd(['kill-server'], timeout=timeout, retries=retries) 331 def StartServer(cls, timeout=DEFAULT_TIMEOUT, retries=DEFAULT_RETRIES): argument 333 cls._RunAdbCmd(['start-server'], timeout=timeout, retries=retries, [all …]
|
/external/chromium-trace/catapult/telemetry/telemetry/internal/browser/ |
D | web_contents.py | 61 timeout=DEFAULT_WEB_CONTENTS_TIMEOUT): argument 70 'document.readyState == "complete"', timeout) 73 timeout=DEFAULT_WEB_CONTENTS_TIMEOUT): argument 82 'document.readyState == "complete"', timeout) 85 timeout=DEFAULT_WEB_CONTENTS_TIMEOUT): argument 98 timeout) 100 def WaitForJavaScriptExpression(self, expr, timeout): argument 123 util.WaitFor(IsJavaScriptExpressionTrue, timeout) 158 def ExecuteJavaScript(self, statement, timeout=DEFAULT_WEB_CONTENTS_TIMEOUT): argument 168 statement, context_id=None, timeout=timeout) [all …]
|
/external/wpa_supplicant_8/src/utils/ |
D | eloop_win.c | 55 struct dl_list timeout; member 78 dl_list_init(&eloop.timeout); in eloop_init() 241 struct eloop_timeout *timeout, *tmp; in eloop_register_timeout() local 244 timeout = os_zalloc(sizeof(*timeout)); in eloop_register_timeout() 245 if (timeout == NULL) in eloop_register_timeout() 247 if (os_get_reltime(&timeout->time) < 0) { in eloop_register_timeout() 248 os_free(timeout); in eloop_register_timeout() 251 now_sec = timeout->time.sec; in eloop_register_timeout() 252 timeout->time.sec += secs; in eloop_register_timeout() 253 if (timeout->time.sec < now_sec) { in eloop_register_timeout() [all …]
|
D | eloop.c | 105 struct dl_list timeout; member 164 dl_list_init(&eloop.timeout); in eloop_init() 766 struct eloop_timeout *timeout, *tmp; in eloop_register_timeout() local 769 timeout = os_zalloc(sizeof(*timeout)); in eloop_register_timeout() 770 if (timeout == NULL) in eloop_register_timeout() 772 if (os_get_reltime(&timeout->time) < 0) { in eloop_register_timeout() 773 os_free(timeout); in eloop_register_timeout() 776 now_sec = timeout->time.sec; in eloop_register_timeout() 777 timeout->time.sec += secs; in eloop_register_timeout() 778 if (timeout->time.sec < now_sec) { in eloop_register_timeout() [all …]
|
/external/chromium-trace/catapult/telemetry/telemetry/internal/backends/chrome_inspector/ |
D | inspector_page.py | 16 def __init__(self, inspector_websocket, timeout): argument 26 self._EnablePageNotifications(timeout=timeout) 49 def _SetScriptToEvaluateOnCommit(self, source, timeout): argument 61 self._inspector_websocket.SyncRequest(request, timeout) 70 res = self._inspector_websocket.SyncRequest(request, timeout) 76 def _EnablePageNotifications(self, timeout=60): argument 80 res = self._inspector_websocket.SyncRequest(request, timeout) 83 def WaitForNavigate(self, timeout=60): argument 90 remaining_time = timeout 93 remaining_time = max(timeout - (time.time() - start_time), 0.0) [all …]
|
D | inspector_backend.py | 51 def __init__(self, app, devtools_client, context, timeout=120): argument 66 self._websocket.Connect(self.debugger_url, timeout) 70 self._websocket, timeout=timeout) 142 def Screenshot(self, timeout): argument 144 return self._page.CaptureScreenshot(timeout) 149 def GetDOMStats(self, timeout): argument 157 dom_counters = self._memory.GetDOMCounters(timeout) 167 def WaitForNavigate(self, timeout): argument 168 self._page.WaitForNavigate(timeout) 171 def Navigate(self, url, script_to_evaluate_on_commit, timeout): argument [all …]
|
D | devtools_http.py | 38 def _Connect(self, timeout): argument 43 self._conn = httplib.HTTPConnection(host_port, timeout=timeout) 59 def Request(self, path, timeout=30): argument 72 assert timeout 75 self._Connect(timeout) 81 self._conn.sock.settimeout(timeout) 83 self._conn.timeout = timeout 96 def RequestJson(self, path, timeout=30): argument 107 return json.loads(self.Request(path, timeout))
|
D | inspector_websocket.py | 56 def Connect(self, url, timeout): argument 64 self._socket = websocket.create_connection(url, timeout=timeout) 99 def SyncRequest(self, req, timeout): argument 110 res = self._Receive(timeout) 126 def DispatchNotifications(self, timeout): argument 134 self._Receive(timeout) 136 def _SetTimeout(self, timeout): argument 137 if self._cur_socket_timeout != timeout: 138 self._socket.settimeout(timeout) 139 self._cur_socket_timeout = timeout [all …]
|
/external/avahi/avahi-common/ |
D | dbus-watch-glue.c | 223 static void update_timeout(TimeoutData *timeout) { in update_timeout() argument 224 assert(timeout); in update_timeout() 225 assert(timeout->ref >= 1); in update_timeout() 227 if (dbus_timeout_get_enabled(timeout->dbus_timeout)) { in update_timeout() 229 avahi_elapse_time(&tv, dbus_timeout_get_interval(timeout->dbus_timeout), 0); in update_timeout() 230 timeout->poll_api->timeout_update(timeout-> in update_timeout() 233 timeout->poll_api->timeout_update(timeout->avahi_timeout, NULL); in update_timeout() 238 TimeoutData *timeout = userdata; in timeout_callback() local 241 assert(timeout); in timeout_callback() 243 timeout_data_ref(timeout); in timeout_callback() [all …]
|
/external/webrtc/webrtc/base/ |
D | gunit.h | 23 #define WAIT(ex, timeout) \ argument 24 for (uint32_t start = rtc::Time(); !(ex) && rtc::Time() < start + timeout;) \ 30 #define WAIT_(ex, timeout, res) \ argument 34 while (!res && rtc::Time() < start + timeout) { \ 41 #define EXPECT_TRUE_WAIT(ex, timeout) \ argument 44 WAIT_(ex, timeout, res); \ 48 #define EXPECT_EQ_WAIT(v1, v2, timeout) \ argument 51 WAIT_(v1 == v2, timeout, res); \ 55 #define ASSERT_TRUE_WAIT(ex, timeout) \ argument 58 WAIT_(ex, timeout, res); \ [all …]
|
/external/autotest/client/virt/ |
D | rss_client.py | 83 def __init__(self, address, port, log_func=None, timeout=20): argument 95 self._socket.settimeout(timeout) 102 if self._receive_msg(timeout) != RSS_MAGIC: 125 def _send(self, str, timeout=60): argument 127 if timeout <= 0: 128 raise socket.timeout 129 self._socket.settimeout(timeout) 131 except socket.timeout: 138 def _receive(self, size, timeout=60): argument 140 end_time = time.time() + timeout [all …]
|
/external/autotest/client/cros/ |
D | login.py | 36 def wait_for_condition(condition, timeout_msg, timeout, process, crash_msg): argument 61 timeout=timeout) 71 def wait_for_browser(timeout=cros_ui.RESTART_UI_TIMEOUT): argument 81 timeout=timeout, 86 def wait_for_browser_exit(crash_msg, timeout=cros_ui.RESTART_UI_TIMEOUT): argument 100 timeout=timeout, 108 def wait_for_cryptohome(user, timeout=cros_ui.RESTART_UI_TIMEOUT): argument 119 timeout=timeout, 124 def wait_for_ownership(timeout=constants.DEFAULT_OWNERSHIP_TIMEOUT): argument 136 timeout=timeout,
|
/external/chromium-trace/catapult/devil/devil/android/ |
D | decorators_test.py | 31 def alwaysTimesOut(timeout=None, retries=None): argument 37 alwaysTimesOut(timeout=1, retries=0) 47 def alwaysRaisesCommandFailedError(timeout=None, retries=None): argument 52 alwaysRaisesCommandFailedError(timeout=30, retries=10) 58 def requiresExplicitTimeoutAndRetries(timeout=None, retries=None): argument 59 return (timeout, retries) 64 requiresExplicitTimeoutAndRetries(timeout=10) 70 requiresExplicitTimeoutAndRetries(timeout=expected_timeout, 78 def alwaysRaisesProvidedException(exception, timeout=None, retries=None): argument 85 timeout=10, retries=1) [all …]
|
/external/autotest/server/hosts/ |
D | sonic_host.py | 47 def check_host(host, timeout=10): argument 60 result = host.run('getprop ro.product.device', timeout=timeout) 110 def get_boot_id(self, timeout=60): argument 120 return self.run(cmd, timeout=timeout).stdout.strip() 131 def ssh_ping(self, timeout=60, base_cmd=''): argument 142 super(SonicHost, self).ssh_ping(timeout=timeout, 175 timeout = timeout_mins * 60 177 lambda: self.run(cmd, timeout=timeout/10), 178 timeout=timeout, sleep_interval=timeout/10) 187 def reboot(self, timeout=5): argument [all …]
|
/external/okhttp/okio/okio/src/main/java/okio/ |
D | Okio.java | 65 private static Sink sink(final OutputStream out, final Timeout timeout) { in sink() argument 67 if (timeout == null) throw new IllegalArgumentException("timeout == null"); in sink() 73 timeout.throwIfReached(); in sink() 97 @Override public Timeout timeout() { in sink() method in Okio 98 return timeout; in sink() 114 AsyncTimeout timeout = timeout(socket); 115 Sink sink = sink(socket.getOutputStream(), timeout); 116 return timeout.sink(sink); 124 private static Source source(final InputStream in, final Timeout timeout) { 126 if (timeout == null) throw new IllegalArgumentException("timeout == null"); [all …]
|
/external/autotest/client/tests/barriertest/ |
D | barriertest.py | 12 def run_once(self, our_addr, hostnames, master, timeout=120): argument 17 self.job.barrier(our_addr, 'First', timeout=timeout, 23 self.job.barrier(our_addr, 'Second', timeout=timeout, 31 self.job.barrier(our_addr, 'WillAbort', timeout=timeout, 47 self.job.barrier(our_addr, 'FinalSync', timeout=timeout, 55 self.job.barrier(our_addr, 'WillAbortServers', timeout=timeout,
|
/external/guava/guava/src/com/google/common/collect/ |
D | ForwardingBlockingDeque.java | 65 public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerFirst() argument 66 return delegate().offerFirst(e, timeout, unit); in offerFirst() 70 public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerLast() argument 71 return delegate().offerLast(e, timeout, unit); in offerLast() 85 public E pollFirst(long timeout, TimeUnit unit) throws InterruptedException { in pollFirst() argument 86 return delegate().pollFirst(timeout, unit); in pollFirst() 90 public E pollLast(long timeout, TimeUnit unit) throws InterruptedException { in pollLast() argument 91 return delegate().pollLast(timeout, unit); in pollLast() 100 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { in offer() argument 101 return delegate().offer(e, timeout, unit); in offer() [all …]
|
/external/autotest/client/common_lib/cros/graphite/ |
D | autotest_es.py | 97 timeout=DEFAULT_TIMEOUT, index=INDEX_METADATA, udp_port=ES_UDP_PORT, argument 105 timeout=timeout, index=index, udp_port=udp_port) 110 timeout=DEFAULT_TIMEOUT, index=INDEX_METADATA, argument 119 timeout=timeout, index=index, 129 timeout=DEFAULT_TIMEOUT, index=INDEX_METADATA, argument 137 timeout=timeout, index=index, udp_port=0) 141 def query(host=METADATA_ES_SERVER, port=ES_PORT, timeout=DEFAULT_TIMEOUT, argument 149 timeout=timeout, index=index, udp_port=0)
|
/external/autotest/client/tests/kvm/tests/ |
D | hdparm.py | 18 def check_setting_result(set_cmd, timeout): argument 23 (s, output) = session.cmd_status_output(cmd, timeout) 32 def perform_read_timing(disk, timeout, num=5): argument 36 (s, output) = session.cmd_status_output(cmd, timeout) 54 session = vm.wait_for_login(timeout=int(params.get("login_timeout", 360))) 56 timeout = float(params.get("cmd_timeout", 60)) 63 session.cmd(cmd, timeout) 67 check_setting_result(cmd, timeout) 68 low_result = perform_read_timing(disk, timeout) 74 session.cmd(cmd, timeout) [all …]
|
/external/dbus/bus/ |
D | expirelist.c | 34 DBusTimeout *timeout; member 60 list->timeout = _dbus_timeout_new (100, /* irrelevant */ in bus_expire_list_new() 63 if (list->timeout == NULL) in bus_expire_list_new() 66 _dbus_timeout_set_enabled (list->timeout, FALSE); in bus_expire_list_new() 68 if (!_dbus_loop_add_timeout (list->loop, list->timeout)) in bus_expire_list_new() 74 if (list->timeout) in bus_expire_list_new() 75 _dbus_timeout_unref (list->timeout); in bus_expire_list_new() 87 _dbus_loop_remove_timeout (list->loop, list->timeout); in bus_expire_list_free() 89 _dbus_timeout_unref (list->timeout); in bus_expire_list_free() 95 bus_expire_timeout_set_interval (DBusTimeout *timeout, in bus_expire_timeout_set_interval() argument [all …]
|
/external/ksoap2/ksoap2-base/src/main/java/org/ksoap2/transport/ |
D | Transport.java | 49 protected int timeout = ServiceConnection.DEFAULT_TIMEOUT; field in Transport 71 public Transport(String url, int timeout) { in Transport() argument 73 this.timeout = timeout; in Transport() 76 public Transport(String url, int timeout, int bufferLength) { in Transport() argument 78 this.timeout = timeout; in Transport() 95 public Transport(Proxy proxy, String url, int timeout) { in Transport() argument 98 this.timeout = timeout; in Transport() 101 public Transport(Proxy proxy, String url, int timeout, int bufferLength) { in Transport() argument 104 this.timeout = timeout; in Transport()
|
/external/chromium-trace/catapult/systrace/systrace/ |
D | tracing_controller.py | 42 def StartAgentTracing(self, config, timeout=None): argument 61 def StopAgentTracing(self, timeout=None): argument 71 def GetResults(self, timeout=None): argument 136 timeout=self._controller_config.timeout): 146 timeout=self._controller_config.timeout): 177 if agent.StopAgentTracing(timeout=self._controller_config.timeout): 185 timeout=self._controller_config.timeout): 201 timeout=self._controller_config.collection_timeout) 273 link_assets, asset_dir, timeout, collection_timeout, argument 282 self.timeout = timeout [all …]
|