| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | AsyncTimeoutTest.kt | 47 a.timeout(250, TimeUnit.MILLISECONDS) in setUp()
48 b.timeout(500, TimeUnit.MILLISECONDS) in setUp()
49 c.timeout(750, TimeUnit.MILLISECONDS) in setUp()
50 d.timeout(1000, TimeUnit.MILLISECONDS) in setUp()
55 val timeout = RecordingAsyncTimeout() in zeroTimeoutIsNoTimeout() constant
56 timeout.timeout(0, TimeUnit.MILLISECONDS) in zeroTimeoutIsNoTimeout()
57 timeout.enter() in zeroTimeoutIsNoTimeout()
59 assertFalse(timeout.exit()) in zeroTimeoutIsNoTimeout()
146 a.timeout(10, TimeUnit.SECONDS) in reEnter()
155 a.timeout(1, TimeUnit.MILLISECONDS) in reEnterAfterTimeout()
[all …]
|
| D | WaitUntilNotifiedTest.kt | 35 private val timeout = factory.newTimeout() constant
46 timeout.timeout(5000, TimeUnit.MILLISECONDS) in notified()
57 timeout.waitUntilNotified(this) in notified()
63 fun timeout() { in timeout() method
65 timeout.timeout(1000, TimeUnit.MILLISECONDS) in timeout()
68 timeout.waitUntilNotified(this) in timeout()
71 assertEquals("timeout", expected.message) in timeout()
80 timeout.deadline(1000, TimeUnit.MILLISECONDS) in deadline()
83 timeout.waitUntilNotified(this) in deadline()
86 assertEquals("timeout", expected.message) in deadline()
[all …]
|
| D | PipeKotlinTest.kt | 29 import org.junit.rules.Timeout as JUnitTimeout
33 val timeout = JUnitTimeout(5, TimeUnit.SECONDS) constant
136 underlying.timeout.timeout(biggerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
137 pipe.sink.timeout().timeout(smallerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
144 assertEquals(biggerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
151 underlying.timeout.timeout(smallerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
152 pipe.sink.timeout().timeout(biggerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
159 assertEquals(smallerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
166 underlying.timeout.timeout(biggerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnFlushingWhenItIsSmaller()
167 pipe.sink.timeout().timeout(smallerTimeoutNanos, TimeUnit.NANOSECONDS) in honorsPipeSinkTimeoutOnFlushingWhenItIsSmaller()
[all …]
|
| D | AwaitSignalTest.kt | 36 private val timeout = factory.newTimeout() constant
49 timeout.timeout(5000, TimeUnit.MILLISECONDS) in <lambda>()
56 timeout.awaitSignal(condition) in <lambda>()
61 fun timeout() = lock.withLock { in <lambda>() method
63 timeout.timeout(1000, TimeUnit.MILLISECONDS) in <lambda>()
66 timeout.awaitSignal(condition) in <lambda>()
69 assertEquals("timeout", expected.message) in <lambda>()
77 timeout.deadline(1000, TimeUnit.MILLISECONDS) in <lambda>()
80 timeout.awaitSignal(condition) in <lambda>()
83 assertEquals("timeout", expected.message) in <lambda>()
[all …]
|
| /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/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/python/python-api-core/google/api_core/gapic_v1/ |
| D | method.py | 17 This is used by gapic clients to provide common error mapping, retry, timeout,
25 from google.api_core import timeout
41 """Sentinel value indicating that a retry or timeout argument was unspecified,
64 """Determines how timeout should be applied to a wrapped method.
67 default_timeout (Optional[Timeout]): The default timeout specified
69 specified_timeout (Optional[Timeout]): The timeout specified at
75 Optional[Timeout]: The timeout to apply to the method or ``None``.
77 # If timeout is specified as a number instead of a Timeout instance,
80 specified_timeout = timeout.ConstantTimeout(specified_timeout)
82 default_timeout = timeout.ConstantTimeout(default_timeout)
[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/python/python-api-core/google/api_core/ |
| D | timeout.py | 15 """Decorators for applying timeout arguments to functions.
18 or exponential timeout argument.
25 def is_thing_ready(timeout=None):
35 timeout_ = timeout.ExponentialTimeout()
45 small timeout (like 1 second). If the resource is available and the request
47 and the request times out, it'll be retried - this time with a larger timeout.
51 matches ``api_method(request, timeout=None, retry=None)``.
65 # timeout calculation.
70 """A decorator that adds a constant timeout argument.
73 ``functools.partial(func, timeout=timeout)``.
[all …]
|
| /external/okio/okio/src/jvmMain/kotlin/okio/ |
| D | Timeout.kt | 27 actual open class Timeout { class
38 * before and after an operation to test if the timeout was canceled during the operation.
43 * Wait at most `timeout` time before aborting an operation. Using a per-operation timeout means
46 * If `timeout == 0`, operations will run indefinitely. (Operating system timeouts may still
49 open fun timeout(timeout: Long, unit: TimeUnit): Timeout { in timeout() method in okio.Timeout
50 require(timeout >= 0) { "timeout < 0: $timeout" } in timeout()
51 timeoutNanos = unit.toNanos(timeout) in timeout()
55 /** Returns the timeout in nanoseconds, or `0` for no timeout. */
76 open fun deadlineNanoTime(deadlineNanoTime: Long): Timeout { in deadlineNanoTime()
83 fun deadline(duration: Long, unit: TimeUnit): Timeout { in deadline()
[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 …]
|
| /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-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/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/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Timeout.kt | 19 …* Runs a given suspending [block] of code inside a coroutine with a specified [timeout][timeMillis… in <lambda>()
20 * a [TimeoutCancellationException] if the timeout was exceeded. in <lambda>()
23 …* The code that is executing inside the [block] is cancelled on timeout and the active or next inv… in <lambda>()
26 * The sibling function that does not throw an exception on timeout is [withTimeoutOrNull]. in <lambda>()
27 …* Note that the timeout action can be specified for a [select] invocation with [onTimeout][SelectB… in <lambda>()
29 …* **The timeout event is asynchronous with respect to the code running in the block** and may happ… in <lambda>()
30 …* even right before the return from inside the timeout [block]. Keep this in mind if you open or a… in <lambda>()
33 … [Asynchronous timeout and resources][https://kotlinlang.org/docs/reference/coroutines/cancellatio… in <lambda>()
38 * @param timeMillis timeout time in milliseconds. in <lambda>()
51 …* 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/apache-commons-io/src/main/java/org/apache/commons/io/ |
| D | ThreadMonitor.java | 22 * Monitors a thread, interrupting it if it reaches the specified timeout.
24 …* This works by sleeping until the specified timeout amount and then interrupting the thread being…
30 * Duration timeout = Duration.ofSeconds(1);
32 * Thread monitor = ThreadMonitor.start(timeout);
45 * @param timeout The timeout amount. or no timeout if the value is zero or less.
46 * @return The monitor thread or {@code null} if the timeout amount is not greater than zero.
48 static Thread start(final Duration timeout) { in start() argument
49 return start(Thread.currentThread(), timeout); in start()
56 * @param timeout The timeout amount. or no timeout if the value is zero or less.
57 * @return The monitor thread or {@code null} if the timeout amount is not greater than zero.
[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 …]
|
| /external/python/cpython3/Lib/asyncio/ |
| D | timeouts.py | 12 "Timeout",
13 "timeout",
27 class Timeout: class
30 Use `timeout()` or `timeout_at()` rather than instantiating this class directly.
34 """Schedule a timeout that will trigger at a given loop time.
36 - If `when` is `None`, the timeout will never trigger.
37 - If `when < loop.time()`, the timeout will trigger on the next
51 """Reschedule the timeout."""
55 f"Cannot change state of {self._state.value} Timeout",
73 """Is timeout expired during execution?"""
[all …]
|
| /external/python/python-api-core/tests/unit/ |
| D | test_timeout.py | 20 from google.api_core import timeout
24 gen = timeout._exponential_timeout_generator(1.0, 60.0, 2.0, deadline=None)
37 gen = timeout._exponential_timeout_generator(1.0, 60.0, 2.0, deadline=30.0)
47 timeout_ = timeout.ConstantTimeout()
51 timeout_ = timeout.ConstantTimeout(42.0)
55 timeout_ = timeout.ConstantTimeout(1)
56 assert str(timeout_) == "<ConstantTimeout timeout=1.0>"
60 timeout_ = timeout.ConstantTimeout(42.0)
65 target.assert_called_once_with(timeout=42.0)
69 timeout_ = timeout.ConstantTimeout(42.0)
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | _client_adaptations.py | 106 def result(self, timeout=None): argument
108 return self._future.result(timeout=timeout)
116 def exception(self, timeout=None): argument
118 rpc_error_call = self._future.exception(timeout=timeout)
128 def traceback(self, timeout=None): argument
130 return self._future.traceback(timeout=timeout)
188 timeout, argument
207 timeout=timeout,
215 timeout=timeout,
227 timeout, argument
[all …]
|
| /external/webrtc/rtc_base/ |
| D | gunit.h | 20 // Wait until "ex" is true, or "timeout" expires.
21 #define WAIT(ex, timeout) \ argument
23 !(ex) && rtc::SystemTimeMillis() < start + (timeout);) { \
31 #define WAIT_(ex, timeout, res) \ argument
35 while (!res && rtc::SystemTimeMillis() < start + (timeout)) { \
42 // The typical EXPECT_XXXX and ASSERT_XXXXs, but done until true or a timeout.
44 #define EXPECT_TRUE_WAIT(ex, timeout) \ argument
47 WAIT_(ex, timeout, res); \
53 #define EXPECT_EQ_WAIT(v1, v2, timeout) \ argument
56 WAIT_(v1 == v2, timeout, res); \
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | timeout_encoding.cc | 49 Timeout Timeout::FromDuration(Duration duration) { in FromDuration()
50 return Timeout::FromMillis(duration.millis()); in FromDuration()
53 double Timeout::RatioVersus(Timeout other) const { in RatioVersus()
64 Duration Timeout::AsDuration() const { in AsDuration()
93 Slice Timeout::Encode() const { in Encode()
167 Timeout Timeout::FromMillis(int64_t millis) { in FromMillis()
169 return Timeout(1, Unit::kNanoseconds); in FromMillis()
171 return Timeout(millis, Unit::kMilliseconds); in FromMillis()
174 if (value % 100 != 0) return Timeout(value, Unit::kTenMilliseconds); in FromMillis()
177 if (value % 10 != 0) return Timeout(value, Unit::kHundredMilliseconds); in FromMillis()
[all …]
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | timeout_encoding.cc | 49 Timeout Timeout::FromDuration(Duration duration) { in FromDuration()
50 return Timeout::FromMillis(duration.millis()); in FromDuration()
53 double Timeout::RatioVersus(Timeout other) const { in RatioVersus()
64 Duration Timeout::AsDuration() const { in AsDuration()
93 Slice Timeout::Encode() const { in Encode()
167 Timeout Timeout::FromMillis(int64_t millis) { in FromMillis()
169 return Timeout(1, Unit::kNanoseconds); in FromMillis()
171 return Timeout(millis, Unit::kMilliseconds); in FromMillis()
174 if (value % 100 != 0) return Timeout(value, Unit::kTenMilliseconds); in FromMillis()
177 if (value % 10 != 0) return Timeout(value, Unit::kHundredMilliseconds); in FromMillis()
[all …]
|