| /external/webrtc/rtc_base/ |
| D | gunit.h | 20 #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/ |
| D | WaitUntilNotifiedTest.java | 37 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
|
| D | AsyncTimeoutTest.java | 55 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/ |
| D | AsyncTimeoutTest.java | 51 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/ |
| D | Uninterruptibles.java | 82 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 …]
|
| D | ForwardingBlockingDeque.java | 72 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()
|
| D | TimeLimiter.java | 124 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/ |
| D | decorators_test.py | 30 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 …]
|
| D | device_utils.py | 508 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 …]
|
| D | battery_utils.py | 205 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/ |
| D | adb_wrapper.py | 299 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 …]
|
| D | fastboot.py | 86 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/ |
| D | login.py | 40 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/ |
| D | ForwardingBlockingDeque.java | 72 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()
|
| D | Uninterruptibles.java | 78 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/ |
| D | ForwardingBlockingDeque.java | 74 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/ |
| D | ForwardingBlockingDeque.java | 74 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/ |
| D | collective_ops.py | 31 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.py | 28 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/ |
| D | rx-timeout.hpp | 52 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() argument
78 struct timeout_observer
218 auto operator()(Subscriber dest) const in operator ()()
[all …]
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| D | EventQueueImpl.java | 89 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.py | 93 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/ |
| D | crawl.py | 28 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/ |
| D | standalone_profiler.py | 74 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/ |
| D | face.py | 361 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 …]
|