/external/junit/src/main/java/org/junit/rules/ |
D | Timeout.java | 10 * The Timeout Rule applies the same timeout to all test methods in a class: 15 * public Timeout globalTimeout = Timeout.millis(20); 29 * Each test is run in a new thread. If the specified timeout elapses before 34 * A specified timeout of 0 will be interpreted as not set, however tests will 40 public class Timeout implements TestRule { class 41 private final long timeout; field in Timeout 54 * Create a {@code Timeout} instance with the timeout specified 59 * Instead use {@link #Timeout(long, java.util.concurrent.TimeUnit)}, 60 * {@link Timeout#millis(long)}, or {@link Timeout#seconds(long)}. 63 * test to run before it should timeout [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() 63 assertEquals("timeout", expected.getMessage()); in timeout() 71 Timeout timeout = new Timeout(); in deadline() local 72 timeout.deadline(1000, TimeUnit.MILLISECONDS); in deadline() [all …]
|
/external/okhttp/okio/okio/src/test/java/okio/ |
D | AsyncTimeoutTest.java | 37 private final List<Timeout> timedOut = new CopyOnWriteArrayList<Timeout>(); 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 [all …]
|
/external/llvm/utils/lit/tests/ |
D | shtest-timeout.py | 3 # Test per test timeout using external shell 5 # RUN: %{inputs}/shtest-timeout/infinite_loop.py \ 6 # RUN: %{inputs}/shtest-timeout/quick_then_slow.py \ 7 # RUN: %{inputs}/shtest-timeout/short.py \ 8 # RUN: %{inputs}/shtest-timeout/slow.py \ 9 # RUN: -j 1 -v --debug --timeout 1 --param external=1 > %t.extsh.out 2> %t.extsh.err 15 # Test per test timeout using internal shell 17 # RUN: %{inputs}/shtest-timeout/infinite_loop.py \ 18 # RUN: %{inputs}/shtest-timeout/quick_then_slow.py \ 19 # RUN: %{inputs}/shtest-timeout/short.py \ [all …]
|
/external/okio/okio/src/jvmTest/kotlin/okio/ |
D | PipeKotlinTest.kt | 30 import org.junit.rules.Timeout as JUnitTimeout 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() [all …]
|
/external/chromium-trace/catapult/devil/docs/ |
D | device_utils.md | 13 timeout: timeout in seconds 17 CommandTimeoutError on timeout. 56 timeout: timeout in seconds 60 CommandTimeoutError on timeout. 82 timeout: timeout in seconds 95 timeout: timeout in seconds 100 CommandTimeoutError on timeout. 124 timeout: timeout in seconds 133 CommandTimeoutError on timeout. 144 timeout: timeout in seconds [all …]
|
D | adb_wrapper.md | 20 timeout: (optional) Timeout per try in seconds. 42 timeout: (optional) Timeout per try in seconds. 77 timeout: (optional) Timeout per try in seconds. 87 timeout: (optional) Timeout per try in seconds. 100 timeout: (optional) Timeout per try in seconds. 110 timeout: (optional) Timeout per try in seconds. 132 timeout: (optional) Timeout per try in seconds. 154 timeout: (optional) Timeout per try in seconds. 174 timeout: (optional) Timeout per try in seconds. 185 timeout: Timeout in seconds. [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: 308 # Use a slightly smaller timeout than remaining time to ensure that we 310 timeout = 0.95 * remaining 312 timeout = None 319 timeout, 327 logger.error('Timeout on adb command: %r', adb_cmd) 348 def _RunDeviceAdbCmd(self, args, timeout, retries, check_error=True): argument [all …]
|
/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-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/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/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
D | Timeout.kt | 18 …* Runs a given suspending [block] of code inside a coroutine with a specified [timeout][timeMillis… in <lambda>() 19 * a [TimeoutCancellationException] if the timeout was exceeded. in <lambda>() 21 …* The code that is executing inside the [block] is cancelled on timeout and the active or next inv… in <lambda>() 24 * The sibling function that does not throw an exception on timeout is [withTimeoutOrNull]. in <lambda>() 25 …* Note that the timeout action can be specified for a [select] invocation with [onTimeout][SelectB… in <lambda>() 27 …* **The timeout event is asynchronous with respect to the code running in the block** and may happ… in <lambda>() 28 …* even right before the return from inside of the timeout [block]. Keep this in mind if you open o… in <lambda>() 31 … [Asynchronous timeout and resources][https://kotlinlang.org/docs/reference/coroutines/cancellatio… in <lambda>() 36 * @param timeMillis timeout time in milliseconds. in <lambda>() 49 …* Runs a given suspending [block] of code inside a coroutine with the specified [timeout] and thro… [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 …]
|
/external/okio/okio/src/jvmMain/kotlin/okio/ |
D | Timeout.kt | 22 actual open class Timeout { class 32 * Wait at most `timeout` time before aborting an operation. Using a per-operation timeout means 35 * If `timeout == 0`, operations will run indefinitely. (Operating system timeouts may still 38 open fun timeout(timeout: Long, unit: TimeUnit): Timeout { in timeout() method in okio.Timeout 39 require(timeout >= 0) { "timeout < 0: $timeout" } in timeout() 40 timeoutNanos = unit.toNanos(timeout) in timeout() 44 /** Returns the timeout in nanoseconds, or `0` for no timeout. */ 65 open fun deadlineNanoTime(deadlineNanoTime: Long): Timeout { in deadlineNanoTime() 72 fun deadline(duration: Long, unit: TimeUnit): Timeout { in deadline() 77 /** Clears the timeout. Operating system timeouts may still apply. */ [all …]
|
/external/chromium-trace/catapult/devil/devil/android/ |
D | decorators_test.py | 26 """Tests that the base decorator handles the timeout logic.""" 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) 55 """Tests that the base decorator requires timeout and retries params.""" 58 def requiresExplicitTimeoutAndRetries(timeout=None, retries=None): argument 59 return (timeout, retries) 64 requiresExplicitTimeoutAndRetries(timeout=10) 70 timeout=expected_timeout, retries=expected_retries)) [all …]
|
D | decorators.py | 5 Function/method decorators that provide timeout and retry logic. 28 """ Wraps a funcion with timeout and retry handling logic. 32 timeout_func: A callable that returns the timeout value. 35 |retries_func| to the wrapped function as 'timeout' and 43 timeout = timeout_func(*args, **kwargs) 46 kwargs['timeout'] = timeout 55 # Don't wrap if there's already an outer timeout thread. 63 impl, timeout, retries, desc=desc, retry_if_func=retry_if_func) 81 'timeout' and 'retries' kwargs must be passed to the function. 88 get_timeout = lambda *a, **kw: kw['timeout'] [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/webrtc/rtc_base/ |
D | gunit.h | 19 // Wait until "ex" is true, or "timeout" expires. 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)) { \ 41 // The typical EXPECT_XXXX and ASSERT_XXXXs, but done until true or a 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); \ [all …]
|
/external/rust/crates/tokio/src/time/ |
D | timeout.rs | 3 //! See [`Timeout`] documentation for more details. 5 //! [`Timeout`]: struct@Timeout 22 /// Cancelling a timeout is done by dropping the future. No additional cleanup 25 /// The original future may be obtained by calling [`Timeout::into_inner`]. This 26 /// consumes the `Timeout`. 30 /// Create a new `Timeout` set to expire in 10 milliseconds. 33 /// use tokio::time::timeout; 42 /// // Wrap the future with a `Timeout` set to expire in 10 milliseconds. 43 /// if let Err(_) = timeout(Duration::from_millis(10), rx).await { 48 pub fn timeout<T>(duration: Duration, future: T) -> Timeout<T> in timeout() function [all …]
|
/external/autotest/client/cros/ |
D | login.py | 40 def wait_for_condition(condition, timeout_msg, timeout, process, crash_msg): argument 43 Poll for |condition| to become true, for |timeout| seconds. If the timeout 49 @param timeout: float number of seconds to poll on |condition|. 54 @raise: TimeoutError if timeout is reached. 65 timeout=timeout) 75 def wait_for_browser(timeout=cros_ui.RESTART_UI_TIMEOUT): argument 78 @param timeout: float number of seconds to wait. 80 @raise: TimeoutError: Chrome didn't start before timeout. 85 timeout=timeout, 90 def wait_for_browser_exit(crash_msg, timeout=cros_ui.RESTART_UI_TIMEOUT): argument [all …]
|
/external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/ |
D | Timeout.java | 31 * This class offers two complementary controls to define a timeout policy. 44 public class Timeout { class 46 * An empty timeout that neither tracks nor detects timeouts. Use this when 50 public static final Timeout NONE = new Timeout() { 51 @Override public Timeout timeout(long timeout, TimeUnit unit) { 55 @Override public Timeout deadlineNanoTime(long deadlineNanoTime) { 71 public Timeout() { in Timeout() method in Timeout 75 * Wait at most {@code timeout} time before aborting an operation. Using a 76 * per-operation timeout means that as long as forward progress is being made, 79 * <p>If {@code timeout == 0}, operations will run indefinitely. (Operating [all …]
|
/external/okhttp/okio/okio/src/main/java/okio/ |
D | Timeout.java | 30 * This class offers two complementary controls to define a timeout policy. 42 public class Timeout { class 44 * An empty timeout that neither tracks nor detects timeouts. Use this when 48 public static final Timeout NONE = new Timeout() { 49 @Override public Timeout timeout(long timeout, TimeUnit unit) { 53 @Override public Timeout deadlineNanoTime(long deadlineNanoTime) { 69 public Timeout() { in Timeout() method in Timeout 73 * Wait at most {@code timeout} time before aborting an operation. Using a 74 * per-operation timeout means that as long as forward progress is being made, 77 * <p>If {@code timeout == 0}, operations will run indefinitely. (Operating [all …]
|
/external/tensorflow/tensorflow/python/ops/ |
D | collective_ops.py | 31 timeout=0): argument 50 timeout: a float. If set to a non zero, set a completion timeout to detect 52 timeout value in seconds. This feature is experimental. 71 timeout_seconds=timeout) 81 timeout=0, argument 99 timeout: a float. If set to a non zero, set a completion timeout to detect 101 timeout value in seconds. This feature is experimental. 119 timeout_seconds=timeout, 128 timeout=0): argument 140 timeout: a float. If set to a non zero, set a completion timeout to detect [all …]
|
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
D | timeout.cpp | 2 #include "rxcpp/operators/rx-timeout.hpp" 6 SCENARIO("should timeout if the source never emits any items", "[timeout][operators]"){ 13 rxcpp::timeout_error ex("timeout has occurred"); 19 WHEN("timeout is set"){ 24 | rxo::timeout(milliseconds(10), so); in __anona46c52f80102() 47 SCENARIO("should not timeout if completed before the specified timeout duration", "[timeout][operat… 59 WHEN("timeout is set"){ 63 return xs.timeout(so, milliseconds(100)); in __anona46c52f80202() 87 SCENARIO("should not timeout if all items are emitted within the specified timeout duration", "[tim… 101 WHEN("timeout is set"){ [all …]
|