/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() function 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 …]
|