| /foundation/multimedia/histreamer/engine/foundation/osal/thread/ |
| D | scoped_lock.cpp | 26 ScopedLock::ScopedLock() : mutex_(nullptr) in ScopedLock()
30 ScopedLock::ScopedLock(Mutex& mutex) : mutex_(&mutex) in ScopedLock()
32 mutex_->Lock(); in ScopedLock()
37 if (mutex_ != nullptr) { in ~ScopedLock()
38 mutex_->Unlock(); in ~ScopedLock()
39 mutex_ = nullptr; in ~ScopedLock()
45 mutex_ = nullptr; in ScopedLock()
52 if (mutex_) { in operator =()
53 mutex_->Unlock(); in operator =()
55 mutex_ = other.mutex_; in operator =()
[all …]
|
| /foundation/graphic/utils/interfaces/innerkits/ |
| D | graphic_mutex.h | 37 mutex_ = CreateMutex(NULL, FALSE, NULL); in GraphicMutex()
38 initFlag_ = (mutex_ != NULL); in GraphicMutex()
40 initFlag_ = (pthread_mutex_init(&mutex_, NULL) == 0); in GraphicMutex()
42 initFlag_ = (LOS_MuxCreate(&mutex_) == LOS_OK); in GraphicMutex()
53 CloseHandle(mutex_); in ~GraphicMutex()
55 pthread_mutex_destroy(&mutex_); in ~GraphicMutex()
57 LOS_MuxDelete(mutex_); in ~GraphicMutex()
67 return (WaitForSingleObject(mutex_, INFINITE) == WAIT_OBJECT_0); in Lock()
69 return (pthread_mutex_lock(&mutex_) == 0); in Lock()
71 return (LOS_MuxPend(mutex_, LOS_WAIT_FOREVER) == LOS_OK); in Lock()
[all …]
|
| D | graphic_locker.h | 28 GraphicLocker(pthread_mutex_t& mutex) : mutex_(mutex) in GraphicLocker()
30 pthread_mutex_lock(&mutex_); in GraphicLocker()
35 pthread_mutex_unlock(&mutex_); in ~GraphicLocker()
43 pthread_mutex_t& mutex_;
53 pthread_mutex_init(&mutex_, &attr); in GraphicMutex()
57 pthread_mutex_destroy(&mutex_); in ~GraphicMutex()
61 pthread_mutex_lock(&mutex_); in Lock()
65 pthread_mutex_unlock(&mutex_); in Unlock()
73 pthread_mutex_t mutex_;
92 GraphicLockGuard(GraphicMutex& mutex) : mutex_(mutex) in GraphicLockGuard()
[all …]
|
| /foundation/appexecfwk/appexecfwk_lite/utils/bundle_lite/ |
| D | mutex_lock.h | 25 explicit Lock(T &mutex) : mutex_(&mutex) in Lock()
27 if (mutex_ != nullptr) { in Lock()
28 mutex_->Lock(); in Lock()
34 if (mutex_ != nullptr) { in ~Lock()
35 mutex_->UnLock(); in ~Lock()
39 T *mutex_;
46 pthread_mutex_init(&mutex_, nullptr); in Mutex()
51 pthread_mutex_destroy(&mutex_); in ~Mutex()
56 pthread_mutex_lock(&mutex_); in Lock()
61 pthread_mutex_unlock(&mutex_); in UnLock()
[all …]
|
| /foundation/distributeddatamgr/distributeddatamgr/frameworks/common/ |
| D | concurrent_map.h | 49 std::lock_guard<decltype(mutex_)> lock(mutex_);
65 std::lock_guard<decltype(mutex_)> lock(mutex_);
73 std::lock_guard<decltype(mutex_)> lock(mutex_); in Emplace()
80 std::lock_guard<decltype(mutex_)> lock(mutex_); in Find()
91 std::lock_guard<decltype(mutex_)> lock(mutex_); in Contains()
97 std::lock_guard<decltype(mutex_)> lock(mutex_); in Insert()
104 std::lock_guard<decltype(mutex_)> lock(mutex_); in Erase()
110 std::lock_guard<decltype(mutex_)> lock(mutex_); in Clear()
116 std::lock_guard<decltype(mutex_)> lock(mutex_); in Empty()
122 std::lock_guard<decltype(mutex_)> lock(mutex_); in Size()
[all …]
|
| /foundation/distributeddatamgr/distributeddatamgr/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| D | sync_observer.cpp | 25 std::lock_guard<decltype(mutex_)> lock(mutex_); in SyncObserver()
31 std::lock_guard<decltype(mutex_)> lock(mutex_); in Add()
38 std::lock_guard<decltype(mutex_)> lock(mutex_); in Clean()
45 std::lock_guard<decltype(mutex_)> lock(mutex_); in SyncCompleted()
|
| /foundation/multimedia/media_standard/services/services/player/client/ |
| D | player_client.cpp | 44 std::lock_guard<std::mutex> lock(mutex_); in ~PlayerClient()
55 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject()
69 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied()
79 std::lock_guard<std::mutex> lock(mutex_); in SetSource()
86 std::lock_guard<std::mutex> lock(mutex_); in SetSource()
100 std::lock_guard<std::mutex> lock(mutex_); in SetSource()
107 std::lock_guard<std::mutex> lock(mutex_); in Play()
114 std::lock_guard<std::mutex> lock(mutex_); in Prepare()
121 std::lock_guard<std::mutex> lock(mutex_); in PrepareAsync()
128 std::lock_guard<std::mutex> lock(mutex_); in Pause()
[all …]
|
| /foundation/multimedia/media_standard/services/services/recorder/client/ |
| D | recorder_client.cpp | 47 std::lock_guard<std::mutex> lock(mutex_); in ~RecorderClient()
56 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied()
66 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject()
80 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSource()
89 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncoder()
98 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSize()
107 std::lock_guard<std::mutex> lock(mutex_); in SetVideoFrameRate()
116 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncodingBitRate()
125 std::lock_guard<std::mutex> lock(mutex_); in SetCaptureRate()
134 std::lock_guard<std::mutex> lock(mutex_); in GetSurface()
[all …]
|
| /foundation/multimedia/media_standard/services/services/avcodec/client/ |
| D | avcodec_client.cpp | 47 std::lock_guard<std::mutex> lock(mutex_); in ~AVCodecClient()
56 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied()
66 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject()
80 std::lock_guard<std::mutex> lock(mutex_); in InitParameter()
89 std::lock_guard<std::mutex> lock(mutex_); in Configure()
98 std::lock_guard<std::mutex> lock(mutex_); in Prepare()
107 std::lock_guard<std::mutex> lock(mutex_); in Start()
116 std::lock_guard<std::mutex> lock(mutex_); in Stop()
125 std::lock_guard<std::mutex> lock(mutex_); in Flush()
134 std::lock_guard<std::mutex> lock(mutex_); in Reset()
[all …]
|
| /foundation/ai/engine/services/common/platform/event/source/ |
| D | event.cpp | 41 std::unique_lock<std::mutex> lock(mutex_); in Wait()
48 std::unique_lock<std::mutex> lock(mutex_); in Wait()
54 mutex_.lock(); in Signal()
57 mutex_.unlock(); in Signal()
64 mutex_.lock(); in Reset()
67 mutex_.unlock(); in Reset()
78 mutable std::mutex mutex_; member in OHOS::AI::Event
|
| /foundation/windowmanager/wmserver/src/ |
| D | window_manager_service.cpp | 45 windowRoot_ = new WindowRoot(mutex_, in WindowManagerService()
124 std::lock_guard<std::recursive_mutex> lock(mutex_); in CreateWindow()
137 std::lock_guard<std::recursive_mutex> lock(mutex_); in AddWindow()
149 std::lock_guard<std::recursive_mutex> lock(mutex_); in RemoveWindow()
157 std::lock_guard<std::recursive_mutex> lock(mutex_); in DestroyWindow()
169 std::lock_guard<std::recursive_mutex> lock(mutex_); in RequestFocus()
176 std::lock_guard<std::recursive_mutex> lock(mutex_); in SetWindowBackgroundBlur()
183 std::lock_guard<std::recursive_mutex> lock(mutex_); in SetAlpha()
190 std::lock_guard<std::recursive_mutex> lock(mutex_); in SaveAbilityToken()
197 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetAvoidAreaByType()
[all …]
|
| /foundation/communication/bluetooth/services/bluetooth_standard/service/src/common/ |
| D | adapter_device_config.cpp | 50 std::lock_guard<std::mutex> lg(mutex_); in Load()
77 std::lock_guard<std::mutex> lg(mutex_); in Save()
83 std::lock_guard<std::mutex> lg(mutex_); in SetValue()
89 std::lock_guard<std::mutex> lg(mutex_); in SetValue()
95 std::lock_guard<std::mutex> lg(mutex_); in GetValue()
101 std::lock_guard<std::mutex> lg(mutex_); in GetValue()
108 std::lock_guard<std::mutex> lg(mutex_); in GetValue()
115 std::lock_guard<std::mutex> lg(mutex_); in SetValue()
121 std::lock_guard<std::mutex> lg(mutex_); in SetValue()
128 std::lock_guard<std::mutex> lg(mutex_); in SetValue()
[all …]
|
| D | profile_config.cpp | 26 std::mutex mutex_ = {}; member
44 std::lock_guard<std::mutex> lock(pimpl->mutex_); in Load()
72 std::lock_guard<std::mutex> lock(pimpl->mutex_); in GetValue()
79 std::lock_guard<std::mutex> lock(pimpl->mutex_); in GetValue()
86 std::lock_guard<std::mutex> lock(pimpl->mutex_); in SetValue()
96 std::lock_guard<std::mutex> lock(pimpl->mutex_); in SetValue()
105 std::lock_guard<std::mutex> lock(pimpl->mutex_); in RemoveAddr()
114 std::lock_guard<std::mutex> lock(pimpl->mutex_); in RemoveProperty()
123 std::lock_guard<std::mutex> lock(pimpl->mutex_); in HasSection()
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/app/src/ |
| D | kvstore_resultset_impl.cpp | 37 std::shared_lock<std::shared_mutex> lock(this->mutex_); in GetCount()
48 std::shared_lock<std::shared_mutex> lock(this->mutex_); in GetPosition()
59 std::shared_lock<std::shared_mutex> lock(this->mutex_); in MoveToFirst()
70 std::shared_lock<std::shared_mutex> lock(this->mutex_); in MoveToLast()
81 std::shared_lock<std::shared_mutex> lock(this->mutex_); in MoveToNext()
92 std::shared_lock<std::shared_mutex> lock(this->mutex_); in MoveToPrevious()
103 std::shared_lock<std::shared_mutex> lock(this->mutex_); in Move()
114 std::shared_lock<std::shared_mutex> lock(this->mutex_); in MoveToPosition()
123 std::shared_lock<std::shared_mutex> lock(this->mutex_); in IsFirst()
132 std::shared_lock<std::shared_mutex> lock(this->mutex_); in IsLast()
[all …]
|
| /foundation/multimedia/media_standard/services/services/avmetadatahelper/client/ |
| D | avmetadatahelper_client.cpp | 41 std::lock_guard<std::mutex> lock(mutex_); in ~AVMetadataHelperClient()
50 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied()
56 std::lock_guard<std::mutex> lock(mutex_); in SetSource()
64 std::lock_guard<std::mutex> lock(mutex_); in SetSource()
72 std::lock_guard<std::mutex> lock(mutex_); in ResolveMetadata()
79 std::lock_guard<std::mutex> lock(mutex_); in ResolveMetadata()
86 std::lock_guard<std::mutex> lock(mutex_); in FetchArtPicture()
94 std::lock_guard<std::mutex> lock(mutex_); in FetchFrameAtTime()
101 std::lock_guard<std::mutex> lock(mutex_); in Release()
|
| /foundation/ace/ace_engine_lite/frameworks/src/core/base/ |
| D | ace_lock.cpp | 24 LockType::LockType() : mutex_(PTHREAD_MUTEX_INITIALIZER), mutexInited_(0) in LockType()
26 mutexInited_ = pthread_mutex_init(&mutex_, nullptr); in LockType()
39 pthread_mutex_destroy(&mutex_); in ~LockType()
48 pthread_mutex_lock(&mutex_); in Lock()
56 pthread_mutex_unlock(&mutex_); in Unlock()
|
| /foundation/communication/bluetooth/services/bluetooth_standard/service/src/avrcp_ct/ |
| D | avrcp_ct_connection.cpp | 115 std::lock_guard<std::recursive_mutex> lock(mutex_); in Add()
143 std::lock_guard<std::recursive_mutex> lock(mutex_); in Delete()
165 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetRawAddress()
182 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetDeviceAddresses()
196 std::lock_guard<std::recursive_mutex> lock(mutex_); in AddDisconnectedDevice()
205 std::lock_guard<std::recursive_mutex> lock(mutex_); in DeleteDisconnectedDevice()
218 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetAllDisconnectedDevices()
226 std::lock_guard<std::recursive_mutex> lock(mutex_); in IsConnectInfoEmpty()
233 std::lock_guard<std::recursive_mutex> lock(mutex_); in GetConnectId()
250 std::lock_guard<std::recursive_mutex> lock(mutex_); in SetConnectId()
[all …]
|
| /foundation/multimedia/media_standard/services/services/recorder/server/ |
| D | recorder_server.cpp | 108 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSource()
116 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncoder()
125 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSize()
134 std::lock_guard<std::mutex> lock(mutex_); in SetVideoFrameRate()
143 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncodingBitRate()
152 std::lock_guard<std::mutex> lock(mutex_); in SetCaptureRate()
161 std::lock_guard<std::mutex> lock(mutex_); in GetSurface()
170 std::lock_guard<std::mutex> lock(mutex_); in SetAudioSource()
184 std::lock_guard<std::mutex> lock(mutex_); in SetAudioEncoder()
194 std::lock_guard<std::mutex> lock(mutex_); in SetAudioSampleRate()
[all …]
|
| /foundation/multimedia/media_standard/services/services/avcodec/server/ |
| D | avcodec_server.cpp | 61 std::lock_guard<std::mutex> lock(mutex_); in InitParameter()
69 std::lock_guard<std::mutex> lock(mutex_); in Configure()
79 std::lock_guard<std::mutex> lock(mutex_); in Prepare()
89 std::lock_guard<std::mutex> lock(mutex_); in Start()
99 std::lock_guard<std::mutex> lock(mutex_); in Stop()
110 std::lock_guard<std::mutex> lock(mutex_); in Flush()
121 std::lock_guard<std::mutex> lock(mutex_); in Reset()
130 std::lock_guard<std::mutex> lock(mutex_); in Release()
137 std::lock_guard<std::mutex> lock(mutex_); in CreateInputSurface()
145 std::lock_guard<std::mutex> lock(mutex_); in SetOutputSurface()
[all …]
|
| /foundation/multimedia/media_standard/services/services/avcodeclist/client/ |
| D | avcodeclist_client.cpp | 44 std::lock_guard<std::mutex> lock(mutex_); in ~AVCodecListClient()
53 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied()
59 std::lock_guard<std::mutex> lock(mutex_); in FindVideoDecoder()
66 std::lock_guard<std::mutex> lock(mutex_); in FindVideoEncoder()
73 std::lock_guard<std::mutex> lock(mutex_); in FindAudioDecoder()
80 std::lock_guard<std::mutex> lock(mutex_); in FindAudioEncoder()
87 std::lock_guard<std::mutex> lock(mutex_); in GetCodecCapabilityInfos()
|
| /foundation/multimedia/media_standard/services/engine/gstreamer/player/ |
| D | player_engine_gst_impl.cpp | 81 std::unique_lock<std::mutex> lock(mutex_); in SetSource()
104 std::unique_lock<std::mutex> lock(mutex_); in SetSource()
113 std::unique_lock<std::mutex> lock(mutex_); in SetObs()
120 std::unique_lock<std::mutex> lock(mutex_); in SetVideoSurface()
129 std::unique_lock<std::mutex> lock(mutex_); in Prepare()
151 std::unique_lock<std::mutex> lock(mutex_); in PrepareAsync()
264 std::unique_lock<std::mutex> lock(mutex_); in Play()
274 std::unique_lock<std::mutex> lock(mutex_); in Pause()
283 std::unique_lock<std::mutex> lock(mutex_); in GetCurrentTime()
296 std::unique_lock<std::mutex> lock(mutex_); in GetVideoTrackInfo()
[all …]
|
| /foundation/multimedia/histreamer/engine/utils/ |
| D | buffer_pool.h | 45 OSAL::ScopedLock lock(mutex_);
75 OSAL::ScopedLock lock(mutex_); in Append()
86 OSAL::ScopedLock lock(mutex_); in SetActive()
95 OSAL::ScopedLock lock(mutex_); in RecycleBuffer()
102 OSAL::ScopedLock lock(mutex_); in AllocateBuffer()
118 OSAL::ScopedLock lock(mutex_); in AllocateBufferNonBlocking()
127 OSAL::ScopedLock lock(mutex_); in AllocateAppendBufferNonBlocking()
142 OSAL::ScopedLock lock(mutex_); in Size()
153 OSAL::ScopedLock lock(mutex_); in Empty()
175 OSAL::ScopedLock lock(mutex_); in FinishAllocInProgress()
[all …]
|
| D | blocking_queue.h | 40 OSAL::ScopedLock lock(mutex_); in Size()
49 OSAL::ScopedLock lock(mutex_); in Empty()
54 OSAL::ScopedLock lock(mutex_); in Push()
75 OSAL::ScopedLock lock(mutex_); in Push()
96 OSAL::ScopedLock lock(mutex_); in Pop()
116 OSAL::ScopedLock lock(mutex_); in Pop()
134 OSAL::ScopedLock lock(mutex_); in Clear()
139 OSAL::ScopedLock lock(mutex_); in SetActive()
161 OSAL::Mutex mutex_; variable
|
| /foundation/aafwk/standard/common/task_dispatcher/include/dispatcher/ |
| D | blocking_queue.h | 69 BlockingQueue() : mutex_(), empty_(), stopFlag_(false){}; in BlockingQueue()
74 std::unique_lock<std::mutex> lock(mutex_); in Offer()
82 std::unique_lock<std::mutex> lock(mutex_); in Take()
99 std::unique_lock<std::mutex> lock(mutex_); in Poll()
116 std::lock_guard<std::mutex> lock(mutex_); in Size()
122 std::unique_lock<std::mutex> lock(mutex_); in Empty()
128 std::unique_lock<std::mutex> lock(mutex_); in Stop()
137 std::mutex mutex_;
|
| /foundation/multimedia/image_standard/mock/native/include/ |
| D | singleton.h | 62 static std::mutex mutex_; variable
69 std::mutex DelayedSingleton<T>::mutex_;
75 std::lock_guard<std::mutex> lock(mutex_); in GetInstance()
87 std::lock_guard<std::mutex> lock(mutex_); in DestroyInstance()
101 static std::mutex mutex_; variable
108 std::mutex DelayedRefSingleton<T>::mutex_;
114 std::lock_guard<std::mutex> lock(mutex_); in GetInstance()
|