Home
last modified time | relevance | path

Searched defs:semaphore (Results 1 – 25 of 925) sorted by relevance

12345678910>>...37

/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/sync/
H A DSemaphoreTest.kt11 val semaphore = Semaphore(2) in <lambda>() constant
27 val semaphore = Semaphore(1) in <lambda>() constant
49 val semaphore = Semaphore(2) in <lambda>() constant
62 val semaphore = Semaphore(1) in <lambda>() constant
72 val semaphore = Semaphore(1) in withSemaphoreOnFailureTest() constant
87 val semaphore = Semaphore(1) in <lambda>() constant
101 val semaphore = Semaphore(1) in <lambda>() constant
130 val semaphore = Semaphore(1) in <lambda>() constant
146 val semaphore = Semaphore(1) in <lambda>() constant
170 val semaphore = Semaphore(5, acquiredPermits = 4) in <lambda>() constant
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tokio/src/sync/tests/
Dloom_semaphore_batch.rs18 semaphore: Semaphore, in basic_usage() field
53 let semaphore = Arc::new(Semaphore::new(1)); in release() localVariable
56 let semaphore = semaphore.clone(); in release() localVariable
74 let semaphore = Arc::new(Semaphore::new(1)); in basic_closing() localVariable
77 let semaphore = semaphore.clone(); in basic_closing() localVariable
99 let semaphore = Arc::new(Semaphore::new(1)); in concurrent_close() localVariable
102 let semaphore = semaphore.clone(); in concurrent_close() localVariable
138 let semaphore = Arc::new(Semaphore::new(0)); in concurrent_cancel() localVariable
140 let semaphore = semaphore.clone(); in concurrent_cancel() localVariable
144 let semaphore = semaphore.clone(); in concurrent_cancel() localVariable
[all …]
/aosp_15_r20/external/pigweed/pw_sync/
H A Dcounting_semaphore_facade_test.cc58 CountingSemaphore semaphore; in TEST() local
65 CountingSemaphore semaphore; in TEST() local
90 CountingSemaphore semaphore; in TEST() local
101 CountingSemaphore semaphore; in TEST() local
112 CountingSemaphore semaphore; in TEST() local
122 CountingSemaphore semaphore; in TEST() local
133 CountingSemaphore semaphore; in TEST() local
144 CountingSemaphore semaphore; in TEST() local
155 CountingSemaphore semaphore; in TEST() local
165 CountingSemaphore semaphore; in TEST() local
[all …]
H A Dbinary_semaphore_facade_test.cc52 BinarySemaphore semaphore; in TEST() local
59 BinarySemaphore semaphore; in TEST() local
82 BinarySemaphore semaphore; in TEST() local
93 BinarySemaphore semaphore; in TEST() local
103 BinarySemaphore semaphore; in TEST() local
114 BinarySemaphore semaphore; in TEST() local
125 BinarySemaphore semaphore; in TEST() local
136 BinarySemaphore semaphore; in TEST() local
146 BinarySemaphore semaphore; in TEST() local
156 BinarySemaphore semaphore; in TEST() local
[all …]
H A Dcounting_semaphore.cc20 pw_sync_CountingSemaphore* semaphore) { in pw_sync_CountingSemaphore_Release()
25 pw_sync_CountingSemaphore* semaphore, ptrdiff_t update) { in pw_sync_CountingSemaphore_ReleaseNum()
30 pw_sync_CountingSemaphore* semaphore) { in pw_sync_CountingSemaphore_Acquire()
35 pw_sync_CountingSemaphore* semaphore) { in pw_sync_CountingSemaphore_TryAcquire()
40 pw_sync_CountingSemaphore* semaphore, in pw_sync_CountingSemaphore_TryAcquireFor()
46 pw_sync_CountingSemaphore* semaphore, in pw_sync_CountingSemaphore_TryAcquireUntil()
H A Dcounting_semaphore_facade_test_c.c23 pw_sync_CountingSemaphore* semaphore) { in pw_sync_CountingSemaphore_CallRelease()
28 pw_sync_CountingSemaphore* semaphore, ptrdiff_t update) { in pw_sync_CountingSemaphore_CallReleaseNum()
33 pw_sync_CountingSemaphore* semaphore) { in pw_sync_CountingSemaphore_CallAcquire()
38 pw_sync_CountingSemaphore* semaphore) { in pw_sync_CountingSemaphore_CallTryAcquire()
43 pw_sync_CountingSemaphore* semaphore, in pw_sync_CountingSemaphore_CallTryAcquireFor()
49 pw_sync_CountingSemaphore* semaphore, in pw_sync_CountingSemaphore_CallTryAcquireUntil()
H A Dbinary_semaphore.cc20 pw_sync_BinarySemaphore* semaphore) { in pw_sync_BinarySemaphore_Release()
25 pw_sync_BinarySemaphore* semaphore) { in pw_sync_BinarySemaphore_Acquire()
30 pw_sync_BinarySemaphore* semaphore) { in pw_sync_BinarySemaphore_TryAcquire()
35 pw_sync_BinarySemaphore* semaphore, in pw_sync_BinarySemaphore_TryAcquireFor()
41 pw_sync_BinarySemaphore* semaphore, in pw_sync_BinarySemaphore_TryAcquireUntil()
H A Dbinary_semaphore_facade_test_c.c22 void pw_sync_BinarySemaphore_CallRelease(pw_sync_BinarySemaphore* semaphore) { in pw_sync_BinarySemaphore_CallRelease()
26 void pw_sync_BinarySemaphore_CallAcquire(pw_sync_BinarySemaphore* semaphore) { in pw_sync_BinarySemaphore_CallAcquire()
31 pw_sync_BinarySemaphore* semaphore) { in pw_sync_BinarySemaphore_CallTryAcquire()
36 pw_sync_BinarySemaphore* semaphore, in pw_sync_BinarySemaphore_CallTryAcquireFor()
42 pw_sync_BinarySemaphore* semaphore, in pw_sync_BinarySemaphore_CallTryAcquireUntil()
/aosp_15_r20/external/apache-commons-lang/src/test/java/org/apache/commons/lang3/concurrent/
H A DTimedSemaphoreTest.java60 final TimedSemaphore semaphore = new TimedSemaphore(service, PERIOD_MILLIS, UNIT, in testInit() local
87 final TimedSemaphore semaphore = new TimedSemaphore(PERIOD_MILLIS, UNIT, LIMIT); in testInitDefaultService() local
103 final TimedSemaphoreTestImpl semaphore = new TimedSemaphoreTestImpl(PERIOD_MILLIS, in testStartTimer() local
123 final TimedSemaphore semaphore = new TimedSemaphore(PERIOD_MILLIS, UNIT, LIMIT); in testShutdownOwnExecutor() local
138 final TimedSemaphore semaphore = new TimedSemaphore(service, PERIOD_MILLIS, UNIT, in testShutdownSharedExecutorNoTask() local
172 final TimedSemaphoreTestImpl semaphore = new TimedSemaphoreTestImpl(service, in testShutdownSharedExecutorTask() local
193 final TimedSemaphoreTestImpl semaphore = new TimedSemaphoreTestImpl(service, in testShutdownMultipleTimes() local
216 final TimedSemaphore semaphore = new TimedSemaphore(service, PERIOD_MILLIS, UNIT, 1); in testAcquireLimit() local
250 final TimedSemaphoreTestImpl semaphore = new TimedSemaphoreTestImpl(service, in testAcquireMultipleThreads() local
286 final TimedSemaphoreTestImpl semaphore = new TimedSemaphoreTestImpl(service, in testAcquireNoLimit() local
[all …]
/aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/batching/
H A DSemaphore64Test.java47 Semaphore64 semaphore = new BlockingSemaphore(1); in testNegative() local
53 Semaphore64 semaphore = new NonBlockingSemaphore(1); in testReturning() local
62 final Semaphore64 semaphore = new BlockingSemaphore(1); in testBlocking() local
84 final Semaphore64 semaphore = new NonBlockingSemaphore(5); in testReducePermitLimitNonBlocking() local
93 final Semaphore64 semaphore = new BlockingSemaphore(2); in testReducePermitLimitBlocking() local
119 Semaphore64 semaphore = new NonBlockingSemaphore(5); in testAcquirePartialNonBlocking() local
131 final Semaphore64 semaphore = new BlockingSemaphore(5); in testAcquirePartialBlocking() local
167 Semaphore64 semaphore = new NonBlockingSemaphore(1); in testIncreasePermitLimitNonBlocking() local
178 final Semaphore64 semaphore = new BlockingSemaphore(1); in testIncreasePermitLimitBlocking() local
203 final Semaphore64 semaphore = new NonBlockingSemaphore(10); in testReleaseWontOverflowNonBlocking() local
[all …]
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/sync/
H A DSemaphoreStressTest.kt17 val semaphore = Semaphore(1) in <lambda>() constant
35 val semaphore = Semaphore(10) in <lambda>() constant
53 val semaphore = Semaphore(1) in <lambda>() constant
71 val semaphore = Semaphore(1) in <lambda>() constant
92 val semaphore = Semaphore(1, 1) in <lambda>() constant
121 val semaphore = Semaphore(1) in <lambda>() constant
/aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DUninterruptiblesTest.java365 Semaphore semaphore = new Semaphore(99); in testTryAcquireWithNoWait() local
373 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(20); in testTryAcquireTimeoutNoInterruptNotExpired() local
379 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutNoInterruptExpired() local
385 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(50); in testTryAcquireTimeoutSingleInterruptNoExpire() local
392 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutSingleInterruptExpired() local
399 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(100); in testTryAcquireTimeoutMultiInterruptNoExpire() local
411 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutMultiInterruptExpired() local
419 Semaphore semaphore = new Semaphore(99); in testTryAcquireWithNoWaitMultiPermit() local
427 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(20); in testTryAcquireTimeoutNoInterruptNotExpiredMultiPermit() local
433 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutNoInterruptExpiredMultiPermit() local
[all …]
/aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
H A DUninterruptiblesTest.java364 Semaphore semaphore = new Semaphore(99); in testTryAcquireWithNoWait() local
372 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(20); in testTryAcquireTimeoutNoInterruptNotExpired() local
378 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutNoInterruptExpired() local
384 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(50); in testTryAcquireTimeoutSingleInterruptNoExpire() local
391 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutSingleInterruptExpired() local
398 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(100); in testTryAcquireTimeoutMultiInterruptNoExpire() local
410 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutMultiInterruptExpired() local
418 Semaphore semaphore = new Semaphore(99); in testTryAcquireWithNoWaitMultiPermit() local
426 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(20); in testTryAcquireTimeoutNoInterruptNotExpiredMultiPermit() local
432 TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS); in testTryAcquireTimeoutNoInterruptExpiredMultiPermit() local
[all …]
/aosp_15_r20/external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/file/common/
H A DLockScope.java100 Semaphore semaphore = getOrCreateSemaphore(uri.toString()); in threadLock() local
116 Semaphore semaphore = getOrCreateSemaphore(uri.toString()); in tryThreadLock() local
226 private Semaphore semaphore; field in LockScope.SemaphoreLockImpl
228 SemaphoreLockImpl(Semaphore semaphore) { in SemaphoreLockImpl()
260 @Nullable private Semaphore semaphore; field in LockScope.SemaphoreResource
262 static SemaphoreResource tryAcquire(Semaphore semaphore) { in tryAcquire()
267 static SemaphoreResource acquire(Semaphore semaphore) throws InterruptedIOException { in acquire()
276 SemaphoreResource(@Nullable Semaphore semaphore) { in SemaphoreResource()
303 Semaphore semaphore = lockMap.get(key); in getOrCreateSemaphore() local
/aosp_15_r20/bionic/tests/
H A Dsemaphore_test.cpp35 TEST(semaphore, sem_init) { in TEST() argument
61 TEST(semaphore, sem_trywait) { in TEST() argument
82 TEST(semaphore, sem_wait__sem_post) { in TEST() argument
142 TEST(semaphore, sem_timedwait) { in TEST() argument
146 TEST(semaphore, sem_timedwait_monotonic_np) { in TEST() argument
154 TEST(semaphore, sem_clockwait) { in TEST() argument
176 TEST(semaphore, sem_getvalue) { in TEST() argument
223 TEST(semaphore, sem_wait_no_EINTR_in_sdk_less_equal_than_23) { in TEST() argument
245 TEST(semaphore, sem_wait_EINTR_in_sdk_greater_than_23) { in TEST() argument
/aosp_15_r20/external/mesa3d/src/virtio/venus-protocol/
H A Dvn_protocol_driver_semaphore.h436 static inline size_t vn_sizeof_vkDestroySemaphore(VkDevice device, VkSemaphore semaphore, const VkA… in vn_sizeof_vkDestroySemaphore()
451 …vn_cs_encoder *enc, VkCommandFlagsEXT cmd_flags, VkDevice device, VkSemaphore semaphore, const VkA… in vn_encode_vkDestroySemaphore()
464 static inline size_t vn_sizeof_vkDestroySemaphore_reply(VkDevice device, VkSemaphore semaphore, con… in vn_sizeof_vkDestroySemaphore_reply()
476 …estroySemaphore_reply(struct vn_cs_decoder *dec, VkDevice device, VkSemaphore semaphore, const VkA… in vn_decode_vkDestroySemaphore_reply()
487 static inline size_t vn_sizeof_vkGetSemaphoreCounterValue(VkDevice device, VkSemaphore semaphore, u… in vn_sizeof_vkGetSemaphoreCounterValue()
500 …vn_cs_encoder *enc, VkCommandFlagsEXT cmd_flags, VkDevice device, VkSemaphore semaphore, uint64_t*… in vn_encode_vkGetSemaphoreCounterValue()
512 …ize_t vn_sizeof_vkGetSemaphoreCounterValue_reply(VkDevice device, VkSemaphore semaphore, uint64_t*… in vn_sizeof_vkGetSemaphoreCounterValue_reply()
528 …oreCounterValue_reply(struct vn_cs_decoder *dec, VkDevice device, VkSemaphore semaphore, uint64_t*… in vn_decode_vkGetSemaphoreCounterValue_reply()
657 static inline size_t vn_sizeof_vkWaitSemaphoreResourceMESA(VkDevice device, VkSemaphore semaphore) in vn_sizeof_vkWaitSemaphoreResourceMESA()
669 …ESA(struct vn_cs_encoder *enc, VkCommandFlagsEXT cmd_flags, VkDevice device, VkSemaphore semaphore) in vn_encode_vkWaitSemaphoreResourceMESA()
[all …]
/aosp_15_r20/packages/modules/Bluetooth/system/osi/test/internal/
Dsemaphore_test.cc14 semaphore_t* semaphore; member
40 semaphore_t* semaphore = semaphore_new(0); in TEST_F() local
46 semaphore_t* semaphore = semaphore_new(3); in TEST_F() local
58 semaphore_t* semaphore = semaphore_new(0); in TEST_F() local
70 semaphore_t* semaphore = semaphore_new(0); in TEST_F() local
78 semaphore_t* semaphore = semaphore_new(0); in TEST_F() local
/aosp_15_r20/external/sdv/vsomeip/third_party/boost/atomic/src/
Dlock_pool.cpp668 struct semaphore struct
671 semaphore* m_next;
673 semaphore* m_prev;
676 boost::winapi::HANDLE_ m_semaphore;
678 boost::winapi::ULONG_ m_waiter_count;
680 boost::winapi::ULONG_ m_notify_count;
682 semaphore() BOOST_NOEXCEPT : in semaphore() argument
690 ~semaphore() BOOST_NOEXCEPT in ~semaphore()
699 static semaphore* create() BOOST_NOEXCEPT in create()
711 bool is_singular() const BOOST_NOEXCEPT in is_singular()
[all …]
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvmBenchmark/kotlin/kotlinx/coroutines/
H A DSemaphoreBenchmark.kt41 fun semaphore() = runBlocking { in <lambda>() method
43 val semaphore = Semaphore(_3_maxPermits) in <lambda>() constant
61 val semaphore = Channel<Unit>(_3_maxPermits) in <lambda>() constant
/aosp_15_r20/packages/modules/Bluetooth/system/osi/src/internal/
Dsemaphore.cc54 void semaphore_free(semaphore_t* semaphore) { in semaphore_free()
65 void semaphore_wait(semaphore_t* semaphore) { in semaphore_wait()
75 bool semaphore_try_wait(semaphore_t* semaphore) { in semaphore_try_wait()
101 void semaphore_post(semaphore_t* semaphore) { in semaphore_post()
110 int semaphore_get_fd(const semaphore_t* semaphore) { in semaphore_get_fd()
/aosp_15_r20/art/test/004-ThreadStress/src-art/
H A DMain.java295 private final Semaphore semaphore; field in Main.QueuedWait
297 public QueuedWait(Semaphore semaphore) { in QueuedWait()
328 Semaphore semaphore) { in createDefaultFrequencyMap()
373 Object lock, Semaphore semaphore, String arg) { in updateFrequencyMap()
480 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local
508 Semaphore semaphore = getSemaphore(permits); in parseAndRun() local
532 Semaphore semaphore = new Semaphore(permits, /* fair */ true); in getSemaphore() local
543 private static void forceTransitiveClassInitialization(Semaphore semaphore, final int permits) { in forceTransitiveClassInitialization()
/aosp_15_r20/external/libusb/examples/
H A Ddpfp.c53 sem_t *semaphore; in semaphore_create() local
65 static inline void semaphore_give(semaphore_t semaphore) in semaphore_give()
70 static inline void semaphore_take(semaphore_t semaphore) in semaphore_take()
75 static inline void semaphore_destroy(semaphore_t semaphore) in semaphore_destroy()
107 static inline void semaphore_give(semaphore_t semaphore) in semaphore_give()
112 static inline void semaphore_take(semaphore_t semaphore) in semaphore_take()
117 static inline void semaphore_destroy(semaphore_t semaphore) in semaphore_destroy()
/aosp_15_r20/external/trusty/lk/include/kernel/
Dsemaphore.h28 typedef struct semaphore { struct
32 } semaphore_t; argument
/aosp_15_r20/frameworks/base/libs/WindowManager/Shell/multivalentTests/src/com/android/wm/shell/bubbles/bar/
H A DBubbleBarAnimationHelperTest.kt113 val semaphore = Semaphore(0) in animateSwitch_bubbleToBubble_oldHiddenNewShown() constant
155 val semaphore = Semaphore(0) in animateSwitch_bubbleToOverflow_oldHiddenNewShown() constant
178 val semaphore = Semaphore(0) in animateSwitch_overflowToBubble_oldHiddenNewShown() constant
/aosp_15_r20/external/deqp/framework/delibs/dethread/unix/
H A DdeSemaphoreUnix.c54 void deSemaphore_destroy(deSemaphore semaphore) in deSemaphore_destroy()
62 void deSemaphore_increment(deSemaphore semaphore) in deSemaphore_increment()
70 void deSemaphore_decrement(deSemaphore semaphore) in deSemaphore_decrement()
78 bool deSemaphore_tryDecrement(deSemaphore semaphore) in deSemaphore_tryDecrement()

12345678910>>...37