Home
last modified time | relevance | path

Searched full:acquire (Results 1 – 25 of 8575) sorted by relevance

12345678910>>...343

/aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
H A DRateLimiterTest.java54 limiter.acquire(); // R0.00, since it's the first request in testSimple()
55 limiter.acquire(); // R0.20 in testSimple()
56 limiter.acquire(); // R0.20 in testSimple()
62 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testImmediateTryAcquire()
68 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
87 assertThrows(IllegalArgumentException.class, () -> limiter.acquire(0)); in testAcquireParameterValidation()
88 assertThrows(IllegalArgumentException.class, () -> limiter.acquire(-1)); in testAcquireParameterValidation()
97 limiter.acquire(); // R0.00 in testSimpleWithWait()
99 limiter.acquire(); // R0.00, ...which is granted immediately in testSimpleWithWait()
100 limiter.acquire(); // R0.20 in testSimpleWithWait()
[all …]
/aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DRateLimiterTest.java54 limiter.acquire(); // R0.00, since it's the first request in testSimple()
55 limiter.acquire(); // R0.20 in testSimple()
56 limiter.acquire(); // R0.20 in testSimple()
62 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testImmediateTryAcquire()
68 assertTrue("Unable to acquire initial permit", r.tryAcquire()); in testDoubleMinValueCanAcquireExactlyOnce()
87 assertThrows(IllegalArgumentException.class, () -> limiter.acquire(0)); in testAcquireParameterValidation()
88 assertThrows(IllegalArgumentException.class, () -> limiter.acquire(-1)); in testAcquireParameterValidation()
97 limiter.acquire(); // R0.00 in testSimpleWithWait()
99 limiter.acquire(); // R0.00, ...which is granted immediately in testSimpleWithWait()
100 limiter.acquire(); // R0.20 in testSimpleWithWait()
[all …]
/aosp_15_r20/external/cronet/base/task/common/
H A Dchecked_lock_unittest.cc23 // Acquire()/Release() don't crash.
37 lock_->Acquire(); in Run()
42 lock_->Acquire(); in Run()
74 lock_->Acquire(); in Run()
95 lock.Acquire(); in TEST()
100 lock.Acquire(); in TEST()
106 lock.Acquire(); in TEST()
121 predecessor.Acquire(); in TEST()
122 lock.Acquire(); in TEST()
134 lock.Acquire(); in TEST()
[all …]
/aosp_15_r20/external/python/cpython3/Lib/test/
Dlock_tests.py109 lock.acquire()
115 lock.acquire()
120 lock.acquire()
126 self.assertTrue(lock.acquire(False))
131 lock.acquire()
134 result.append(lock.acquire(False))
141 lock.acquire()
144 lock.acquire()
158 lock.acquire()
176 lock.acquire()
[all …]
/aosp_15_r20/external/python/cpython2/Lib/test/
Dlock_tests.py81 lock.acquire()
86 lock.acquire()
92 self.assertTrue(lock.acquire(False))
97 lock.acquire()
100 result.append(lock.acquire(False))
107 lock.acquire()
110 lock.acquire()
124 lock.acquire()
142 lock.acquire()
161 lock.acquire()
[all …]
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
H A DHealthCheckedChannelPoolTest.java84 Future<Channel> acquire = channelPool.acquire(); in acquireCanMakeJustOneCall() local
86 acquire.get(5, TimeUnit.SECONDS); in acquireCanMakeJustOneCall()
88 assertThat(acquire.isDone()).isTrue(); in acquireCanMakeJustOneCall()
89 assertThat(acquire.isSuccess()).isTrue(); in acquireCanMakeJustOneCall()
90 assertThat(acquire.getNow()).isEqualTo(channels.get(0)); in acquireCanMakeJustOneCall()
92 Mockito.verify(downstreamChannelPool, Mockito.times(1)).acquire(any()); in acquireCanMakeJustOneCall()
100 Future<Channel> acquire = channelPool.acquire(); in acquireCanMakeManyCalls() local
102 acquire.get(5, TimeUnit.SECONDS); in acquireCanMakeManyCalls()
104 assertThat(acquire.isDone()).isTrue(); in acquireCanMakeManyCalls()
105 assertThat(acquire.isSuccess()).isTrue(); in acquireCanMakeManyCalls()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/tests/
Dsemaphore_batch.rs15 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_one_available()
25 assert_ready_ok!(task::spawn(s.acquire(5)).poll()); in poll_acquire_many_available()
28 assert_ready_ok!(task::spawn(s.acquire(5)).poll()); in poll_acquire_many_available()
60 // Acquire the first permit in poll_acquire_one_unavailable()
61 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_one_unavailable()
64 let mut acquire_2 = task::spawn(s.acquire(1)); in poll_acquire_one_unavailable()
65 // Try to acquire the second permit in poll_acquire_one_unavailable()
84 // Acquire the first permit in poll_acquire_many_unavailable()
85 assert_ready_ok!(task::spawn(s.acquire(1)).poll()); in poll_acquire_many_unavailable()
88 // Try to acquire the second permit in poll_acquire_many_unavailable()
[all …]
/aosp_15_r20/out/soong/raw-aosp_shiba/cb/
Dcb4b217533fee5d18d8e0f8f75af49bae1f9937099 …-lse-acquire-release-operations/art-run-test-2242-checker-lse-acquire-release-operations/android_c…
100 …-lse-acquire-release-operations/art-run-test-2242-checker-lse-acquire-release-operations/android_c…
127 …acquire-release-operations/art-run-test-2242-checker-lse-acquire-release-operations/android_common…
130 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
134 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
138 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
142 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
146 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
150 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
154 …ng/.intermediates/art/test/2242-checker-lse-acquire-release-operations/art-run-test-2242-checker-l…
[all …]
/aosp_15_r20/packages/providers/MediaProvider/jni/
Dnode_test.cpp29 static void acquire(node* node) { node->Acquire(); } in acquire() function in NodeTest
65 ASSERT_EQ(child.get(), parent->LookupChildByName("subdir", false /* acquire */)); in TEST_F()
71 acquire(node); in TEST_F()
72 acquire(node); in TEST_F()
91 ASSERT_EQ(child.get(), parent->LookupChildByName("subdir", false /* acquire */)); in TEST_F()
96 ASSERT_EQ(nullptr, parent->LookupChildByName("subdir", false /* acquire */)); in TEST_F()
97 ASSERT_EQ(child.get(), parent->LookupChildByName("subdir_new", false /* acquire */)); in TEST_F()
109 ASSERT_EQ(child.get(), parent1->LookupChildByName("subdir", false /* acquire */)); in TEST_F()
113 ASSERT_EQ(nullptr, parent1->LookupChildByName("subdir", false /* acquire */)); in TEST_F()
116 ASSERT_EQ(child.get(), parent2->LookupChildByName("subdir", false /* acquire */)); in TEST_F()
[all …]
/aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/
H A DSemaphoreTest.java50 * A runnable calling acquire
57 lock.acquire(); in realRun()
64 * A runnable calling acquire that expects to be interrupted
70 lock.acquire(); in realRun()
101 acquire() { in acquire() method
102 void acquire(Semaphore s) throws InterruptedException { in acquire() method
103 s.acquire(); in acquire()
107 void acquire(Semaphore s, int permits) throws InterruptedException { in acquireN() method
108 s.acquire(permits); in acquireN()
112 void acquire(Semaphore s) { in acquireUninterruptibly() method
[all …]
/aosp_15_r20/external/libchrome/base/task_scheduler/
H A Dscheduler_lock_unittest.cc23 // Acquire()/Release() don't crash.
36 lock_->Acquire(); in Run()
41 lock_->Acquire(); in Run()
75 lock_->Acquire(); in Run()
96 lock.Acquire(); in TEST()
101 lock.Acquire(); in TEST()
107 lock.Acquire(); in TEST()
122 predecessor.Acquire(); in TEST()
123 lock.Acquire(); in TEST()
132 lock.Acquire(); in TEST()
[all …]
/aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/
H A DSemaphoreTest.java85 * A runnable calling acquire
92 lock.acquire(); in realRun()
99 * A runnable calling acquire that expects to be interrupted
105 lock.acquire(); in realRun()
136 acquire() { in acquire() method
137 void acquire(Semaphore s) throws InterruptedException { in acquire() method
138 s.acquire(); in acquire()
142 void acquire(Semaphore s, int permits) throws InterruptedException { in acquireN() method
143 s.acquire(permits); in acquireN()
147 void acquire(Semaphore s) { in acquireUninterruptibly() method
[all …]
/aosp_15_r20/external/python/cpython3/Lib/test/test_asyncio/
Dtest_locks.py33 await lock.acquire()
90 self.assertTrue(await lock.acquire())
93 if await lock.acquire():
98 if await lock.acquire():
103 if await lock.acquire():
139 self.assertTrue(await lock.acquire())
141 task = asyncio.create_task(lock.acquire())
150 # - B is blocked in acquire()
151 # - C is blocked in acquire()
165 await lock.acquire()
[all …]
/aosp_15_r20/external/python/cpython2/Demo/threads/
Dsync.py23 # .acquire()
24 # acquire the lock associated with the condition
58 # condition object can (must) be .acquire'ed and .release'ed directly.
87 # condition.acquire()
92 # # did a .wait, *and* acquire the lock again before .wait
109 # condition.acquire()
133 # B_done.acquire() B_done.acquire(); B_done.release()
138 # Because B_done was in the acquire'd state at the time B was spawned,
139 # B's attempt to acquire B_done can't succeed until A has done its
275 # the lock actually used by .acquire() and .release()
[all …]
/aosp_15_r20/external/pigweed/pw_software_update/
H A Dbundled_update_service.cc52 BorrowedStatus borrowed_status = status_.acquire(); \
65 response = *status_.acquire(); in GetStatus()
74 const BundledUpdateState state = status_.acquire()->state; in Start()
80 response = *status_.acquire(); in Start()
85 BorrowedStatus borrowed_status = status_.acquire(); in Start()
97 response = *status_.acquire(); in Start()
108 response = *status_.acquire(); in Start()
114 BorrowedStatus borrowed_status = status_.acquire(); in Start()
135 const BundledUpdateState state = status_.acquire()->state; in SetTransferred()
144 response = *status_.acquire(); in SetTransferred()
[all …]
H A Dbundled_update_service_pwpb.cc50 BorrowedStatus borrowed_status = status_.acquire(); \
63 response = *status_.acquire(); in GetStatus()
71 const BundledUpdateState::Enum state = status_.acquire()->state; in Start()
77 response = *status_.acquire(); in Start()
82 BorrowedStatus borrowed_status = status_.acquire(); in Start()
95 response = *status_.acquire(); in Start()
105 response = *status_.acquire(); in Start()
111 BorrowedStatus borrowed_status = status_.acquire(); in Start()
125 const BundledUpdateState::Enum state = status_.acquire()->state; in SetTransferred()
134 response = *status_.acquire(); in SetTransferred()
[all …]
/aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/
H A DSemaphore64Test.java48 semaphore.acquire(-1); in testNegative()
54 assertTrue(semaphore.acquire(1)); in testReturning()
55 assertFalse(semaphore.acquire(1)); in testReturning()
57 assertTrue(semaphore.acquire(1)); in testReturning()
63 semaphore.acquire(1); in testBlocking()
70 semaphore.acquire(1); in testBlocking()
86 assertFalse(semaphore.acquire(3)); in testReducePermitLimitNonBlocking()
87 assertTrue(semaphore.acquire(2)); in testReducePermitLimitNonBlocking()
96 semaphore.acquire(1); in testReducePermitLimitBlocking()
103 semaphore.acquire(1); in testReducePermitLimitBlocking()
[all …]
/aosp_15_r20/external/llvm/test/CodeGen/X86/
H A Datomic6432.ll8 %t1 = atomicrmw add i64* @sc64, i64 1 acquire
13 %t2 = atomicrmw add i64* @sc64, i64 3 acquire
18 %t3 = atomicrmw add i64* @sc64, i64 5 acquire
23 %t4 = atomicrmw add i64* @sc64, i64 %t3 acquire
34 %t1 = atomicrmw sub i64* @sc64, i64 1 acquire
39 %t2 = atomicrmw sub i64* @sc64, i64 3 acquire
44 %t3 = atomicrmw sub i64* @sc64, i64 5 acquire
49 %t4 = atomicrmw sub i64* @sc64, i64 %t3 acquire
60 %t1 = atomicrmw and i64* @sc64, i64 3 acquire
65 %t2 = atomicrmw and i64* @sc64, i64 4294967297 acquire
[all …]
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedSynchronizer.java75 * mechanical sense that when a shared mode acquire succeeds, the next
77 * acquire as well. Threads waiting in the different modes share the
89 * this object, and {@link #acquire}, given this saved state value,
141 * <em>Acquire:</em>
154 * <p id="barging">Because checks in acquire are invoked before
177 * augment this by preceding calls to acquire methods with
184 * synchronizers that can rely on {@code int} state, acquire, and
251 * public void lock() { sync.acquire(1); }
275 * acquire and release methods.
350 * Dequeuing on acquire involves detaching (nulling) a node's
[all …]
/aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/locks/
H A DAbstractQueuedSynchronizer.java75 * mechanical sense that when a shared mode acquire succeeds, the next
77 * acquire as well. Threads waiting in the different modes share the
89 * this object, and {@link #acquire}, given this saved state value,
141 * <em>Acquire:</em>
154 * <p id="barging">Because checks in acquire are invoked before
177 * augment this by preceding calls to acquire methods with
184 * synchronizers that can rely on {@code int} state, acquire, and
251 * public void lock() { sync.acquire(1); }
275 * acquire and release methods.
350 * Dequeuing on acquire involves detaching (nulling) a node's
[all …]
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/20/libcore/ojluni/src/main/java/java/util/concurrent/locks/
DAbstractQueuedSynchronizer.java75 * mechanical sense that when a shared mode acquire succeeds, the next
77 * acquire as well. Threads waiting in the different modes share the
89 * this object, and {@link #acquire}, given this saved state value,
141 * <em>Acquire:</em>
154 * <p id="barging">Because checks in acquire are invoked before
177 * augment this by preceding calls to acquire methods with
184 * synchronizers that can rely on {@code int} state, acquire, and
251 * public void lock() { sync.acquire(1); }
275 * acquire and release methods.
350 * Dequeuing on acquire involves detaching (nulling) a node's
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/vendor/compiler_builtins/src/out/
H A Doutlined_atomics.rs6 $macro!( Acquire, 1, __aarch64_ldset1_acq );
7 $macro!( Acquire, 2, __aarch64_ldset2_acq );
8 $macro!( Acquire, 4, __aarch64_ldset4_acq );
9 $macro!( Acquire, 8, __aarch64_ldset8_acq );
23 $macro!( Acquire, 1, __aarch64_cas1_acq );
24 $macro!( Acquire, 2, __aarch64_cas2_acq );
25 $macro!( Acquire, 4, __aarch64_cas4_acq );
26 $macro!( Acquire, 8, __aarch64_cas8_acq );
40 $macro!( Acquire, 1, __aarch64_swp1_acq );
41 $macro!( Acquire, 2, __aarch64_swp2_acq );
[all …]
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/vendor/compiler_builtins/src/out/
H A Doutlined_atomics.rs6 $macro!( Acquire, 1, __aarch64_ldset1_acq );
7 $macro!( Acquire, 2, __aarch64_ldset2_acq );
8 $macro!( Acquire, 4, __aarch64_ldset4_acq );
9 $macro!( Acquire, 8, __aarch64_ldset8_acq );
23 $macro!( Acquire, 1, __aarch64_cas1_acq );
24 $macro!( Acquire, 2, __aarch64_cas2_acq );
25 $macro!( Acquire, 4, __aarch64_cas4_acq );
26 $macro!( Acquire, 8, __aarch64_cas8_acq );
40 $macro!( Acquire, 1, __aarch64_swp1_acq );
41 $macro!( Acquire, 2, __aarch64_swp2_acq );
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/vendor/compiler_builtins/src/out/
H A Doutlined_atomics.rs6 $macro!( Acquire, 1, __aarch64_ldset1_acq );
7 $macro!( Acquire, 2, __aarch64_ldset2_acq );
8 $macro!( Acquire, 4, __aarch64_ldset4_acq );
9 $macro!( Acquire, 8, __aarch64_ldset8_acq );
23 $macro!( Acquire, 1, __aarch64_cas1_acq );
24 $macro!( Acquire, 2, __aarch64_cas2_acq );
25 $macro!( Acquire, 4, __aarch64_cas4_acq );
26 $macro!( Acquire, 8, __aarch64_cas8_acq );
40 $macro!( Acquire, 1, __aarch64_swp1_acq );
41 $macro!( Acquire, 2, __aarch64_swp2_acq );
[all …]
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/vendor/compiler_builtins/src/out/
H A Doutlined_atomics.rs6 $macro!( Acquire, 1, __aarch64_ldset1_acq );
7 $macro!( Acquire, 2, __aarch64_ldset2_acq );
8 $macro!( Acquire, 4, __aarch64_ldset4_acq );
9 $macro!( Acquire, 8, __aarch64_ldset8_acq );
23 $macro!( Acquire, 1, __aarch64_cas1_acq );
24 $macro!( Acquire, 2, __aarch64_cas2_acq );
25 $macro!( Acquire, 4, __aarch64_cas4_acq );
26 $macro!( Acquire, 8, __aarch64_cas8_acq );
40 $macro!( Acquire, 1, __aarch64_swp1_acq );
41 $macro!( Acquire, 2, __aarch64_swp2_acq );
[all …]

12345678910>>...343