| /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/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/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/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/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-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/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); 46 * @param timeout The timeout amount. or no timeout if the value is zero or less. 47 * @return The monitor thread or {@code null} if the timeout amount is not greater than zero. 49 static Thread start(final Duration timeout) { in start() argument 50 return start(Thread.currentThread(), timeout); in start() 57 * @param timeout The timeout amount. or no timeout if the value is zero or less. 58 * @return The monitor thread or {@code null} if the timeout amount is not greater than zero. [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 …]
|
| /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/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/pigweed/pw_i2c/public/pw_i2c/ |
| D | register_device.h | 106 // timeout: timeout that's used for both lock and transaction. 119 chrono::SystemClock::duration timeout); 124 chrono::SystemClock::duration timeout); 129 chrono::SystemClock::duration timeout); 134 chrono::SystemClock::duration timeout); 148 // timeout: Timeout that's used for both lock and transaction. 159 chrono::SystemClock::duration timeout); 163 chrono::SystemClock::duration timeout); 167 chrono::SystemClock::duration timeout); 171 chrono::SystemClock::duration timeout); [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/webrtc/net/dcsctp/timer/ |
| D | task_queue_timeout_test.cc | 50 std::unique_ptr<Timeout> timeout = factory_.CreateTimeout(); in TEST_F() local 51 timeout->Start(DurationMs(1000), TimeoutID(1)); in TEST_F() 61 std::unique_ptr<Timeout> timeout = factory_.CreateTimeout(); in TEST_F() local 62 timeout->Start(DurationMs(1000), TimeoutID(1)); in TEST_F() 67 timeout->Stop(); in TEST_F() 74 std::unique_ptr<Timeout> timeout = factory_.CreateTimeout(); in TEST_F() local 75 timeout->Start(DurationMs(1000), TimeoutID(1)); in TEST_F() 80 timeout->Restart(DurationMs(1000), TimeoutID(2)); in TEST_F() 89 std::unique_ptr<Timeout> timeout = factory_.CreateTimeout(); in TEST_F() local 90 timeout->Start(DurationMs(1000), TimeoutID(1)); in TEST_F() [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 …]
|