| /frameworks/libs/binary_translation/tests/ndk_program_tests/ |
| D | mutex_test.cc | 24 pthread_mutex_t mutex; in TEST() local
26 ASSERT_EQ(pthread_mutex_init(&mutex, &attr), 0); in TEST()
27 ASSERT_EQ(pthread_mutex_destroy(&mutex), 0); in TEST()
32 pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; in TEST() local
33 ASSERT_EQ(pthread_mutex_lock(&mutex), 0); in TEST()
34 ASSERT_EQ(pthread_mutex_trylock(&mutex), EBUSY); in TEST()
35 ASSERT_EQ(pthread_mutex_unlock(&mutex), 0); in TEST()
36 ASSERT_EQ(pthread_mutex_destroy(&mutex), 0); in TEST()
43 pthread_mutex_t mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP; in TEST() local
45 pthread_mutex_t mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER; in TEST()
[all …]
|
| D | condvar_test.cc | 23 pthread_mutex_t mutex; member
29 pthread_mutex_lock(&data->mutex); in ThreadCondVarFunc()
32 pthread_mutex_unlock(&data->mutex); in ThreadCondVarFunc()
48 ASSERT_EQ(pthread_mutex_lock(&data.mutex), 0); in TEST()
52 ASSERT_EQ(pthread_cond_wait(&data.cond, &data.mutex), 0); in TEST()
54 ASSERT_EQ(pthread_mutex_unlock(&data.mutex), 0); in TEST()
56 ASSERT_EQ(pthread_mutex_destroy(&data.mutex), 0); in TEST()
|
| /frameworks/native/services/surfaceflinger/tests/unittests/ |
| D | BackgroundExecutorTest.cpp | 29 std::mutex mutex; in TEST_F() local
34 {[&mutex, &condition_variable, &backgroundTaskComplete]() { in TEST_F()
35 std::lock_guard<std::mutex> lock{mutex}; in TEST_F()
40 std::unique_lock<std::mutex> lock{mutex}; in TEST_F()
46 std::mutex mutex; in TEST_F() local
52 std::thread([&mutex, &condition_variable, &backgroundTaskCompleteCount]() { in TEST_F()
54 {[&mutex, &condition_variable, &backgroundTaskCompleteCount]() { in TEST_F()
55 std::lock_guard<std::mutex> lock{mutex}; in TEST_F()
64 std::unique_lock<std::mutex> lock{mutex}; in TEST_F()
|
| D | WindowInfosListenerInvokerTest.cpp | 44 std::mutex mutex; in TEST_F() local
51 std::scoped_lock lock{mutex}; in TEST_F()
64 std::unique_lock<std::mutex> lock{mutex}; in TEST_F()
71 std::mutex mutex; in TEST_F() local
83 std::scoped_lock lock{mutex}; in TEST_F()
100 std::unique_lock<std::mutex> lock{mutex}; in TEST_F()
108 std::mutex mutex; in TEST_F() local
116 std::scoped_lock lock{mutex}; in TEST_F()
130 std::unique_lock lock{mutex}; in TEST_F()
139 std::unique_lock lock{mutex}; in TEST_F()
[all …]
|
| /frameworks/native/services/surfaceflinger/ |
| D | MutexUtils.h | 25 ConditionalLock(Mutex& mutex, bool lock) ACQUIRE(mutex) : mutex(mutex), lock(lock) { in ConditionalLock()
26 if (lock) mutex.lock(); in ConditionalLock()
30 if (lock) mutex.unlock(); in RELEASE()
33 Mutex& mutex; member
38 TimedLock(Mutex& mutex, nsecs_t timeout, const char* whence) ACQUIRE(mutex) in TimedLock()
39 : mutex(mutex), status(mutex.timedLock(timeout)) { in TimedLock()
44 if (locked()) mutex.unlock(); in RELEASE()
49 Mutex& mutex; member
|
| /frameworks/native/libs/ftl/ |
| D | shared_mutex_test.cpp | 24 ftl::SharedMutex mutex; in TEST() local
25 std::shared_lock shared_lock(mutex); in TEST()
27 { std::shared_lock shared_lock2(mutex); } in TEST()
31 ftl::SharedMutex mutex; in TEST() local
32 std::unique_lock unique_lock(mutex); in TEST()
37 void foo() FTL_ATTRIBUTE(requires_shared_capability(mutex)) { num++; } in TEST()
38 void bar() FTL_ATTRIBUTE(requires_capability(mutex)) { num++; } in TEST()
40 std::shared_lock shared_lock(mutex); in TEST()
43 ftl::SharedMutex mutex; in TEST() member
50 s.mutex.lock_shared(); in TEST()
[all …]
|
| D | fake_guard_test.cpp | 28 std::mutex mutex; in TEST() member
29 int x FTL_ATTRIBUTE(guarded_by(mutex)) = -1; in TEST()
33 ftl::FakeGuard guard(mutex); in TEST()
37 return FTL_FAKE_GUARD(mutex, x + 1); in TEST()
41 return [this]() FTL_FAKE_GUARD(mutex) { return x; }; in TEST()
|
| /frameworks/av/services/audioflinger/ |
| D | Threads.h | 52 static audio_utils::mutex* ThreadBase_ThreadLoop;
111 audio_utils::mutex& mutex() const RETURN_CAPABILITY(audio_utils::ConfigEvent_Mutex) { in mutex() function
116 mutable audio_utils::mutex mMutex{audio_utils::MutexOrder::kConfigEvent_Mutex};
122 bool mWaitStatus GUARDED_BY(mutex()); // true if sender is waiting for status
124 bool mRequiresSystemReady GUARDED_BY(mutex());
329 REQUIRES(mutex()) {} in setVolumeForOutput_l()
343 status_t sendConfigEvent_l(sp<ConfigEvent>& event) REQUIRES(mutex());
347 audio_port_handle_t portId = AUDIO_PORT_HANDLE_NONE) final REQUIRES(mutex());
351 REQUIRES(mutex());
352 status_t sendSetParameterConfigEvent_l(const String8& keyValuePair) final REQUIRES(mutex());
[all …]
|
| D | AudioFlinger.h | 284 audio_utils::mutex& clientMutex() const final in clientMutex()
315 audio_utils::mutex& mutex() const final in mutex() function
319 REQUIRES(mutex());
325 void closeThreadInternal_l(const sp<IAfPlaybackThread>& thread) final REQUIRES(mutex());
326 void closeThreadInternal_l(const sp<IAfRecordThread>& thread) final REQUIRES(mutex());
328 IAfPlaybackThread* primaryPlaybackThread_l() const final REQUIRES(mutex());
330 REQUIRES(mutex());
331 IAfRecordThread* checkRecordThread_l(audio_io_handle_t input) const final REQUIRES(mutex());
332 IAfMmapThread* checkMmapThread_l(audio_io_handle_t io) const final REQUIRES(mutex());
341 const String8& outputDeviceAddress) final REQUIRES(mutex());
[all …]
|
| D | IAfThread.h | 76 virtual audio_utils::mutex& mutex() const
79 REQUIRES(mutex()) EXCLUDES_ThreadBase_Mutex = 0; // Tracks
83 REQUIRES(mutex()) = 0;
85 REQUIRES(mutex()) = 0;
87 REQUIRES(mutex()) = 0;
89 REQUIRES(mutex()) = 0;
95 REQUIRES(mutex()) = 0;
109 REQUIRES(mutex(), audio_utils::ThreadBase_Mutex) = 0;
177 virtual void setVolumeForOutput_l(float left, float right) const REQUIRES(mutex()) = 0;
186 REQUIRES(mutex()) = 0;
[all …]
|
| D | MelReporter.h | 32 virtual audio_utils::mutex& mutex() const
36 REQUIRES(mutex()) = 0;
121 audio_utils::mutex& mutex() const RETURN_CAPABILITY(audio_utils::MelReporter_Mutex) { in mutex() function
126 void stopMelComputationForPatch_l(const ActiveMelPatch& patch) REQUIRES(mutex());
129 void startMelComputationForActivePatch_l(const ActiveMelPatch& patch) REQUIRES(mutex());
132 activePatchStreamHandle_l(audio_io_handle_t streamHandle) REQUIRES(mutex());
134 bool useHalSoundDoseInterface_l() REQUIRES(mutex());
145 mutable audio_utils::mutex mMutex{audio_utils::MutexOrder::kMelReporter_Mutex};
147 GUARDED_BY(mutex());
148 std::unordered_map<audio_port_handle_t, int> mActiveDevices GUARDED_BY(mutex());
[all …]
|
| D | MelReporter.cpp | 65 audio_utils::lock_guard _l(mutex()); in activateInternalSoundDoseComputation()
90 audio_utils::lock_guard _laf(mAfMelReporterCallback->mutex()); // AudioFlinger_Mutex in updateMetadataForCsd()
91 audio_utils::lock_guard _l(mutex()); in updateMetadataForCsd()
162 audio_utils::lock_guard _afl(mAfMelReporterCallback->mutex()); // AudioFlinger_Mutex in onCreateAudioPatch()
163 audio_utils::lock_guard _l(mutex()); in onCreateAudioPatch()
200 audio_utils::lock_guard _laf(mAfMelReporterCallback->mutex()); in startMelComputationForDeviceId()
201 audio_utils::lock_guard _l(mutex()); in startMelComputationForDeviceId()
226 audio_utils::lock_guard _l(mutex()); in onReleaseAudioPatch()
239 audio_utils::lock_guard _afl(mAfMelReporterCallback->mutex()); // AudioFlinger_Mutex in onReleaseAudioPatch()
240 audio_utils::lock_guard _l(mutex()); in onReleaseAudioPatch()
[all …]
|
| /frameworks/native/include/ftl/ |
| D | fake_guard.h | 61 explicit FakeGuard(const Mutex& mutex) FTL_ATTRIBUTE(acquire_capability(mutex)) {} in FakeGuard()
72 #define FTL_FAKE_GUARD1(mutex) [[using clang: acquire_capability(mutex), release_capability(mutex)]]
74 #define FTL_FAKE_GUARD1(mutex) \ argument
75 FTL_ATTRIBUTE(acquire_capability(mutex)) \
76 FTL_ATTRIBUTE(release_capability(mutex))
79 #define FTL_FAKE_GUARD2(mutex, expr) \ argument
80 (android::ftl::FakeGuard(mutex), expr)
|
| /frameworks/av/media/module/libmediatranscoding/transcoder/tests/ |
| D | TranscoderTestUtils.h | 88 std::unique_lock<std::mutex> lock(mMutex); in onTrackFormatAvailable()
94 std::unique_lock<std::mutex> lock(mMutex); in onTrackFinished()
100 std::unique_lock<std::mutex> lock(mMutex); in onTrackStopped()
107 std::unique_lock<std::mutex> lock(mMutex); in onTrackError()
115 std::unique_lock<std::mutex> lock(mMutex); in waitUntilFinished()
123 std::unique_lock<std::mutex> lock(mMutex); in waitUntilTrackFormatAvailable()
136 std::mutex mMutex;
147 std::unique_lock<std::mutex> lock(mMutex); in onFinished()
155 std::unique_lock<std::mutex> lock(mMutex); in onError()
165 std::unique_lock<std::mutex> lock(mMutex); in onProgressUpdate()
[all …]
|
| /frameworks/av/media/libstagefright/renderfright/gl/ |
| D | ImageManager.cpp | 50 std::lock_guard<std::mutex> lock(mMutex); in ~ImageManager()
63 std::lock_guard<std::mutex> lock(barrier->mutex); in cacheAsync()
79 std::lock_guard<std::mutex> lock(barrier->mutex); in cache()
80 barrier->condition.wait(barrier->mutex, in cache()
81 [&]() REQUIRES(barrier->mutex) { return barrier->isOpen; }); in cache()
93 std::lock_guard<std::mutex> lock(mMutex); in queueOperation()
104 std::lock_guard<std::mutex> lock(mMutex); in threadMain()
110 std::lock_guard<std::mutex> lock(mMutex); in threadMain()
137 std::lock_guard<std::mutex> entryLock(entry.barrier->mutex); in threadMain()
|
| D | ImageManager.h | 35 std::mutex mutex; member
37 bool isOpen GUARDED_BY(mutex) = false;
38 status_t result GUARDED_BY(mutex) = NO_ERROR;
66 std::mutex mMutex;
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| D | Camera3OutputStreamInterface.cpp | 35 std::lock_guard<std::mutex> lock(mLock); in add()
40 std::lock_guard<std::mutex> lock(mLock); in remove()
45 std::lock_guard<std::mutex> lock(mLock); in get()
54 std::lock_guard<std::mutex> lock(mLock); in operator []()
59 std::lock_guard<std::mutex> lock(mLock); in size()
64 std::lock_guard<std::mutex> lock(mLock); in clear()
69 std::lock_guard<std::mutex> lock(mLock); in getStreamIds()
78 std::lock_guard<std::mutex> lock(other.mLock); in StreamSet()
|
| D | BufferUtils.cpp | 32 std::lock_guard<std::mutex> oLock(other.mInflightLock); in takeInflightBufferMap()
33 std::lock_guard<std::mutex> lock(mInflightLock); in takeInflightBufferMap()
42 std::lock_guard<std::mutex> oLock(other.mRequestedBuffersLock); in takeRequestedBufferMap()
43 std::lock_guard<std::mutex> lock(mRequestedBuffersLock); in takeRequestedBufferMap()
52 std::lock_guard<std::mutex> oLock(other.mBufferIdMapLock); in takeBufferCaches()
53 std::lock_guard<std::mutex> lock(mBufferIdMapLock); in takeBufferCaches()
65 std::lock_guard<std::mutex> lock(mBufferIdMapLock); in getBufferId()
80 std::lock_guard<std::mutex> lock(mBufferIdMapLock); in tryCreateBufferCache()
87 std::lock_guard<std::mutex> lock(mBufferIdMapLock); in removeInactiveBufferCaches()
100 std::lock_guard<std::mutex> lock(mBufferIdMapLock); in removeOneBufferCache()
[all …]
|
| /frameworks/base/libs/usb/tests/accessorytest/ |
| D | audio.c | 47 static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; variable
58 pthread_mutex_lock(&mutex); in get_empty()
61 pthread_cond_wait(&empty_cond, &mutex); in get_empty()
71 pthread_mutex_unlock(&mutex); in get_empty()
77 pthread_mutex_lock(&mutex); in put_empty()
85 pthread_mutex_unlock(&mutex); in put_empty()
92 pthread_mutex_lock(&mutex); in get_full()
95 pthread_cond_wait(&full_cond, &mutex); in get_full()
105 pthread_mutex_unlock(&mutex); in get_full()
111 pthread_mutex_lock(&mutex); in put_full()
[all …]
|
| /frameworks/av/media/module/bufferpool/2.0/tests/ |
| D | cond.cpp | 164 IpcMutex *mutex = nullptr; in doReceiver() local
179 mutex = IpcMutex::Import(mem); in doReceiver()
180 pthread_mutex_lock(&(mutex->lock)); in doReceiver()
181 while (mutex->signalled != true) { in doReceiver()
182 pthread_cond_wait(&(mutex->cond), &(mutex->lock)); in doReceiver()
184 val = mutex->counter; in doReceiver()
185 pthread_mutex_unlock(&(mutex->lock)); in doReceiver()
222 IpcMutex *mutex = nullptr; in TEST_F() local
230 mutex = new(mem) IpcMutex(); in TEST_F()
231 mutex->init(); in TEST_F()
[all …]
|
| /frameworks/av/camera/ndk/ndk_vendor/tests/ |
| D | ACameraManagerTest.cpp | 42 std::lock_guard<std::mutex> lock(thiz->mMutex); in onAvailable()
54 std::lock_guard<std::mutex> lock(thiz->mMutex); in onUnavailable()
71 std::lock_guard<std::mutex> lock(thiz->mMutex); in onPhysicalCameraAvailable()
83 std::lock_guard<std::mutex> lock(thiz->mMutex); in onPhysicalCameraUnavailable()
89 std::lock_guard<std::mutex> lock(mMutex); in resetCount()
98 std::lock_guard<std::mutex> lock(mMutex); in getAvailableCount()
103 std::lock_guard<std::mutex> lock(mMutex); in getUnavailableCount()
108 std::lock_guard<std::mutex> lock(mMutex); in getPhysicalCameraAvailableCount()
113 std::lock_guard<std::mutex> lock(mMutex); in getUnavailablePhysicalCameras()
118 std::lock_guard<std::mutex> lock(mMutex); in isAvailable()
[all …]
|
| /frameworks/base/tests/ChoreographerTests/jni/ |
| D | android_view_tests_ChoreographerNativeTest.cpp | 58 std::mutex mutex; member
67 int count GUARDED_BY(mutex){0}; in GUARDED_BY()
68 std::chrono::nanoseconds frameTime GUARDED_BY(mutex){0}; in GUARDED_BY()
70 std::chrono::nanoseconds endTime GUARDED_BY(mutex){0}; in GUARDED_BY()
83 std::lock_guard<std::mutex> _l(cb->mutex); in vsyncCallback()
138 std::scoped_lock<std::mutex> conditionLock(cb.mutex); in android_view_ChoreographerNativeTest_testPostVsyncCallbackAtFrameRate()
139 ASSERT(cb.condition.wait_for(cb.mutex, 2 * kMaxRuntime, [&cb] { return cb.callbacksComplete; }), in android_view_ChoreographerNativeTest_testPostVsyncCallbackAtFrameRate()
|
| /frameworks/av/services/camera/libcameraservice/utils/ |
| D | SessionStatsBuilder.cpp | 37 std::lock_guard<std::mutex> l(mLock); in addStream()
44 std::lock_guard<std::mutex> l(mLock); in removeStream()
53 std::lock_guard<std::mutex> l(mLock); in buildAndReset()
93 std::lock_guard<std::mutex> l(mLock); in startCounter()
98 std::lock_guard<std::mutex> l(mLock); in stopCounter()
104 std::lock_guard<std::mutex> l(mLock); in incCounter()
124 std::lock_guard<std::mutex> l(mLock); in stopCounter()
132 std::lock_guard<std::mutex> l(mLock); in incResultCounter()
140 std::lock_guard<std::mutex> l(mLock); in onDeviceError()
146 std::lock_guard<std::mutex> l(mLock); in incFpsRequestedCount()
|
| /frameworks/base/media/jni/soundpool/ |
| D | SoundPool.cpp | 109 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in load()
116 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in unload()
134 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in play()
153 auto apiLock = std::make_unique<std::lock_guard<std::mutex>>(mApiLock); in autoPause()
160 auto apiLock = std::make_unique<std::lock_guard<std::mutex>>(mApiLock); in autoResume()
167 auto apiLock = std::make_unique<std::lock_guard<std::mutex>>(mApiLock); in mute()
174 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in pause()
183 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in resume()
192 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in stop()
203 auto apiLock = kUseApiLock ? std::make_unique<std::lock_guard<std::mutex>>(mApiLock) : nullptr; in setVolume()
[all …]
|
| /frameworks/av/services/oboeservice/ |
| D | AAudioClientTracker.cpp | 76 const std::lock_guard<std::mutex> lock(mLock); in registerClient()
105 const std::lock_guard<std::mutex> lock(mLock); in unregisterClient()
110 const std::lock_guard<std::mutex> lock(mLock); in getStreamCount()
123 const std::lock_guard<std::mutex> lock(mLock); in registerClientStream()
132 const std::lock_guard<std::mutex> lock(mLock); in unregisterClientStream()
145 const std::lock_guard<std::mutex> lock(mLock); in setExclusiveEnabled()
150 const std::lock_guard<std::mutex> lock(mLock); in isExclusiveEnabled()
175 const std::lock_guard<std::mutex> lock(mLock); in getStreamCount()
181 const std::lock_guard<std::mutex> lock(mLock); in registerClientStream()
188 const std::lock_guard<std::mutex> lock(mLock); in unregisterClientStream()
[all …]
|