/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/ |
H A D | mutex.c | 16 #include "platform/include/mutex.h" 22 pthread_mutex_t mutex; member 27 Mutex *mutex = (Mutex *)malloc(sizeof(Mutex)); in MutexCreate() local 32 if (mutex != NULL) { in MutexCreate() 33 if (pthread_mutex_init(&mutex->mutex, &attr) != 0) { in MutexCreate() 34 free(mutex); in MutexCreate() 38 return mutex; in MutexCreate() 41 void MutexDelete(Mutex *mutex) in MutexDelete() argument 43 if (mutex in MutexDelete() 51 MutexLock(Mutex *mutex) MutexLock() argument 57 MutexUnlock(Mutex *mutex) MutexUnlock() argument 63 MutexTryLock(Mutex *mutex) MutexTryLock() argument [all...] |
H A D | queue.c | 20 #include "platform/include/mutex.h" 26 Mutex *mutex; member 42 queue->mutex = MutexCreate(); in QueueCreate() 43 if (queue->mutex == NULL) { in QueueCreate() 62 MutexDelete(queue->mutex); in QueueCreate() 88 MutexDelete(queue->mutex); in QueueDelete() 98 MutexLock(queue->mutex); in QueueEnqueue() 100 MutexUnlock(queue->mutex); in QueueEnqueue() 114 MutexLock(queue->mutex); in QueueTryEnqueue() 116 MutexUnlock(queue->mutex); in QueueTryEnqueue() [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_sta/ |
H A D | sta_interface.cpp | 32 std::lock_guard<std::mutex> lock(mutex); in ~StaInterface() 53 std::lock_guard<std::mutex> lock(mutex); in EnableStaService() 70 std::lock_guard<std::mutex> lock(mutex); in DisableStaService() 82 std::lock_guard<std::mutex> lock(mutex); in ConnectToNetwork() 94 std::lock_guard<std::mutex> lock(mutex); in ConnectToDevice() [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_scan/ |
H A D | scan_interface.cpp | 28 std::lock_guard<std::mutex> lock(mutex); in ~ScanInterface() 49 std::lock_guard<std::mutex> lock(mutex); in Init() 71 std::lock_guard<std::mutex> lock(mutex); in UnInit() 80 std::lock_guard<std::mutex> lock(mutex); in Scan() 88 std::lock_guard<std::mutex> lock(mutex); in ScanWithParam() [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
H A D | wifi_p2p_group_info_proxy.cpp | 21 std::unique_lock<std::mutex> lock(proxyMutex); in operator ==() 27 std::unique_lock<std::mutex> lock(proxyMutex); in operator !=() 33 std::unique_lock<std::mutex> lock(proxyMutex); in SetIsGroupOwner() 39 std::unique_lock<std::mutex> lock(proxyMutex); in IsGroupOwner() 45 std::unique_lock<std::mutex> lock(proxyMutex); in SetOwner() 51 std::unique_lock<std::mutex> lock(proxyMutex); in GetOwner() 57 std::unique_lock<std::mutex> lock(proxyMutex); in SetPassphrase() 63 std::unique_lock<std::mutex> lock(proxyMutex); in GetPassphrase() 69 std::unique_lock<std::mutex> lock(proxyMutex); in SetInterface() 75 std::unique_lock<std::mutex> loc in GetInterface() [all...] |
/foundation/communication/dsoftbus/adapter/common/include/ |
H A D | softbus_adapter_thread.h | 71 // mutex 73 int32_t SoftBusMutexInit(SoftBusMutex *mutex, SoftBusMutexAttr *mutexAttr); 74 int32_t SoftBusMutexLockInner(SoftBusMutex *mutex); 75 int32_t SoftBusMutexUnlockInner(SoftBusMutex *mutex); 76 int32_t SoftBusMutexDestroy(SoftBusMutex *mutex); 78 static inline bool CheckMutexIsNull(const SoftBusMutex *mutex) in CheckMutexIsNull() argument 80 return (mutex == NULL) || ((void *)(*mutex) == NULL); in CheckMutexIsNull() 83 #define SoftBusMutexLock(mutex) \ 86 if (CheckMutexIsNull(mutex)) { \ 115 SoftBusMutexUnlockAuto(SoftBusMutex **mutex) SoftBusMutexUnlockAuto() argument [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_self_cure/ |
H A D | self_cure_interface.cpp | 32 std::lock_guard<std::mutex> lock(mutex); in ~SelfCureInterface() 61 std::lock_guard<std::mutex> lock(mutex); in InitSelfCureService() 103 std::lock_guard<std::mutex> lock(mutex); in NotifyInternetFailureDetected() 114 std::lock_guard<std::mutex> lock(mutex); in IsSelfCureOnGoing() 124 std::lock_guard<std::mutex> lock(mutex); in DealStaConnChanged() [all...] |
/foundation/window/window_manager/window_scene/test/dms_unittest/ |
H A D | fold_screen_controller_test.cpp | 67 std::recursive_mutex mutex; in HWTEST_F() local 68 FoldScreenController fsc_(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 94 std::recursive_mutex mutex; in HWTEST_F() local 95 FoldScreenController fsc_(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 110 std::recursive_mutex mutex; in HWTEST_F() local 111 FoldScreenController fsc_(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 132 std::recursive_mutex mutex; in HWTEST_F() local 133 FoldScreenController fsc_(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 148 std::recursive_mutex mutex; in HWTEST_F() local 149 FoldScreenController fsc_(mutex, st in HWTEST_F() 164 std::recursive_mutex mutex; HWTEST_F() local 179 std::recursive_mutex mutex; HWTEST_F() local 194 std::recursive_mutex mutex; HWTEST_F() local 209 std::recursive_mutex mutex; HWTEST_F() local 226 std::recursive_mutex mutex; HWTEST_F() local 242 std::recursive_mutex mutex; HWTEST_F() local 257 std::recursive_mutex mutex; HWTEST_F() local 272 std::recursive_mutex mutex; HWTEST_F() local 287 std::recursive_mutex mutex; HWTEST_F() local 302 std::recursive_mutex mutex; HWTEST_F() local 318 std::recursive_mutex mutex; HWTEST_F() local 334 std::recursive_mutex mutex; HWTEST_F() local 349 std::recursive_mutex mutex; HWTEST_F() local [all...] |
H A D | dual_display_fold_policy_test.cpp | 70 std::recursive_mutex mutex; in HWTEST_F() local 71 DualDisplayFoldPolicy dualDisplayFoldPolicy(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 96 std::recursive_mutex mutex; in HWTEST_F() local 97 DualDisplayFoldPolicy dualDisplayFoldPolicy(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 125 std::recursive_mutex mutex; in HWTEST_F() local 126 DualDisplayFoldPolicy dualDisplayFoldPolicy(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 139 std::recursive_mutex mutex; in HWTEST_F() local 140 DualDisplayFoldPolicy dualDisplayFoldPolicy(mutex, std::shared_ptr<TaskScheduler>()); in HWTEST_F() 155 std::recursive_mutex mutex; in HWTEST_F() local 156 DualDisplayFoldPolicy dualDisplayFoldPolicy(mutex, st in HWTEST_F() 168 std::recursive_mutex mutex; HWTEST_F() local 182 std::recursive_mutex mutex; HWTEST_F() local 198 std::recursive_mutex mutex; HWTEST_F() local 214 std::recursive_mutex mutex; HWTEST_F() local 233 std::recursive_mutex mutex; HWTEST_F() local 250 std::recursive_mutex mutex; HWTEST_F() local 264 std::recursive_mutex mutex; HWTEST_F() local 289 std::recursive_mutex mutex; HWTEST_F() local 303 std::recursive_mutex mutex; HWTEST_F() local 319 std::recursive_mutex mutex; HWTEST_F() local 336 std::recursive_mutex mutex; HWTEST_F() local 353 std::recursive_mutex mutex; HWTEST_F() local 370 std::recursive_mutex mutex; HWTEST_F() local 385 std::recursive_mutex mutex; HWTEST_F() local 400 std::recursive_mutex mutex; HWTEST_F() local 415 std::recursive_mutex mutex; HWTEST_F() local 430 std::recursive_mutex mutex; HWTEST_F() local 445 std::recursive_mutex mutex; HWTEST_F() local [all...] |
/foundation/communication/wifi/wifi/frameworks/native/src/ |
H A D | wifi_device_impl.cpp | 124 std::lock_guard<std::mutex> lock(mutex_); in EnableWifi() 131 std::lock_guard<std::mutex> lock(mutex_); in DisableWifi() 138 std::lock_guard<std::mutex> lock(mutex_); in InitWifiProtect() 145 std::lock_guard<std::mutex> lock(mutex_); in GetWifiProtectRef() 152 std::lock_guard<std::mutex> lock(mutex_); in PutWifiProtectRef() 159 std::lock_guard<std::mutex> lock(mutex_); in IsHeldWifiProtectRef() 185 std::lock_guard<std::mutex> lock(mutex_); in RemoveCandidateConfig() 192 std::lock_guard<std::mutex> lock(mutex_); in RemoveCandidateConfig() 199 std::lock_guard<std::mutex> lock(mutex_); in AddDeviceConfig() 206 std::lock_guard<std::mutex> loc in UpdateDeviceConfig() [all...] |
H A D | wifi_p2p_impl.cpp | 78 std::lock_guard<std::mutex> lock(mutex_); in EnableP2p() 85 std::lock_guard<std::mutex> lock(mutex_); in DisableP2p() 92 std::lock_guard<std::mutex> lock(mutex_); in DiscoverDevices() 99 std::lock_guard<std::mutex> lock(mutex_); in StopDiscoverDevices() 106 std::lock_guard<std::mutex> lock(mutex_); in DiscoverServices() 113 std::lock_guard<std::mutex> lock(mutex_); in StopDiscoverServices() 120 std::lock_guard<std::mutex> lock(mutex_); in RequestService() 127 std::lock_guard<std::mutex> lock(mutex_); in PutLocalP2pService() 134 std::lock_guard<std::mutex> lock(mutex_); in DeleteLocalP2pService() 141 std::lock_guard<std::mutex> loc in StartP2pListen() [all...] |
/foundation/multimedia/camera_framework/frameworks/native/camera/src/output/ |
H A D | capture_output.cpp | 18 #include <mutex> 40 std::lock_guard<std::mutex> lock(deathRecipientMutex_); in RegisterStreamBinderDied() 56 std::lock_guard<std::mutex> lock(bufferProducerMutex_); in GetBufferProducer() 62 std::lock_guard<std::mutex> lock(deathRecipientMutex_); in UnregisterStreamBinderDied() 101 std::lock_guard<std::mutex> lock(streamMutex_); in IsStreamCreated() 107 std::lock_guard<std::mutex> lock(streamMutex_); in GetStream() 114 std::lock_guard<std::mutex> lock(streamMutex_); in SetStream() 122 std::lock_guard<std::mutex> lock(sessionMutex_); in GetSession() 128 std::lock_guard<std::mutex> lock(sessionMutex_); in SetSession() 136 std::lock_guard<std::mutex> loc in Release() [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/ |
H A D | dps.cpp | 25 std::mutex mutex{}; 36 std::unique_lock<std::mutex> lock(g_dpsInfo.mutex); in DPS_Initialize() 63 std::unique_lock<std::mutex> lock(g_dpsInfo.mutex); in DPS_Destroy() 75 std::unique_lock<std::mutex> lock(g_dpsInfo.mutex); in DPS_GetCommandServer() 84 std::unique_lock<std::mutex> lock(g_dpsInfo.mutex); in DPS_GetSessionManager() [all...] |
/foundation/multimodalinput/input/service/connect_manager/src/ |
H A D | multimodal_input_connect_manager.cpp | 56 std::lock_guard<std::mutex> guard(lock_); in AllocSocketPair() 78 std::lock_guard<std::mutex> guard(lock_); in GetDisplayBindInfo() 86 std::lock_guard<std::mutex> guard(lock_); in GetAllMmiSubscribedEvents() 93 std::lock_guard<std::mutex> guard(lock_); in SetDisplayBind() 100 std::lock_guard<std::mutex> guard(lock_); in GetWindowPid() 108 std::lock_guard<std::mutex> guard(lock_); in AddInputEventFilter() 115 std::lock_guard<std::mutex> guard(lock_); in NotifyNapOnline() 122 std::lock_guard<std::mutex> guard(lock_); in RemoveInputEventObserver() 129 std::lock_guard<std::mutex> guard(lock_); in RemoveInputEventFilter() 136 std::lock_guard<std::mutex> guar in SetMouseScrollRows() [all...] |
/foundation/multimedia/av_codec/test/unittest/video_test/vcodec_server_test/mock/ |
H A D | codecbase_mock.cpp | 15 #include <mutex> 25 std::mutex g_mutex; 33 std::lock_guard<std::mutex> lock(g_mutex); in CreateByName() 42 std::lock_guard<std::mutex> lock(g_mutex); in CreateByName() 51 std::lock_guard<std::mutex> lock(g_mutex); in CreateByName() 60 std::lock_guard<std::mutex> lock(g_mutex); in GetCapabilityList() 71 std::lock_guard<std::mutex> lock(g_mutex); in GetCapabilityList() 82 std::lock_guard<std::mutex> lock(g_mutex); in GetCapabilityList() 93 std::lock_guard<std::mutex> lock(g_mutex); in RegisterMock() 100 std::lock_guard<std::mutex> loc in CodecBase() [all...] |
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/src/parameter/ |
H A D | parameters.cpp | 19 #include <mutex>
24 std::mutex mutex;
member 43 std::lock_guard<std::mutex> lock(mutex);
in GetIntParameter() 57 std::lock_guard<std::mutex> lock(mutex);
in GetParameter() 67 std::lock_guard<std::mutex> lock(mutex);
in SetParameter()
|
/foundation/CastEngine/castengine_wifi_display/services/network/eventhandler/ |
H A D | event_handler_manager.cpp | 30 std::unique_lock<std::mutex> lock(mutex); in ~EventHandlerManager() 39 std::unique_lock<std::mutex> lock(mutex); in Init() 53 std::unique_lock<std::mutex> lock(mutex); in GetEventHandler() 67 std::unique_lock<std::mutex> lock(mutex); in AddFdListener() 81 std::unique_lock<std::mutex> lock(mutex); in AddEventHandler() [all...] |
/foundation/communication/ipc/ipc/native/c/rpc/src/ |
H A D | rpc_process_skeleton.c | 38 static StubObjectList g_stubObjectList = {.mutex = PTHREAD_MUTEX_INITIALIZER}; 39 static ThreadProcessInfoList g_processInfoList = {.mutex = PTHREAD_MUTEX_INITIALIZER}; 40 static SocketThreadLockInfoList g_socketLockInfoList = {.mutex = PTHREAD_MUTEX_INITIALIZER}; 41 static IdleDataThreadsList g_idleDataThreadsList = {.mutex = PTHREAD_MUTEX_INITIALIZER}; 51 .mutex = PTHREAD_MUTEX_INITIALIZER, 88 pthread_mutex_lock(&g_stubObjectList.mutex); in AddStubByIndex() 90 pthread_mutex_unlock(&g_stubObjectList.mutex); in AddStubByIndex() 97 pthread_mutex_lock(&g_stubObjectList.mutex); in QueryStubByIndex() 101 pthread_mutex_unlock(&g_stubObjectList.mutex); in QueryStubByIndex() 105 pthread_mutex_unlock(&g_stubObjectList.mutex); in QueryStubByIndex() [all...] |
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/src/ |
H A D | fsm_common.h | 43 #define FSM_LOCK(mutex) \ 45 (void)pthread_mutex_lock(&(mutex)); \ 48 #define FSM_UNLOCK(mutex) \ 50 (void)pthread_mutex_unlock(&(mutex)); \ 53 #define FSM_COND_WAIT(cond, mutex) \ 55 (void)pthread_cond_wait(&(cond), &(mutex)); \ 67 int32_t FsmCondTimewait(pthread_cond_t &cond, pthread_mutex_t &mutex, uint32_t delayUs);
|
/foundation/multimedia/player_framework/services/services/recorder/client/ |
H A D | recorder_client.cpp | 48 std::lock_guard<std::mutex> lock(mutex_); in ~RecorderClient() 61 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied() 72 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject() 87 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSource() 96 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncoder() 105 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSize() 114 std::lock_guard<std::mutex> lock(mutex_); in SetVideoFrameRate() 123 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncodingBitRate() 132 std::lock_guard<std::mutex> lock(mutex_); in SetVideoIsHdr() 141 std::lock_guard<std::mutex> loc in SetVideoEnableTemporalScale() [all...] |
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
H A D | thread_adapter.c | 29 pthread_mutex_t *mutex = SAMGR_Malloc(sizeof(pthread_mutex_t));
in MUTEX_InitValue() local 30 if (mutex == NULL) {
in MUTEX_InitValue() 33 (void)pthread_mutex_init(mutex, NULL);
in MUTEX_InitValue() 34 return (MutexId)mutex;
in MUTEX_InitValue() 37 void MUTEX_Lock(MutexId mutex)
in MUTEX_Lock() argument 39 if (mutex == NULL) {
in MUTEX_Lock() 42 pthread_mutex_lock((pthread_mutex_t *)mutex);
in MUTEX_Lock() 45 void MUTEX_Unlock(MutexId mutex)
in MUTEX_Unlock() argument 47 if (mutex == NULL) {
in MUTEX_Unlock() 50 pthread_mutex_unlock((pthread_mutex_t *)mutex);
in MUTEX_Unlock() [all...] |
/foundation/communication/ipc/utils/src/ |
H A D | rpc_session_handle.c | 46 pthread_mutex_lock(&sessionIdList->mutex); in FindOrNewSessionIdObject() 52 pthread_mutex_unlock(&sessionIdList->mutex); in FindOrNewSessionIdObject() 60 pthread_mutex_unlock(&sessionIdList->mutex); in FindOrNewSessionIdObject() 64 (void)pthread_mutex_init(&node->mutex, NULL); in FindOrNewSessionIdObject() 70 pthread_mutex_unlock(&sessionIdList->mutex); in FindOrNewSessionIdObject() 89 pthread_mutex_lock(&sessionIdObject->mutex); in WaitForSessionIdReady() 91 pthread_mutex_unlock(&sessionIdObject->mutex); in WaitForSessionIdReady() 97 pthread_mutex_unlock(&sessionIdObject->mutex); in WaitForSessionIdReady() 102 &sessionIdObject->mutex, &waitTime) == ETIMEDOUT) { in WaitForSessionIdReady() 104 pthread_mutex_unlock(&sessionIdObject->mutex); in WaitForSessionIdReady() [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
H A D | semaphore_linux.c | 21 #include "platform/include/mutex.h" 30 Mutex *mutex; member 42 Mutex *mutex = MutexCreate(); in SemaphoreCreate() local 43 if (mutex == NULL) { in SemaphoreCreate() 52 MutexDelete(mutex); in SemaphoreCreate() 58 semaphore->mutex = mutex; in SemaphoreCreate() 73 MutexDelete(sem->mutex); in SemaphoreDelete() 89 MutexLock(sem->mutex); in SemaphoreTryWait() 108 MutexUnlock(sem->mutex); in SemaphoreTryWait() [all...] |
/foundation/multimedia/player_framework/services/services/screen_capture/client/ |
H A D | screen_capture_client.cpp | 47 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject() 63 std::lock_guard<std::mutex> lock(mutex_); in ~ScreenCaptureClient() 72 std::lock_guard<std::mutex> lock(mutex_); in SetScreenCaptureCallback() 83 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied() 93 std::lock_guard<std::mutex> lock(mutex_); in Release() 100 std::lock_guard<std::mutex> lock(mutex_); in SetCaptureMode() 107 std::lock_guard<std::mutex> lock(mutex_); in SetDataType() 114 std::lock_guard<std::mutex> lock(mutex_); in SetRecorderInfo() 121 std::lock_guard<std::mutex> lock(mutex_); in SetOutputFile() 128 std::lock_guard<std::mutex> loc in InitAudioEncInfo() [all...] |
/foundation/graphic/graphic_surface/surface/src/ |
H A D | surface_buffer_impl.cpp | 18 #include <mutex> 34 static std::mutex g_displayBufferMutex; 41 std::lock_guard<std::mutex> bufferLock(g_displayBufferMutex); 49 std::lock_guard<std::mutex> bufferLock(g_displayBufferMutex); in GetDisplayBuffer() 58 std::lock_guard<std::mutex> bufferLock(g_displayBufferMutex); in GetOrResetDisplayBuffer() 88 static std::mutex mutex; in SurfaceBufferImpl() local 89 mutex.lock(); in SurfaceBufferImpl() 97 mutex.unlock(); in SurfaceBufferImpl() 133 std::lock_guard<std::mutex> loc in Alloc() [all...] |