Home
last modified time | relevance | path

Searched defs:timeout (Results 1 – 25 of 1650) sorted by relevance

12345678910>>...66

/external/webrtc/rtc_base/
Dgunit.h20 #define WAIT(ex, timeout) \ argument
30 #define WAIT_(ex, timeout, res) \ argument
43 #define EXPECT_TRUE_WAIT(ex, timeout) \ argument
52 #define EXPECT_EQ_WAIT(v1, v2, timeout) \ argument
61 #define ASSERT_TRUE_WAIT(ex, timeout) \ argument
70 #define ASSERT_EQ_WAIT(v1, v2, timeout) \ argument
82 #define EXPECT_TRUE_WAIT_MARGIN(ex, timeout, margin) \ argument
100 #define SIMULATED_WAIT(ex, timeout, clock) \ argument
109 #define SIMULATED_WAIT_(ex, timeout, res, clock) \ argument
120 #define EXPECT_TRUE_SIMULATED_WAIT(ex, timeout, clock) \ argument
[all …]
/external/okio/okio/src/jvmTest/java/okio/
DWaitUntilNotifiedTest.java37 Timeout timeout = new Timeout(); in notified() local
53 @Test public synchronized void timeout() { in timeout() method in WaitUntilNotifiedTest
56 Timeout timeout = new Timeout(); in timeout() local
71 Timeout timeout = new Timeout(); in deadline() local
86 Timeout timeout = new Timeout(); in deadlineBeforeTimeout() local
102 Timeout timeout = new Timeout(); in timeoutBeforeDeadline() local
118 Timeout timeout = new Timeout(); in deadlineAlreadyReached() local
133 Timeout timeout = new Timeout(); in threadInterrupted() local
149 Timeout timeout = new Timeout(); in threadInterruptedOnThrowIfReached() local
DAsyncTimeoutTest.java55 AsyncTimeout timeout = new RecordingAsyncTimeout(); in zeroTimeoutIsNoTimeout() local
155 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineOnly() local
164 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineBeforeTimeout() local
174 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineAfterTimeout() local
184 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineStartsBeforeEnter() local
194 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineInThePast() local
212 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSinkTimesOut() local
233 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSinkFlushTimesOut() local
253 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSinkCloseTimesOut() local
274 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSourceTimesOut() local
[all …]
/external/okhttp/okio/okio/src/test/java/okio/
DAsyncTimeoutTest.java51 AsyncTimeout timeout = new RecordingAsyncTimeout(); in zeroTimeoutIsNoTimeout() local
135 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineOnly() local
144 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineBeforeTimeout() local
154 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineAfterTimeout() local
164 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineStartsBeforeEnter() local
174 RecordingAsyncTimeout timeout = new RecordingAsyncTimeout(); in deadlineInThePast() local
192 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSinkTimesOut() local
213 AsyncTimeout timeout = new AsyncTimeout(); in wrappedSourceTimesOut() local
234 AsyncTimeout timeout = new AsyncTimeout(); in wrappedThrowsWithTimeout() local
252 AsyncTimeout timeout = new AsyncTimeout(); in wrappedThrowsWithoutTimeout() local
/external/guava/guava/src/com/google/common/util/concurrent/
DUninterruptibles.java82 public static boolean awaitUninterruptibly(CountDownLatch latch, Duration timeout) { in awaitUninterruptibly()
93 public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { in awaitUninterruptibly()
123 public static boolean awaitUninterruptibly(Condition condition, Duration timeout) { in awaitUninterruptibly()
135 public static boolean awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit) { in awaitUninterruptibly()
184 public static void joinUninterruptibly(Thread toJoin, Duration timeout) { in joinUninterruptibly()
194 public static void joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit) { in joinUninterruptibly()
274 public static <V> V getUninterruptibly(Future<V> future, Duration timeout) in getUninterruptibly()
300 public static <V> V getUninterruptibly(Future<V> future, long timeout, TimeUnit unit) in getUninterruptibly()
415 public static boolean tryAcquireUninterruptibly(Semaphore semaphore, Duration timeout) { in tryAcquireUninterruptibly()
428 Semaphore semaphore, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly()
[all …]
DForwardingBlockingDeque.java72 public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerFirst()
77 public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerLast()
92 public E pollFirst(long timeout, TimeUnit unit) throws InterruptedException { in pollFirst()
97 public E pollLast(long timeout, TimeUnit unit) throws InterruptedException { in pollLast()
107 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { in offer()
117 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll()
DTimeLimiter.java124 default <T> T newProxy(T target, Class<T> interfaceType, Duration timeout) { in newProxy()
167 default <T> T callWithTimeout(Callable<T> callable, Duration timeout) in callWithTimeout()
216 default <T> T callUninterruptiblyWithTimeout(Callable<T> callable, Duration timeout) in callUninterruptiblyWithTimeout()
255 default void runWithTimeout(Runnable runnable, Duration timeout) in runWithTimeout()
297 default void runUninterruptiblyWithTimeout(Runnable runnable, Duration timeout) in runUninterruptiblyWithTimeout()
/external/chromium-trace/catapult/devil/devil/android/
Ddecorators_test.py30 def alwaysTimesOut(timeout=None, retries=None): argument
46 def alwaysRaisesCommandFailedError(timeout=None, retries=None): argument
58 def requiresExplicitTimeoutAndRetries(timeout=None, retries=None): argument
78 def alwaysRaisesProvidedException(exception, timeout=None, retries=None): argument
94 def alwaysRaisesCommandFailedError(timeout=None, retries=None): argument
109 def alwaysRaisesNoAdbError(timeout=None, retries=None): argument
122 def alwaysTimesOut(timeout=None, retries=None): argument
145 def alwaysRaisesCommandFailedError(timeout=None, retries=None): argument
162 def alwaysReturnsTimeouts(timeout=None, retries=None): argument
169 def alwaysReturnsRetries(timeout=None, retries=None): argument
[all …]
Ddevice_utils.py508 def IsOnline(self, timeout=None, retries=None): argument
528 def HasRoot(self, timeout=None, retries=None): argument
565 def NeedsSU(self, timeout=DEFAULT, retries=DEFAULT): argument
612 def EnableRoot(self, timeout=None, retries=None): argument
650 def IsUserBuild(self, timeout=None, retries=None): argument
668 def GetExternalStoragePath(self, timeout=None, retries=None): argument
692 def GetAppWritablePath(self, timeout=None, retries=None): argument
717 def GetIMEI(self, timeout=None, retries=None): argument
760 self, package, version_code=None, timeout=None, retries=None): argument
805 def GetApplicationPaths(self, package, timeout=None, retries=None): argument
[all …]
Dbattery_utils.py205 def SupportsFuelGauge(self, timeout=None, retries=None): argument
221 def GetFuelGaugeChargeCounter(self, timeout=None, retries=None): argument
243 def GetPowerData(self, timeout=None, retries=None): argument
308 def GetBatteryInfo(self, timeout=None, retries=None): argument
334 def GetCharging(self, timeout=None, retries=None): argument
358 def DisableBatteryUpdates(self, timeout=None, retries=None): argument
384 def EnableBatteryUpdates(self, timeout=None, retries=None): argument
405 def BatteryMeasurement(self, timeout=None, retries=None): argument
536 def SetCharging(self, enabled, timeout=None, retries=None): argument
566 def _HardwareSetCharging(self, enabled, timeout=None, retries=None): argument
[all …]
/external/chromium-trace/catapult/devil/devil/android/sdk/
Dadb_wrapper.py299 timeout=None, argument
348 def _RunDeviceAdbCmd(self, args, timeout, retries, check_error=True): argument
369 def _IterRunDeviceAdbCmd(self, args, iter_timeout, timeout, check_error=True): argument
423 def KillServer(cls, timeout=DEFAULT_TIMEOUT, retries=DEFAULT_RETRIES): argument
429 timeout=DEFAULT_TIMEOUT, argument
449 def GetDevices(cls, timeout=DEFAULT_TIMEOUT, retries=DEFAULT_RETRIES): argument
458 timeout=DEFAULT_TIMEOUT, argument
487 timeout=DEFAULT_TIMEOUT, argument
507 timeout=DEFAULT_SUPER_LONG_TIMEOUT, argument
583 timeout=DEFAULT_LONG_TIMEOUT, argument
[all …]
Dfastboot.py86 def GetVar(self, variable, timeout=None, retries=None): argument
99 def Flash(self, partition, image, timeout=None, retries=None): argument
110 def Devices(cls, timeout=None, retries=None): argument
120 def RebootBootloader(self, timeout=None, retries=None): argument
125 def Reboot(self, timeout=None, retries=None): argument
130 def SetOemOffModeCharge(self, value, timeout=None, retries=None): argument
/external/autotest/client/cros/
Dlogin.py40 def wait_for_condition(condition, timeout_msg, timeout, process, crash_msg): argument
75 def wait_for_browser(timeout=cros_ui.RESTART_UI_TIMEOUT): argument
90 def wait_for_browser_exit(crash_msg, timeout=cros_ui.RESTART_UI_TIMEOUT): argument
112 def wait_for_cryptohome(user, timeout=cros_ui.RESTART_UI_TIMEOUT): argument
128 def wait_for_ownership(timeout=constants.DEFAULT_OWNERSHIP_TIMEOUT): argument
/external/guava/android/guava/src/com/google/common/util/concurrent/
DForwardingBlockingDeque.java72 public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerFirst()
77 public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerLast()
92 public E pollFirst(long timeout, TimeUnit unit) throws InterruptedException { in pollFirst()
97 public E pollLast(long timeout, TimeUnit unit) throws InterruptedException { in pollLast()
107 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { in offer()
117 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll()
DUninterruptibles.java78 public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { in awaitUninterruptibly()
108 public static boolean awaitUninterruptibly(Condition condition, long timeout, TimeUnit unit) { in awaitUninterruptibly()
155 public static void joinUninterruptibly(Thread toJoin, long timeout, TimeUnit unit) { in joinUninterruptibly()
234 public static <V> V getUninterruptibly(Future<V> future, long timeout, TimeUnit unit) in getUninterruptibly()
338 Semaphore semaphore, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly()
351 Semaphore semaphore, int permits, long timeout, TimeUnit unit) { in tryAcquireUninterruptibly()
381 public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) { in tryLockUninterruptibly()
425 ExecutorService executor, long timeout, TimeUnit unit) { in awaitTerminationUninterruptibly()
/external/guava/android/guava/src/com/google/common/collect/
DForwardingBlockingDeque.java74 public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerFirst()
79 public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerLast()
94 public E pollFirst(long timeout, TimeUnit unit) throws InterruptedException { in pollFirst()
99 public E pollLast(long timeout, TimeUnit unit) throws InterruptedException { in pollLast()
109 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { in offer()
119 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll()
/external/guava/guava/src/com/google/common/collect/
DForwardingBlockingDeque.java74 public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerFirst()
79 public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException { in offerLast()
94 public E pollFirst(long timeout, TimeUnit unit) throws InterruptedException { in pollFirst()
99 public E pollLast(long timeout, TimeUnit unit) throws InterruptedException { in pollLast()
109 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { in offer()
119 public E poll(long timeout, TimeUnit unit) throws InterruptedException { in poll()
/external/tensorflow/tensorflow/python/ops/
Dcollective_ops.py31 timeout=0): argument
81 timeout=0, argument
128 timeout=0): argument
167 timeout=0, argument
210 timeout=0): argument
269 timeout=0): argument
304 timeout=0): argument
347 timeout=0): argument
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_multi_callable.py28 def __call__(self, request, timeout=None, metadata=None, credentials=None): argument
34 def with_call(self, request, timeout=None, metadata=None, credentials=None): argument
40 def future(self, request, timeout=None, metadata=None, credentials=None): argument
53 def __call__(self, request, timeout=None, metadata=None, credentials=None): argument
68 timeout=None, argument
79 timeout=None, argument
90 timeout=None, argument
108 timeout=None, argument
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-timeout.hpp52 struct timeout struct
54 typedef rxu::decay_t<T> source_value_type;
55 typedef rxu::decay_t<Coordination> coordination_type;
56 typedef typename coordination_type::coordinator_type coordinator_type;
57 typedef rxu::decay_t<Duration> duration_type;
59 struct timeout_values
70 timeout_values initial;
72 timeout(duration_type period, coordination_type coordination) in timeout() function
78 struct timeout_observer
218 auto operator()(Subscriber dest) const in operator ()()
[all …]
/external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/
DEventQueueImpl.java89 public EventSet remove(long timeout) throws InterruptedException { in remove()
137 private TimerThread startTimerThread(long timeout) { in startTimerThread()
149 private EventSetImpl removeUnfiltered(long timeout) in removeUnfiltered()
218 private long timeout; field in EventQueueImpl.TimerThread
220 TimerThread(long timeout) { in TimerThread()
/external/grpc-grpc/src/python/grpcio/grpc/beta/
D_client_adaptations.py93 def result(self, timeout=None): argument
103 def exception(self, timeout=None): argument
115 def traceback(self, timeout=None): argument
172 def _blocking_unary_unary(channel, group, method, timeout, with_call, argument
198 def _future_unary_unary(channel, group, method, timeout, protocol_options, argument
214 def _unary_stream(channel, group, method, timeout, protocol_options, metadata, argument
230 def _blocking_stream_unary(channel, group, method, timeout, with_call, argument
257 def _future_stream_unary(channel, group, method, timeout, protocol_options, argument
273 def _stream_stream(channel, group, method, timeout, protocol_options, metadata, argument
302 timeout, argument
[all …]
/external/python/futures/
Dcrawl.py28 def load_url(url, timeout): argument
32 def download_urls_sequential(urls, timeout=60): argument
41 def download_urls_with_executor(urls, executor, timeout=60): argument
/external/autotest/server/
Dstandalone_profiler.py74 def wait_for_profilers(machines, timeout=300): argument
80 def start_profilers(machines, timeout=120): argument
86 def stop_profilers(machines, timeout=120): argument
92 def finish_profilers(machines, timeout=120): argument
/external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/
Dface.py361 timeout, argument
387 def future(self, request, timeout, metadata=None, protocol_options=None): argument
411 timeout, argument
437 def __call__(self, request, timeout, metadata=None, protocol_options=None): argument
460 timeout, argument
488 timeout, argument
516 timeout, argument
541 timeout, argument
569 timeout, argument
593 timeout, argument
[all …]

12345678910>>...66