| /external/strace/tests/ |
| D | rt_sigtimedwait.c | 46 const struct timespec *const timeout, const unsigned long size) in k_sigtimedwait() argument
48 return syscall(__NR_rt_sigtimedwait, set, info, timeout, size); in k_sigtimedwait()
53 const struct timespec *const timeout, unsigned int size) in iterate() argument
56 assert(k_sigtimedwait(set, NULL, timeout, size) == -1); in iterate()
61 (long long) timeout->tv_sec, in iterate()
62 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
69 set, (long long) timeout->tv_sec, in iterate()
70 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
76 text, (long long) timeout->tv_sec, in iterate()
77 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
[all …]
|
| /external/strace/tests-m32/ |
| D | rt_sigtimedwait.c | 46 const struct timespec *const timeout, const unsigned long size) in k_sigtimedwait() argument
48 return syscall(__NR_rt_sigtimedwait, set, info, timeout, size); in k_sigtimedwait()
53 const struct timespec *const timeout, unsigned int size) in iterate() argument
56 assert(k_sigtimedwait(set, NULL, timeout, size) == -1); in iterate()
61 (long long) timeout->tv_sec, in iterate()
62 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
69 set, (long long) timeout->tv_sec, in iterate()
70 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
76 text, (long long) timeout->tv_sec, in iterate()
77 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
[all …]
|
| /external/strace/tests-mx32/ |
| D | rt_sigtimedwait.c | 46 const struct timespec *const timeout, const unsigned long size) in k_sigtimedwait() argument
48 return syscall(__NR_rt_sigtimedwait, set, info, timeout, size); in k_sigtimedwait()
53 const struct timespec *const timeout, unsigned int size) in iterate() argument
56 assert(k_sigtimedwait(set, NULL, timeout, size) == -1); in iterate()
61 (long long) timeout->tv_sec, in iterate()
62 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
69 set, (long long) timeout->tv_sec, in iterate()
70 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
76 text, (long long) timeout->tv_sec, in iterate()
77 zero_extend_signed_to_ull(timeout->tv_nsec), in iterate()
[all …]
|
| /external/okio/okio/src/jvmTest/java/okio/ |
| D | AsyncTimeoutTest.java | 48 a.timeout( 250, TimeUnit.MILLISECONDS); in setUp()
49 b.timeout( 500, TimeUnit.MILLISECONDS); in setUp()
50 c.timeout( 750, TimeUnit.MILLISECONDS); in setUp()
51 d.timeout(1000, TimeUnit.MILLISECONDS); in setUp()
55 AsyncTimeout timeout = new RecordingAsyncTimeout(); in zeroTimeoutIsNoTimeout() local
56 timeout.timeout(0, TimeUnit.MILLISECONDS); in zeroTimeoutIsNoTimeout()
57 timeout.enter(); in zeroTimeoutIsNoTimeout()
59 assertFalse(timeout.exit()); in zeroTimeoutIsNoTimeout()
138 a.timeout(10, SECONDS); in reEnter()
146 a.timeout(1, MILLISECONDS); in reEnterAfterTimeout()
[all …]
|
| D | WaitUntilNotifiedTest.java | 37 Timeout timeout = new Timeout(); in notified() local
38 timeout.timeout(5000, TimeUnit.MILLISECONDS); in notified()
49 timeout.waitUntilNotified(this); in notified()
53 @Test public synchronized void timeout() { in timeout() method in WaitUntilNotifiedTest
56 Timeout timeout = new Timeout(); in timeout() local
57 timeout.timeout(1000, TimeUnit.MILLISECONDS); in timeout()
60 timeout.waitUntilNotified(this); in timeout()
71 Timeout timeout = new Timeout(); in deadline() local
72 timeout.deadline(1000, TimeUnit.MILLISECONDS); in deadline()
75 timeout.waitUntilNotified(this); in deadline()
[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/okio/okio/src/jvmTest/kotlin/okio/ |
| D | PipeKotlinTest.kt | 33 @JvmField @Rule val timeout = JUnitTimeout(5, TimeUnit.SECONDS) constant in okio.PipeKotlinTest
134 underlying.timeout.timeout(biggerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
135 pipe.sink.timeout().timeout(smallerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
142 assertEquals(biggerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
149 underlying.timeout.timeout(smallerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
150 pipe.sink.timeout().timeout(biggerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
157 assertEquals(smallerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
164 underlying.timeout.timeout(biggerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnFlushingWhenItIsSmaller()
165 pipe.sink.timeout().timeout(smallerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnFlushingWhenItIsSmaller()
172 assertEquals(biggerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnFlushingWhenItIsSmaller()
[all …]
|
| /external/chromium-trace/catapult/devil/devil/android/sdk/ |
| D | adb_wrapper.py | 94 raw_version = AdbWrapper._RunAdbCmd(['version'], timeout=2, retries=0)
132 @decorators.WithExplicitTimeoutAndRetries(timeout=60, retries=3)
299 timeout=None, argument
305 if timeout:
310 timeout = 0.95 * remaining
312 timeout = None
319 timeout,
348 def _RunDeviceAdbCmd(self, args, timeout, retries, check_error=True): argument
364 timeout=timeout,
369 def _IterRunDeviceAdbCmd(self, args, iter_timeout, timeout, check_error=True): argument
[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
166 dl_list_init(&eloop.timeout); in eloop_init()
776 struct eloop_timeout *timeout, *tmp; in eloop_register_timeout() local
779 timeout = os_zalloc(sizeof(*timeout)); in eloop_register_timeout()
780 if (timeout == NULL) in eloop_register_timeout()
782 if (os_get_reltime(&timeout->time) < 0) { in eloop_register_timeout()
783 os_free(timeout); in eloop_register_timeout()
786 now_sec = timeout->time.sec; in eloop_register_timeout()
787 timeout->time.sec += secs; in eloop_register_timeout()
788 if (timeout->time.sec < now_sec) { in eloop_register_timeout()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | gunit.h | 20 #define WAIT(ex, timeout) \ argument
22 !(ex) && rtc::SystemTimeMillis() < start + (timeout);) { \
30 #define WAIT_(ex, timeout, res) \ argument
34 while (!res && rtc::SystemTimeMillis() < start + (timeout)) { \
43 #define EXPECT_TRUE_WAIT(ex, timeout) \ argument
46 WAIT_(ex, timeout, res); \
52 #define EXPECT_EQ_WAIT(v1, v2, timeout) \ argument
55 WAIT_(v1 == v2, timeout, res); \
61 #define ASSERT_TRUE_WAIT(ex, timeout) \ argument
64 WAIT_(ex, timeout, res); \
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Uninterruptibles.java | 82 public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout) { in awaitUninterruptibly() argument
83 return awaitUninterruptibly(latch, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in awaitUninterruptibly()
93 public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { in awaitUninterruptibly() argument
96 long remainingNanos = unit.toNanos(timeout); in awaitUninterruptibly()
123 public static boolean awaitUninterruptibly(Condition condition, Duration timeout) { in awaitUninterruptibly() argument
124 return awaitUninterruptibly(condition, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in awaitUninterruptibly()
135 public static boolean awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit) { in awaitUninterruptibly() argument
138 long remainingNanos = unit.toNanos(timeout); in awaitUninterruptibly()
184 public static void joinUninterruptibly(Thread toJoin, Duration timeout) { in joinUninterruptibly() argument
185 joinUninterruptibly(toJoin, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in joinUninterruptibly()
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 93 def result(self, timeout=None): argument
95 return self._future.result(timeout=timeout)
103 def exception(self, timeout=None): argument
105 rpc_error_call = self._future.exception(timeout=timeout)
115 def traceback(self, timeout=None): argument
117 return self._future.traceback(timeout=timeout)
172 def _blocking_unary_unary(channel, group, method, timeout, with_call, argument
184 timeout=timeout,
191 timeout=timeout,
198 def _future_unary_unary(channel, group, method, timeout, protocol_options, argument
[all …]
|
| /external/llvm-project/lldb/unittests/Utility/ |
| D | ListenerTest.cpp | 29 const std::chrono::seconds timeout(0); in TEST() local
31 EXPECT_FALSE(listener_sp->GetEvent(event_sp, timeout)); in TEST()
32 EXPECT_FALSE(listener_sp->GetEventForBroadcaster(nullptr, event_sp, timeout)); in TEST()
34 listener_sp->GetEventForBroadcaster(&broadcaster, event_sp, timeout)); in TEST()
36 &broadcaster, event_mask, event_sp, timeout)); in TEST()
40 EXPECT_TRUE(listener_sp->GetEvent(event_sp, timeout)); in TEST()
43 EXPECT_TRUE(listener_sp->GetEventForBroadcaster(nullptr, event_sp, timeout)); in TEST()
47 listener_sp->GetEventForBroadcaster(&broadcaster, event_sp, timeout)); in TEST()
51 &broadcaster, event_mask * 2, event_sp, timeout)); in TEST()
53 &broadcaster, event_mask, event_sp, timeout)); in TEST()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/firmware/ |
| D | fw_fallback.sh | 30 local timeout=10
33 timeout=$(( $timeout - 1 ))
34 if [ "$timeout" -eq 0 ]; then
57 local timeout=10
60 timeout=$(( $timeout - 1 ))
61 if [ "$timeout" -eq 0 ]; then
86 local timeout=10
89 timeout=$(( $timeout - 1 ))
90 if [ "$timeout" -eq 0 ]; then
119 local timeout=10
[all …]
|
| /external/chromium-trace/catapult/devil/devil/android/ |
| D | decorators_test.py | 30 def alwaysTimesOut(timeout=None, retries=None): argument
36 alwaysTimesOut(timeout=1, retries=0)
46 def alwaysRaisesCommandFailedError(timeout=None, retries=None): argument
51 alwaysRaisesCommandFailedError(timeout=30, retries=10)
58 def requiresExplicitTimeoutAndRetries(timeout=None, retries=None): argument
59 return (timeout, retries)
64 requiresExplicitTimeoutAndRetries(timeout=10)
70 timeout=expected_timeout, retries=expected_retries))
78 def alwaysRaisesProvidedException(exception, timeout=None, retries=None): argument
84 reraiser_thread.TimeoutError(exception_desc), timeout=10, retries=1)
[all …]
|
| /external/adhd/cras/src/server/ |
| D | cras_dbus.c | 81 struct DBusTimeout *timeout = data; in dbus_timeout_callback() local
85 t = cras_tm_create_timer(tm, dbus_timeout_get_interval(timeout), in dbus_timeout_callback()
86 dbus_timeout_callback, timeout); in dbus_timeout_callback()
87 dbus_timeout_set_data(timeout, t, NULL); in dbus_timeout_callback()
89 if (!dbus_timeout_handle(timeout)) in dbus_timeout_callback()
93 static dbus_bool_t dbus_timeout_add(DBusTimeout *timeout, void *arg) in dbus_timeout_add() argument
96 struct cras_timer *t = dbus_timeout_get_data(timeout); in dbus_timeout_add()
99 dbus_timeout_set_data(timeout, NULL, NULL); in dbus_timeout_add()
103 if (dbus_timeout_get_enabled(timeout)) { in dbus_timeout_add()
104 t = cras_tm_create_timer(tm, dbus_timeout_get_interval(timeout), in dbus_timeout_add()
[all …]
|
| /external/autotest/client/cros/ |
| D | login.py | 40 def wait_for_condition(condition, timeout_msg, timeout, process, crash_msg): argument
65 timeout=timeout)
75 def wait_for_browser(timeout=cros_ui.RESTART_UI_TIMEOUT): argument
85 timeout=timeout,
90 def wait_for_browser_exit(crash_msg, timeout=cros_ui.RESTART_UI_TIMEOUT): argument
104 timeout=timeout,
112 def wait_for_cryptohome(user, timeout=cros_ui.RESTART_UI_TIMEOUT): argument
123 timeout=timeout,
128 def wait_for_ownership(timeout=constants.DEFAULT_OWNERSHIP_TIMEOUT): argument
140 timeout=timeout,
|
| /external/autotest/server/cros/tradefed/ |
| D | tradefed_chromelogin.py | 74 def _login_by_script(self, timeout, verbose): argument
80 timeout=timeout)
82 def _login(self, timeout, verbose=False, install_autotest=False): argument
87 self._login_by_script(timeout=timeout, verbose=verbose)
95 'dummy_Pass', timeout=2 * timeout, check_client_result=True)
97 self._login_by_script(timeout=timeout, verbose=verbose)
106 ignore_status=False, timeout=9)
110 timeout = self._timeout
112 logging.info('Ensure Android is running (timeout=%d)...', timeout)
113 self._login(timeout=timeout)
[all …]
|
| /external/arm-trusted-firmware/plat/nvidia/tegra/drivers/bpmp/ |
| D | bpmp.c | 56 int32_t ret = -ETIMEDOUT, timeout = 0; in tegra_bpmp_send_receive_atomic() local
61 for (timeout = 0; timeout < BPMP_TIMEOUT; timeout++) { in tegra_bpmp_send_receive_atomic()
69 if (timeout != BPMP_TIMEOUT) { in tegra_bpmp_send_receive_atomic()
82 for (timeout = 0; timeout < BPMP_TIMEOUT; timeout++) { in tegra_bpmp_send_receive_atomic()
90 if (timeout != BPMP_TIMEOUT) { in tegra_bpmp_send_receive_atomic()
109 if (timeout == BPMP_TIMEOUT) { in tegra_bpmp_send_receive_atomic()
118 uint32_t val, base, timeout = BPMP_TIMEOUT; in tegra_bpmp_init() local
129 timeout--; in tegra_bpmp_init()
132 } while ((val != SIGN_OF_LIFE) && (timeout > 0U)); in tegra_bpmp_init()
202 uint32_t val, timeout = 0; in tegra_bpmp_resume() local
[all …]
|
| /external/python/cpython2/Lib/ |
| D | telnetlib.py | 189 timeout=socket._GLOBAL_DEFAULT_TIMEOUT): argument
199 self.timeout = timeout
211 self.open(host, port, timeout)
213 def open(self, host, port=0, timeout=socket._GLOBAL_DEFAULT_TIMEOUT): argument
226 self.timeout = timeout
227 self.sock = socket.create_connection((host, port), timeout)
285 def read_until(self, match, timeout=None): argument
294 return self._read_until_with_poll(match, timeout)
296 return self._read_until_with_select(match, timeout)
298 def _read_until_with_poll(self, match, timeout): argument
[all …]
|
| /external/libcups/cups/ |
| D | sidechannel.c | 59 double timeout) /* I - Timeout in seconds */ in cupsSideChannelDoRequest() argument
65 if (cupsSideChannelWrite(command, CUPS_SC_STATUS_NONE, NULL, 0, timeout)) in cupsSideChannelDoRequest()
68 if (cupsSideChannelRead(&rcommand, &status, data, datalen, timeout)) in cupsSideChannelDoRequest()
99 double timeout) /* I - Timeout in seconds */ in cupsSideChannelRead() argument
115 datalen, datalen ? *datalen : -1, timeout)); in cupsSideChannelRead()
133 timeout < 0.0 ? -1 : (int)(timeout * 1000))) < 0 && in cupsSideChannelRead()
141 stimeout.tv_sec = (int)timeout; in cupsSideChannelRead()
142 stimeout.tv_usec = (int)(timeout * 1000000) % 1000000; in cupsSideChannelRead()
145 timeout < 0.0 ? NULL : &stimeout)) < 0 && in cupsSideChannelRead()
298 double timeout) /* I - Timeout in seconds */ in cupsSideChannelSNMPGet() argument
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | timeout_encoding.cc | 80 void grpc_http2_encode_timeout(grpc_millis timeout, char* buffer) { in grpc_http2_encode_timeout() argument
82 if (timeout <= 0) { in grpc_http2_encode_timeout()
84 } else if (timeout < 1000 * GPR_MS_PER_SEC) { in grpc_http2_encode_timeout()
85 enc_millis(buffer, timeout); in grpc_http2_encode_timeout()
86 } else if (timeout >= kMaxTimeout) { in grpc_http2_encode_timeout()
90 timeout / GPR_MS_PER_SEC + (timeout % GPR_MS_PER_SEC != 0)); in grpc_http2_encode_timeout()
99 int grpc_http2_decode_timeout(const grpc_slice& text, grpc_millis* timeout) { in grpc_http2_decode_timeout() argument
114 *timeout = GRPC_MILLIS_INF_FUTURE; in grpc_http2_decode_timeout()
128 *timeout = x / GPR_NS_PER_MS + (x % GPR_NS_PER_MS != 0); in grpc_http2_decode_timeout()
131 *timeout = x / GPR_US_PER_MS + (x % GPR_US_PER_MS != 0); in grpc_http2_decode_timeout()
[all …]
|
| /external/adhd/cras/src/tests/ |
| D | file_wait_unittest.cc | 55 struct timespec timeout = {0, 100000000}; in SimpleFileWait() local
82 EXPECT_EQ(1, cras_poll(&poll_fd, 1, &timeout, NULL)); in SimpleFileWait()
101 struct timespec timeout = {0, 100000000}; in TEST() local
158 EXPECT_EQ(1, cras_poll(&poll_fd, 1, &timeout, NULL)); in TEST()
168 timeout.tv_sec = 0; in TEST()
169 timeout.tv_nsec = 100000000; in TEST()
170 EXPECT_EQ(1, cras_poll(&poll_fd, 1, &timeout, NULL)); in TEST()
177 timeout.tv_sec = 0; in TEST()
178 timeout.tv_nsec = 100000000; in TEST()
179 EXPECT_EQ(1, cras_poll(&poll_fd, 1, &timeout, NULL)); in TEST()
[all …]
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _multi_callable.py | 28 def __call__(self, request, timeout=None, metadata=None, credentials=None): argument
31 [request], True, timeout)
34 def with_call(self, request, timeout=None, metadata=None, credentials=None): argument
37 [request], True, timeout)
40 def future(self, request, timeout=None, metadata=None, credentials=None): argument
43 [request], True, timeout)
53 def __call__(self, request, timeout=None, metadata=None, credentials=None): argument
56 [request], True, timeout)
68 timeout=None, argument
73 [], False, timeout)
[all …]
|