Home
last modified time | relevance | path

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

12345678

/system/chre/util/tests/
Dconditional_lock_guard_test.cc44 MockMutex mutex; in TEST() local
45 ASSERT_EQ(mutex.getLockCount(), 0); in TEST()
48 ConditionalLockGuard<MockMutex> lock(mutex, true); in TEST()
49 EXPECT_EQ(mutex.getLockCount(), 1); in TEST()
52 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
56 MockMutex mutex; in TEST() local
57 ASSERT_EQ(mutex.getLockCount(), 0); in TEST()
60 ConditionalLockGuard<MockMutex> lock(mutex, false); in TEST()
61 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
64 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
Dlock_guard_test.cc44 MockMutex mutex; in TEST() local
45 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
48 LockGuard<MockMutex> lock(mutex); in TEST()
49 EXPECT_EQ(mutex.getLockCount(), 1); in TEST()
52 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
/system/chre/chpp/platform/linux/include/chpp/platform/
Dplatform_mutex.h30 static inline void chppMutexInit(struct ChppMutex *mutex) { in chppMutexInit() argument
31 pthread_mutex_init(&mutex->lock, NULL); in chppMutexInit()
34 static inline void chppMutexDeinit(struct ChppMutex *mutex) { in chppMutexDeinit() argument
35 pthread_mutex_destroy(&mutex->lock); in chppMutexDeinit()
38 static inline void chppMutexLock(struct ChppMutex *mutex) { in chppMutexLock() argument
39 pthread_mutex_lock(&mutex->lock); in chppMutexLock()
42 static inline void chppMutexUnlock(struct ChppMutex *mutex) { in chppMutexUnlock() argument
43 pthread_mutex_unlock(&mutex->lock); in chppMutexUnlock()
Dplatform_condition_variable.h45 struct ChppMutex *mutex) { in chppConditionVariableWait() argument
46 return pthread_cond_wait(&cv->cond, &mutex->lock) == 0; in chppConditionVariableWait()
50 struct ChppConditionVariable *cv, struct ChppMutex *mutex, in chppConditionVariableTimedWait() argument
59 return pthread_cond_timedwait(&cv->cond, &mutex->lock, &now) == 0; in chppConditionVariableTimedWait()
/system/chre/chpp/platform/linux/
Dnotifier.c35 chppMutexInit(&notifier->mutex); in chppPlatformNotifierInit()
41 chppMutexDeinit(&notifier->mutex); in chppPlatformNotifierDeinit()
45 chppMutexLock(&notifier->mutex); in chppPlatformNotifierGetSignal()
50 chppMutexUnlock(&notifier->mutex); in chppPlatformNotifierGetSignal()
55 chppMutexLock(&notifier->mutex); in chppPlatformNotifierWait()
58 pthread_cond_wait(&notifier->cond, &notifier->mutex.lock); in chppPlatformNotifierWait()
63 chppMutexUnlock(&notifier->mutex); in chppPlatformNotifierWait()
77 chppMutexLock(&notifier->mutex); in chppPlatformNotifierTimedWait()
86 pthread_cond_timedwait(&notifier->cond, &notifier->mutex.lock, &absTime); in chppPlatformNotifierTimedWait()
92 chppMutexUnlock(&notifier->mutex); in chppPlatformNotifierTimedWait()
[all …]
Dlink.c49 chppMutexLock(&params->mutex); in linkSendThread()
71 chppMutexUnlock(&params->mutex); in linkSendThread()
80 chppMutexInit(&params->mutex); in chppPlatformLinkInit()
94 chppMutexDeinit(&params->mutex); in chppPlatformLinkDeinit()
100 chppMutexLock(&params->mutex); in chppPlatformLinkSend()
110 chppMutexUnlock(&params->mutex); in chppPlatformLinkSend()
/system/chre/platform/zephyr/include/chre/target_platform/
Dcondition_variable_impl.h34 inline void ConditionVariable::wait(Mutex &mutex) { in wait() argument
35 k_condvar_wait(&condvar, &(mutex.mutex), K_FOREVER); in wait()
38 inline bool ConditionVariable::wait_for(Mutex &mutex, Nanoseconds timeout) { in wait_for() argument
39 return (k_condvar_wait(&condvar, &(mutex.mutex), in wait_for()
Dmutex_base_impl.h25 k_mutex_init(&mutex); in Mutex()
31 k_mutex_lock(&mutex, K_FOREVER); in lock()
35 return (k_mutex_lock(&mutex, K_NO_WAIT) == 0); in try_lock()
39 k_mutex_unlock(&mutex); in unlock()
/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/
Dsnapuserd_transitions.cpp170 std::lock_guard<std::mutex> lock(lock_); in MonitorMerge()
179 std::lock_guard<std::mutex> lock(lock_); in InitiateMerge()
196 std::unique_lock<std::mutex> lock(lock_); in WaitForMergeBegin()
250 std::lock_guard<std::mutex> lock(lock_); in ReadAheadIOCompleted()
268 std::unique_lock<std::mutex> lock(lock_); in WaitForMergeReady()
290 std::lock_guard<std::mutex> lock(lock_); in NotifyRAForMergeReady()
303 std::lock_guard<std::mutex> lock(lock_); in MergeFailed()
312 std::lock_guard<std::mutex> lock(lock_); in MergeCompleted()
338 std::lock_guard<std::mutex> lock(lock_); in NotifyIOTerminated()
346 std::lock_guard<std::mutex> lock(lock_); in IsIOTerminated()
[all …]
Dsnapuserd_server.h100 std::mutex lock_;
128 HandlerList::iterator FindHandler(std::lock_guard<std::mutex>* proof_of_lock,
131 double GetMergePercentage(std::lock_guard<std::mutex>* proof_of_lock);
132 void TerminateMergeThreads(std::lock_guard<std::mutex>* proof_of_lock);
134 bool UpdateVerification(std::lock_guard<std::mutex>* proof_of_lock);
151 bool StartMerge(std::lock_guard<std::mutex>* proof_of_lock,
/system/chre/chpp/include/chpp/
Dmutex.h42 static void chppMutexInit(struct ChppMutex *mutex);
49 static void chppMutexDeinit(struct ChppMutex *mutex);
56 static void chppMutexLock(struct ChppMutex *mutex);
63 static void chppMutexUnlock(struct ChppMutex *mutex);
/system/security/keystore2/src/km_compat/
Dkm_compat_service.cpp26 static std::mutex mutex; in addKeyMintDeviceService() local
27 std::lock_guard<std::mutex> lock(mutex); in addKeyMintDeviceService()
/system/chre/platform/linux/include/chre/target_platform/
Dcondition_variable_impl.h32 inline void ConditionVariable::wait(Mutex &mutex) { in wait() argument
33 mConditionVariable.wait(mutex); in wait()
36 inline bool ConditionVariable::wait_for(Mutex &mutex, Nanoseconds timeout) { in wait_for() argument
38 mutex, std::chrono::nanoseconds(timeout.toRawNanoseconds())); in wait_for()
/system/libhidl/base/
DSynchronizedQueue.h48 std::unique_lock<std::mutex> lock() { in lock()
49 return std::unique_lock<std::mutex>(mMutex); in lock()
61 std::mutex mMutex;
73 std::unique_lock<std::mutex> lock(mMutex); in wait_pop()
89 std::unique_lock<std::mutex> lock(mMutex); in push()
104 std::unique_lock<std::mutex> lock(mMutex); in size()
/system/core/libutils/include/utils/
DCondition.h69 status_t wait(Mutex& mutex);
71 status_t waitRelative(Mutex& mutex, nsecs_t reltime);
117 inline status_t Condition::wait(Mutex& mutex) { in wait() argument
118 return -pthread_cond_wait(&mCond, &mutex.mMutex); in wait()
120 inline status_t Condition::waitRelative(Mutex& mutex, nsecs_t reltime) { in waitRelative() argument
150 return -pthread_cond_timedwait(&mCond, &mutex.mMutex, &ts); in waitRelative()
DMutex.h132 inline explicit Autolock(Mutex& mutex) ACQUIRE(mutex) : mLock(mutex) { mLock.lock(); } in Autolock() argument
133 inline explicit Autolock(Mutex* mutex) ACQUIRE(mutex) : mLock(*mutex) { mLock.lock(); } in Autolock() argument
/system/chre/platform/slpi/include/chre/target_platform/
Dcondition_variable_impl.h39 inline void ConditionVariable::wait(Mutex &mutex) { in wait() argument
40 qurt_cond_wait(&mConditionVariable, &mutex.mMutex); in wait()
45 inline bool ConditionVariable::wait_for(Mutex &mutex, Nanoseconds timeout) { in wait_for() argument
65 wait(mutex); in wait_for()
/system/libhidl/transport/include/hidl/
DConcurrentMap.h34 std::unique_lock<std::mutex> _lock(mMutex); in set()
40 std::unique_lock<std::mutex> _lock(mMutex); in get()
49 std::unique_lock<std::mutex> _lock(mMutex); in erase()
54 std::unique_lock<std::mutex> _lock(mMutex); in eraseIfEqual()
67 std::unique_lock<std::mutex> lock() { return std::unique_lock<std::mutex>(mMutex); } in lock()
89 mutable std::mutex mMutex;
/system/libhidl/transport/token/1.0/utils/
DHybridInterface.cpp30 std::mutex gTokenManagerLock;
35 std::lock_guard<std::mutex> lock(gTokenManagerLock); in serviceDied()
79 std::lock_guard<std::mutex> lock(gTokenManagerLock); in retrieveHalInterface()
94 std::lock_guard<std::mutex> lock(gTokenManagerLock); in createHalToken()
108 std::lock_guard<std::mutex> lock(gTokenManagerLock); in deleteHalToken()
/system/memory/libmemunreachable/
DAtomicState.h43 std::lock_guard<std::mutex> lock(m_); in set()
63 std::lock_guard<std::mutex> lock(m_); in transition_or()
82 std::unique_lock<std::mutex> lock(m_); in wait_for_either_of()
89 std::mutex m_;
/system/unwinding/libunwindstack/
DThreadEntry.h65 std::mutex mutex_;
66 std::mutex wait_mutex_;
71 static std::mutex entries_mutex_;
DThreadEntry.cpp32 std::mutex ThreadEntry::entries_mutex_;
45 std::lock_guard<std::mutex> guard(entries_mutex_); in Get()
62 std::lock_guard<std::mutex> guard(entries_mutex_); in Remove()
79 std::unique_lock<std::mutex> lock(wait_mutex_); in Wait()
/system/chre/host/hal_generic/aidl/
Devent_logger.cc47 std::lock_guard<std::mutex> lock(mQueuesMutex); in logNanoappLoad()
58 std::lock_guard<std::mutex> lock(mQueuesMutex); in logNanoappUnload()
67 std::lock_guard<std::mutex> lock(mQueuesMutex); in logContextHubRestart()
73 std::lock_guard<std::mutex> lock(mQueuesMutex); in logMessageToNanoapp()
84 std::lock_guard<std::mutex> lock(mQueuesMutex); in logMessageFromNanoapp()
96 std::lock_guard<std::mutex> lock(mQueuesMutex); in dump()
/system/chre/platform/linux/
Dplatform_log.cc32 std::unique_lock<std::mutex> lock(mMutex); in logLooper()
62 std::unique_lock<std::mutex> lock(mMutex); in ~PlatformLog()
76 std::unique_lock<std::mutex> lock(mMutex); in logVa()
/system/gsid/
Dgsi_service.cpp135 std::lock_guard<std::mutex> guard(lock_); in openInstall()
157 std::lock_guard<std::mutex> guard(lock_); in closeInstall()
192 std::lock_guard<std::mutex> guard(lock_); in createPartition()
233 std::lock_guard<std::mutex> guard(lock_); in closePartition()
250 std::lock_guard<std::mutex> guard(lock_); in commitGsiChunkFromStream()
262 std::lock_guard<std::mutex> guard(progress_lock_); in StartAsyncOperation()
271 std::lock_guard<std::mutex> guard(progress_lock_); in UpdateProgress()
283 std::lock_guard<std::mutex> guard(progress_lock_); in getInstallProgress()
294 std::lock_guard<std::mutex> guard(lock_); in commitGsiChunkFromAshmem()
318 std::lock_guard<std::mutex> guard(lock_); in enableGsiAsync()
[all …]

12345678