Home
last modified time | relevance | path

Searched refs:mutex (Results 1 – 25 of 44) sorted by relevance

12

/system/ulib/sync/
A Dcondition.cpp13 static zx_futex_t* get_futex(sync_mutex_t* mutex) { in get_futex()
14 return &mutex->futex; in get_futex()
17 static zx_status_t lock(sync_mutex_t* mutex, int* mutex_lock_err) __TA_ACQUIRE(mutex) { in lock()
18 sync_mutex_lock(mutex); in lock()
23 sync_mutex_t* mutex, int waiters_delta, int* mutex_lock_err) __TA_ACQUIRE(mutex) { in lock_with_waiters()
24 sync_mutex_lock_with_waiter(mutex); in lock_with_waiters()
28 static void unlock(sync_mutex_t* mutex) __TA_RELEASE(mutex) { in unlock()
29 sync_mutex_unlock(mutex); in unlock()
33 void sync_condition_wait(sync_condition_t* condition, sync_mutex_t* mutex) { in sync_condition_wait() argument
35 condition, mutex, ZX_TIME_INFINITE, nullptr); in sync_condition_wait()
[all …]
A Dmutex.c25 static zx_status_t lock_slow_path(sync_mutex_t* mutex, zx_time_t deadline, in lock_slow_path() argument
32 atomic_compare_exchange_strong(&mutex->futex, &old_state, in lock_slow_path()
45 if (atomic_compare_exchange_strong(&mutex->futex, &old_state, in lock_slow_path()
52 zx_status_t sync_mutex_trylock(sync_mutex_t* mutex) { in sync_mutex_trylock() argument
54 if (atomic_compare_exchange_strong(&mutex->futex, &old_state, in sync_mutex_trylock()
65 if (atomic_compare_exchange_strong(&mutex->futex, &old_state, in sync_mutex_timedlock()
69 return lock_slow_path(mutex, deadline, old_state); in sync_mutex_timedlock()
73 zx_status_t status = sync_mutex_timedlock(mutex, ZX_TIME_INFINITE); in sync_mutex_lock()
81 if (atomic_compare_exchange_strong(&mutex->futex, &old_state, in sync_mutex_lock_with_waiter()
94 int old_state = atomic_exchange(&mutex->futex, UNLOCKED); in sync_mutex_unlock()
[all …]
/system/utest/core/condition-generic/
A Dcondition-generic.h30 ctx.mutex.lock(); in condition_test()
32 ctx.mutex.unlock(); in condition_test()
43 ctx.mutex.lock(); in condition_test()
45 ctx.mutex.unlock(); in condition_test()
57 ctx.mutex.lock(); in condition_test()
78 Mutex mutex; in condition_timeout_test() local
80 mutex.lock(); in condition_timeout_test()
82 mutex.unlock(); in condition_timeout_test()
91 Mutex mutex; member
101 ctx->mutex.lock(); in cond_thread()
[all …]
/system/utest/core/c11-condvar/
A Dcondvar.c11 static mtx_t mutex = MTX_INIT; variable
18 mtx_lock(&mutex); in cond_thread()
20 cnd_wait(&cond, &mutex); in cond_thread()
22 cnd_wait(&cond, &mutex); in cond_thread()
24 mtx_unlock(&mutex); in cond_thread()
43 mtx_lock(&mutex); in cnd_test()
45 mtx_unlock(&mutex); in cnd_test()
57 mtx_lock(&mutex); in cnd_test()
59 mtx_unlock(&mutex); in cnd_test()
105 mtx_lock(&mutex); in cnd_timedwait_timeout_test()
[all …]
/system/ulib/sync/include/lib/sync/
A Dmutex.h40 void sync_mutex_lock(sync_mutex_t* mutex) __TA_ACQUIRE(mutex);
46 void sync_mutex_lock_with_waiter(sync_mutex_t* mutex) __TA_ACQUIRE(mutex);
58 zx_status_t sync_mutex_timedlock(sync_mutex_t* mutex, zx_time_t deadline);
63 zx_status_t sync_mutex_trylock(sync_mutex_t* mutex);
68 void sync_mutex_unlock(sync_mutex_t* mutex) __TA_RELEASE(mutex);
A Dcondition.h35 void sync_condition_wait(sync_condition_t* condition, sync_mutex_t* mutex);
48 zx_status_t sync_condition_timedwait(sync_condition_t* condition, sync_mutex_t* mutex, zx_time_t de…
/system/ulib/fbl/include/fbl/
A Dauto_lock.h29 explicit AutoLock(fbl_mutex_t* mutex) __TA_ACQUIRE(mutex) in AutoLock() argument
30 : mutex_(mutex), acquired_(true) { in AutoLock()
34 explicit AutoLock(Mutex* mutex) __TA_ACQUIRE(mutex) in AutoLock() argument
35 : AutoLock(mutex->GetInternal()) {} in AutoLock()
37 explicit AutoLock(fbl::NullLock* mutex) __TA_ACQUIRE(mutex) in AutoLock() argument
A Dcondition_variable.h31 void Wait(Mutex* mutex) __TA_REQUIRES(mutex) { in Wait() argument
32 cnd_wait(&cond_, mutex->GetInternal()); in Wait()
/system/utest/core/pthread/
A Dpthread.cpp32 pthread_mutex_lock(&mutex); in mutex_thread_1()
40 pthread_mutex_unlock(&mutex); in mutex_thread_1()
48 pthread_mutex_lock(&mutex); in mutex_thread_2()
58 pthread_mutex_unlock(&mutex); in mutex_thread_2()
66 pthread_mutex_lock(&mutex); in mutex_thread_3()
76 pthread_mutex_unlock(&mutex); in mutex_thread_3()
82 pthread_mutex_lock(&mutex); in cond_thread1()
94 pthread_mutex_lock(&mutex); in cond_thread2()
106 pthread_mutex_lock(&mutex); in cond_thread3()
123 pthread_mutex_lock(&mutex); in pthread_test()
[all …]
/system/utest/fbl/
A Dref_counted_upgradeable_tests.cpp19 RawUpgradeTester(fbl::Mutex* mutex, std::atomic<bool>* destroying, zx::event* event) in RawUpgradeTester() argument
20 : mutex_(mutex), destroying_(destroying), destroying_event_(event) {} in RawUpgradeTester()
50 fbl::Mutex mutex; in upgrade_fail_test() local
58 auto raw = new (&ac) RawUpgradeTester<EnableAdoptionValidator>(&mutex, in upgrade_fail_test()
65 fbl::AutoLock al(&mutex); in upgrade_fail_test()
73 auto upgrade1 = fbl::MakeRefPtrUpgradeFromRaw(raw, mutex); in upgrade_fail_test()
76 auto upgrade2 = fbl::MakeRefPtrUpgradeFromRaw(raw, mutex); in upgrade_fail_test()
88 fbl::Mutex mutex; in upgrade_success_test() local
92 auto ref = fbl::AdoptRef(new (&ac) RawUpgradeTester<EnableAdoptionValidator>(&mutex, in upgrade_success_test()
99 fbl::AutoLock al(&mutex); in upgrade_success_test()
[all …]
A Dcondition_variable_tests.cpp27 Mutex mutex; in WaitTest() member
32 AutoLock lock(&state.mutex); in WaitTest()
36 AutoLock lock(&state->mutex); in WaitTest()
41 state.cvar.Wait(&state.mutex); in WaitTest()
/system/ulib/unittest/
A Dwatchdog.cpp42 static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; variable
122 pthread_mutex_lock(&mutex); in watchdog_thread_func()
131 pthread_mutex_unlock(&mutex); in watchdog_thread_func()
141 auto result __UNUSED = pthread_cond_timedwait(&cond, &mutex, &delay); in watchdog_thread_func()
157 pthread_mutex_unlock(&mutex); in watchdog_thread_func()
193 pthread_mutex_lock(&mutex); in watchdog_start()
199 pthread_mutex_unlock(&mutex); in watchdog_start()
212 pthread_mutex_lock(&mutex); in watchdog_cancel()
215 pthread_mutex_unlock(&mutex); in watchdog_cancel()
229 pthread_mutex_lock(&mutex); in watchdog_terminate()
[all …]
A Dcrash-list.cpp25 mtx_t mutex; member
36 int ret = mtx_init(&crash_list->mutex, mtx_plain); in crash_list_new()
76 mtx_lock(&crash_list->mutex); in crash_list_register()
78 mtx_unlock(&crash_list->mutex); in crash_list_register()
90 mtx_lock(&crash_list->mutex); in crash_list_lookup_koid()
97 mtx_unlock(&crash_list->mutex); in crash_list_lookup_koid()
111 mtx_lock(&crash_list->mutex); in crash_list_delete_koid()
120 mtx_unlock(&crash_list->mutex); in crash_list_delete_koid()
140 mtx_destroy(&crash_list->mutex); in crash_list_delete()
/system/utest/perftest/
A Dmutex-test.cpp16 mtx_t mutex; in MutexLockUnlockTest() local
17 ZX_ASSERT(mtx_init(&mutex, mtx_plain) == thrd_success); in MutexLockUnlockTest()
19 ZX_ASSERT(mtx_lock(&mutex) == thrd_success); in MutexLockUnlockTest()
21 ZX_ASSERT(mtx_unlock(&mutex) == thrd_success); in MutexLockUnlockTest()
23 mtx_destroy(&mutex); in MutexLockUnlockTest()
/system/dev/bluetooth/bt-transport-usb/
A Dbt-transport-usb.c80 mtx_t mutex; member
136 mtx_lock(&hci->mutex); in hci_event_complete()
211 mtx_lock(&hci->mutex); in hci_acl_read_complete()
247 mtx_lock(&hci->mutex); in hci_acl_write_complete()
295 mtx_lock(&hci->mutex); in hci_build_read_wait_items()
331 mtx_lock(&hci->mutex); in hci_handle_cmd_read_events()
379 mtx_lock(&hci->mutex); in hci_handle_acl_read_events()
392 mtx_lock(&hci->mutex); in hci_read_thread()
439 mtx_lock(&hci->mutex); in hci_read_thread()
447 mtx_lock(&hci->mutex); in hci_open_channel()
[all …]
/system/ulib/ftl/utils/
A Dsemaphore.cpp39 fbl::Mutex* mutex = new fbl::Mutex(); in semCreate() local
40 SEM sem = reinterpret_cast<SEM>(mutex); in semCreate()
46 fbl::Mutex* mutex = reinterpret_cast<fbl::Mutex*>(*semp); in semDelete() local
47 delete mutex; in semDelete()
/system/dev/bluetooth/bt-transport-uart/
A Dbt-transport-uart.c72 mtx_t mutex; member
142 mtx_lock(&hci->mutex); in hci_build_read_wait_items()
144 mtx_unlock(&hci->mutex); in hci_build_read_wait_items()
180 mtx_lock(&hci->mutex); in hci_handle_cmd_read_events()
182 mtx_unlock(&hci->mutex); in hci_handle_cmd_read_events()
212 mtx_lock(&hci->mutex); in hci_handle_acl_read_events()
326 mtx_lock(&hci->mutex); in hci_handle_uart_read_events()
339 mtx_lock(&hci->mutex); in hci_read_thread()
388 mtx_lock(&hci->mutex); in hci_read_thread()
396 mtx_lock(&hci->mutex); in hci_open_channel()
[all …]
/system/ulib/sync/include/lib/sync/internal/
A Dcondition-template.h27 static zx_futex_t* get_futex(Mutex* mutex);
32 static zx_status_t lock(Mutex* mutex, int* mutex_lock_err);
39 Mutex* mutex, int waiters_delta, int* mutex_lock_err);
42 static void unlock(Mutex* mutex);
101 static inline zx_status_t timedwait(Condition* c, Mutex* mutex, zx_time_t deadline, in timedwait() argument
120 MutexOps<Mutex>::unlock(mutex); in timedwait()
181 if (MutexOps<Mutex>::lock(mutex, mutex_lock_err) != ZX_OK) { in timedwait()
221 zx_status_t status = MutexOps<Mutex>::lock_with_waiters(mutex, waiters_delta, mutex_lock_err); in timedwait()
227 sync_completion_signal_requeue(&node.prev->ready, MutexOps<Mutex>::get_futex(mutex)); in timedwait()
/system/ulib/fit/
A Dsingle_threaded_executor.cpp55 std::mutex mutex_;
94 std::lock_guard<std::mutex> lock(guarded_.mutex_); in ~dispatcher_impl()
104 std::lock_guard<std::mutex> lock(guarded_.mutex_); in shutdown()
119 std::lock_guard<std::mutex> lock(guarded_.mutex_); in schedule_task()
151 std::lock_guard<std::mutex> lock(guarded_.mutex_); in suspend_current_task()
165 std::unique_lock<std::mutex> lock(guarded_.mutex_); in wait_for_runnable_tasks()
191 std::lock_guard<std::mutex> lock(guarded_.mutex_); in run_task()
199 std::lock_guard<std::mutex> lock(guarded_.mutex_); in duplicate_ticket()
209 std::lock_guard<std::mutex> lock(guarded_.mutex_); in resolve_ticket()
/system/dev/audio/usb-audio/
A Dusb-midi-sink.c30 mtx_t mutex; member
65 mtx_lock(&sink->mutex); in usb_midi_sink_write_complete()
70 mtx_unlock(&sink->mutex); in usb_midi_sink_write_complete()
99 mtx_lock(&sink->mutex); in usb_midi_sink_open()
106 mtx_unlock(&sink->mutex); in usb_midi_sink_open()
114 mtx_lock(&sink->mutex); in usb_midi_sink_close()
116 mtx_unlock(&sink->mutex); in usb_midi_sink_close()
139 mtx_lock(&sink->mutex); in usb_midi_sink_write()
144 mtx_unlock(&sink->mutex); in usb_midi_sink_write()
A Dusb-midi-source.c31 mtx_t mutex; member
64 mtx_lock(&source->mutex); in usb_midi_source_read_complete()
78 mtx_unlock(&source->mutex); in usb_midi_source_read_complete()
110 mtx_lock(&source->mutex); in usb_midi_source_open()
132 mtx_unlock(&source->mutex); in usb_midi_source_open()
140 mtx_lock(&source->mutex); in usb_midi_source_close()
142 mtx_unlock(&source->mutex); in usb_midi_source_close()
158 mtx_lock(&source->mutex); in usb_midi_source_read()
185 mtx_unlock(&source->mutex); in usb_midi_source_read()
/system/dev/ethernet/rndis/
A Drndishost.c61 mtx_t mutex; member
163 mtx_lock(&eth->mutex); in rndis_read_complete()
190 mtx_unlock(&eth->mutex); in rndis_read_complete()
202 mtx_lock(&eth->mutex); in rndis_write_complete()
219 mtx_unlock(&eth->mutex); in rndis_write_complete()
250 mtx_lock(&eth->mutex); in rndishost_stop()
259 mtx_lock(&eth->mutex); in rndishost_start()
278 mtx_lock(&eth->mutex); in rndishost_queue_tx()
334 mtx_lock(&eth->mutex); in rndishost_release()
464 mtx_lock(&eth->mutex); in rndis_start_thread()
[all …]
/system/utest/core/c11-mutex/
A Drules.mk14 $(LOCAL_DIR)/mutex.c
16 MODULE_NAME := c11-mutex-test
/system/utest/core/sync-mutex/
A Drules.mk14 $(LOCAL_DIR)/mutex.c \
16 MODULE_NAME := sync-mutex-test
/system/dev/ethernet/asix-88772b/
A Dasix-88772b.c72 mtx_t mutex; member
246 mtx_lock(&eth->mutex); in ax88772b_read_complete()
273 mtx_unlock(&eth->mutex); in ax88772b_read_complete()
284 mtx_lock(&eth->mutex); in ax88772b_write_complete()
321 mtx_lock(&eth->mutex); in ax88772b_interrupt_complete()
379 mtx_lock(&eth->mutex); in ax88772b_queue_tx()
401 mtx_lock(&eth->mutex); in ax88772b_unbind()
452 mtx_lock(&eth->mutex); in ax88772b_stop()
461 mtx_lock(&eth->mutex); in ax88772b_start()
498 mtx_lock(&eth->mutex); in ax88772b_set_param()
[all …]

Completed in 41 milliseconds

12