| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | RateLimiterTest.java | 61 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testImmediateTryAcquire()
62 assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); in testImmediateTryAcquire()
67 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
68 assertFalse("Capable of acquiring an additional permit", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
70 assertFalse("Capable of acquiring an additional permit after sleeping", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
104 limiter.tryAcquire(0); in testAcquireParameterValidation()
109 limiter.tryAcquire(-1); in testAcquireParameterValidation()
114 limiter.tryAcquire(0, 1, SECONDS); in testAcquireParameterValidation()
119 limiter.tryAcquire(-1, 1, SECONDS); in testAcquireParameterValidation()
333 assertTrue(limiter.tryAcquire(0, SECONDS)); in testTryAcquire_noWaitAllowed()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | RateLimiterTest.java | 61 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testImmediateTryAcquire()
62 assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); in testImmediateTryAcquire()
67 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
68 assertFalse("Capable of acquiring an additional permit", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
70 assertFalse("Capable of acquiring an additional permit after sleeping", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
104 limiter.tryAcquire(0); in testAcquireParameterValidation()
109 limiter.tryAcquire(-1); in testAcquireParameterValidation()
114 limiter.tryAcquire(0, 1, SECONDS); in testAcquireParameterValidation()
119 limiter.tryAcquire(-1, 1, SECONDS); in testAcquireParameterValidation()
333 assertTrue(limiter.tryAcquire(0, SECONDS)); in testTryAcquire_noWaitAllowed()
[all …]
|
| D | JSR166TestCase.java | 864 assertTrue(semaphore.tryAcquire(LONG_DELAY_MS, MILLISECONDS));
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | RateLimiter.java | 333 public boolean tryAcquire(Duration timeout) { in tryAcquire() method in RateLimiter
334 return tryAcquire(1, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in tryAcquire()
350 public boolean tryAcquire(long timeout, TimeUnit unit) { in tryAcquire() method in RateLimiter
351 return tryAcquire(1, timeout, unit); in tryAcquire()
364 public boolean tryAcquire(int permits) { in tryAcquire() method in RateLimiter
365 return tryAcquire(permits, 0, MICROSECONDS); in tryAcquire()
377 public boolean tryAcquire() { in tryAcquire() method in RateLimiter
378 return tryAcquire(1, 0, MICROSECONDS); in tryAcquire()
392 public boolean tryAcquire(int permits, Duration timeout) { in tryAcquire() method in RateLimiter
393 return tryAcquire(permits, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); in tryAcquire()
[all …]
|
| D | Uninterruptibles.java | 464 return semaphore.tryAcquire(permits, remainingNanos, NANOSECONDS); in tryAcquireUninterruptibly()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/ |
| D | SemaphoreTest.kt | 52 assertTrue(semaphore.tryAcquire()) in <lambda>()
53 assertTrue(semaphore.tryAcquire()) in <lambda>()
54 assertFalse(semaphore.tryAcquire()) in <lambda>()
58 assertTrue(semaphore.tryAcquire()) in <lambda>()
107 assertFalse(semaphore.tryAcquire()) in <lambda>()
147 assertFalse(semaphore.tryAcquire()) in <lambda>()
150 assertTrue(semaphore.tryAcquire()) in <lambda>()
160 repeat(5) { assertTrue(semaphore.tryAcquire()) } in <lambda>()
161 assertFalse(semaphore.tryAcquire()) in <lambda>()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | RateLimiter.java | 304 public boolean tryAcquire(long timeout, TimeUnit unit) { in tryAcquire() method in RateLimiter
305 return tryAcquire(1, timeout, unit); in tryAcquire()
318 public boolean tryAcquire(int permits) { in tryAcquire() method in RateLimiter
319 return tryAcquire(permits, 0, MICROSECONDS); in tryAcquire()
331 public boolean tryAcquire() { in tryAcquire() method in RateLimiter
332 return tryAcquire(1, 0, MICROSECONDS); in tryAcquire()
347 public boolean tryAcquire(int permits, long timeout, TimeUnit unit) { in tryAcquire() method in RateLimiter
|
| D | Uninterruptibles.java | 360 return semaphore.tryAcquire(permits, remainingNanos, NANOSECONDS); in tryAcquireUninterruptibly()
|
| /external/kotlinx.atomicfu/atomicfu/src/commonTest/kotlin/kotlinx/atomicfu/test/ |
| D | LockTest.kt | 16 if (inProgressLock.tryAcquire()) { in testLock()
25 private inline fun AtomicBoolean.tryAcquire(): Boolean = compareAndSet(false, true) method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | SemaphoreLCStressTest.kt | 17 fun tryAcquire() = semaphore.tryAcquire() method
|
| /external/deqp/framework/platform/android/ |
| D | tcuAndroidWindow.cpp | 57 bool Window::tryAcquire (void) in tryAcquire() function in tcu::Android::Window
177 if (window->tryAcquire()) in tryAcquireWindow()
|
| D | tcuAndroidWindow.hpp | 59 bool tryAcquire (void);
|
| /external/skqp/include/private/ |
| D | SkSpinlock.h | 27 bool tryAcquire() { in tryAcquire() function
|
| /external/skia/include/private/ |
| D | SkSpinlock.h | 28 bool tryAcquire() SK_TRY_ACQUIRE(true) { in tryAcquire() function
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/sync/ |
| D | Semaphore.kt | 54 public fun tryAcquire(): Boolean in <lambda>() method
154 override fun tryAcquire(): Boolean { in tryAcquire() method
|
| /external/replicaisland/src/com/replica/replicaisland/ |
| D | RenderingWatchDog.java | 84 mSemaphore.tryAcquire(mTimeoutInMilliSecs, TimeUnit.MILLISECONDS)); in run()
|
| /external/libchrome/base/android/java/src/org/chromium/base/process_launcher/ |
| D | ChildProcessService.java | 242 if (mActivitySemaphore.tryAcquire()) { in onCreate()
258 if (mActivitySemaphore.tryAcquire()) { in onDestroy()
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| D | IOHandler.java | 180 boolean retval = this.ioSemaphore.tryAcquire(10000, TimeUnit.MILLISECONDS);
253 boolean retval = this.ioSemaphore.tryAcquire(10000, TimeUnit.MILLISECONDS);
|
| D | SIPServerTransaction.java | 1306 boolean acquired = this.provisionalResponseSem.tryAcquire(1,TimeUnit.SECONDS); in sendResponse()
1565 boolean acquired = this.provisionalResponseSem.tryAcquire(1, TimeUnit.SECONDS); in sendReliableProvisionalResponse()
|
| D | SIPTransaction.java | 1140 retval = this.semaphore.tryAcquire(1000, TimeUnit.MILLISECONDS); in acquireSem()
|
| /external/sl4a/ScriptingLayerForAndroid/src/org/connectbot/service/ |
| D | PromptHelper.java | 149 if (!promptToken.tryAcquire()) { in cancelPrompt()
|
| /external/guava/guava-tests/test/com/google/common/base/ |
| D | FinalizableReferenceQueueClassLoaderUnloadingTest.java | 250 boolean finalized = finalizeCount.tryAcquire(5, TimeUnit.SECONDS); in doTestUnloadableInStaticFieldIfClosed()
|
| /external/guava/android/guava-tests/test/com/google/common/base/ |
| D | FinalizableReferenceQueueClassLoaderUnloadingTest.java | 250 boolean finalized = finalizeCount.tryAcquire(5, TimeUnit.SECONDS); in doTestUnloadableInStaticFieldIfClosed()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 531 assertTrue(semaphore.tryAcquire(5, TimeUnit.SECONDS)); in inprocessTransportOutboundFlowControl()
533 assertTrue(semaphore.tryAcquire(5, TimeUnit.SECONDS)); in inprocessTransportOutboundFlowControl()
|
| /external/tensorflow/tensorflow/tools/android/test/src/org/tensorflow/demo/ |
| D | CameraConnectionFragment.java | 419 if (!cameraOpenCloseLock.tryAcquire(2500, TimeUnit.MILLISECONDS)) { in openCamera()
|