| /foundation/communication/bluetooth/services/bluetooth_standard/stack/platform/src/ |
| D | mutex.c | 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 == NULL) { in MutexDelete()
47 pthread_mutex_destroy(&mutex->mutex); in MutexDelete()
48 free(mutex); in MutexDelete()
[all …]
|
| D | event.c | 23 pthread_mutex_t mutex; member
33 pthread_mutex_init(&event->mutex, NULL); in EventCreate()
50 pthread_mutex_destroy(&event->mutex); in EventDelete()
58 pthread_mutex_lock(&event->mutex); in EventSet()
60 pthread_mutex_unlock(&event->mutex); in EventSet()
66 pthread_mutex_unlock(&event->mutex); in EventSet()
73 pthread_mutex_lock(&event->mutex); in EventClear()
76 pthread_mutex_unlock(&event->mutex); in EventClear()
83 ret = pthread_cond_wait(&event->cond, &event->mutex); in EventWaitInternal()
90 ret = pthread_cond_timedwait(&event->cond, &event->mutex, &timeout); in EventWaitInternal()
[all …]
|
| D | queue.c | 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()
130 MutexLock(queue->mutex); in QueueDequeue()
[all …]
|
| /foundation/communication/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
| 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> lock(proxyMutex); in GetInterface()
[all …]
|
| /foundation/communication/bluetooth/services/bluetooth_standard/stack/platform/linux/ |
| D | semaphore_linux.c | 29 Mutex *mutex; member
41 Mutex *mutex = MutexCreate(); in SemaphoreCreate() local
42 if (mutex == NULL) { in SemaphoreCreate()
51 MutexDelete(mutex); in SemaphoreCreate()
56 semaphore->mutex = mutex; in SemaphoreCreate()
71 MutexDelete(sem->mutex); in SemaphoreDelete()
87 MutexLock(sem->mutex); in SemaphoreTryWait()
106 MutexUnlock(sem->mutex); in SemaphoreTryWait()
110 MutexUnlock(sem->mutex); in SemaphoreTryWait()
125 MutexLock(sem->mutex); in SemaphoreTryPost()
[all …]
|
| D | alarm_linux.c | 39 Mutex *mutex; member
70 MutexLock(alarm->mutex); in AlarmNotify()
89 MutexUnlock(alarm->mutex); in AlarmNotify()
116 Mutex *mutex = MutexCreate(); in AlarmCreate() local
117 if (mutex == NULL) { in AlarmCreate()
125 alarm->mutex = mutex; in AlarmCreate()
142 MutexDelete(alarm->mutex); in AlarmCreate()
156 MutexDelete(alarm->mutex); in AlarmDelete()
164 MutexLock(alarm->mutex); in AlarmSet()
178 MutexUnlock(alarm->mutex); in AlarmSet()
[all …]
|
| /foundation/communication/ipc/ipc/native/c/rpc/src/ |
| 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/distributedschedule/samgr_lite/samgr/adapter/posix/ |
| 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()
|
| /foundation/communication/ipc/utils/src/ |
| D | rpc_session_handle.c | 45 pthread_mutex_lock(&sessionIdList->mutex); in FindOrNewSessionIdObject()
51 pthread_mutex_unlock(&sessionIdList->mutex); in FindOrNewSessionIdObject()
59 pthread_mutex_unlock(&sessionIdList->mutex); in FindOrNewSessionIdObject()
63 (void)pthread_mutex_init(&node->mutex, NULL); in FindOrNewSessionIdObject()
69 pthread_mutex_unlock(&sessionIdList->mutex); in FindOrNewSessionIdObject()
88 pthread_mutex_lock(&sessionIdObject->mutex); in WaitForSessionIdReady()
90 pthread_mutex_unlock(&sessionIdObject->mutex); in WaitForSessionIdReady()
96 pthread_mutex_unlock(&sessionIdObject->mutex); in WaitForSessionIdReady()
101 &sessionIdObject->mutex, &waitTime) == ETIMEDOUT) { in WaitForSessionIdReady()
103 pthread_mutex_unlock(&sessionIdObject->mutex); in WaitForSessionIdReady()
[all …]
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/src/ |
| D | fsm_common.h | 43 #define FSM_LOCK(mutex) \ argument
45 (void)pthread_mutex_lock(&(mutex)); \
48 #define FSM_UNLOCK(mutex) \ argument
50 (void)pthread_mutex_unlock(&(mutex)); \
53 #define FSM_COND_WAIT(cond, mutex) \ argument
55 (void)pthread_cond_wait(&(cond), &(mutex)); \
67 int32_t FsmCondTimewait(pthread_cond_t &cond, pthread_mutex_t &mutex, uint32_t delayUs);
|
| /foundation/communication/dsoftbus/core/connection/common/src/ |
| D | softbus_thread_pool.c | 74 if (SoftBusMutexInit(&(pool->mutex), NULL) != SOFTBUS_OK) { in CreateThreadPool()
117 if (SoftBusMutexLock(&(pool->mutex)) != 0) { in ThreadPoolInit()
138 SoftBusMutexUnlock(&pool->mutex); in ThreadPoolInit()
141 SoftBusMutexUnlock(&(pool->mutex)); in ThreadPoolInit()
145 SoftBusMutexDestroy(&pool->mutex); in ThreadPoolInit()
186 if (SoftBusMutexLock(&(pool->mutex)) != 0) { in ThreadPoolWorker()
191 SoftBusCondWait(&(pool->queueNotEmpty), &(pool->mutex), NULL); in ThreadPoolWorker()
194 SoftBusMutexUnlock(&(pool->mutex)); in ThreadPoolWorker()
199 if (SoftBusMutexLock(&(job->mutex)) != 0) { in ThreadPoolWorker()
202 SoftBusMutexUnlock(&(pool->mutex)); in ThreadPoolWorker()
[all …]
|
| /foundation/communication/ipc/services/dbinder/c/src/ |
| D | dbinder_service.c | 46 pthread_mutex_t mutex; member
51 pthread_mutex_t mutex; member
56 pthread_mutex_t mutex; member
63 pthread_mutex_t mutex; member
68 pthread_mutex_t mutex; member
73 pthread_mutex_t mutex; member
76 static RemoteBinderObjectsList g_binderList = {.mutex = PTHREAD_MUTEX_INITIALIZER};
77 static DBinderStubRegistedList g_stubRegistedList = {.mutex = PTHREAD_MUTEX_INITIALIZER};
78 static ThreadLockInfoList g_threadLockInfoList = {.mutex = PTHREAD_MUTEX_INITIALIZER};
79 static SessionInfoList g_sessionInfoList = {.mutex = PTHREAD_MUTEX_INITIALIZER};
[all …]
|
| /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/distributedhardware/distributedcamera/camera_hdf/hdi_impl/src/dstream_operator/ |
| D | dimage_buffer.cpp | 108 std::lock_guard<std::mutex> l(l_); in SetIndex()
115 std::lock_guard<std::mutex> l(l_); in SetWidth()
122 std::lock_guard<std::mutex> l(l_); in SetHeight()
129 std::lock_guard<std::mutex> l(l_); in SetStride()
136 std::lock_guard<std::mutex> l(l_); in SetFormat()
143 std::lock_guard<std::mutex> l(l_); in SetSize()
150 std::lock_guard<std::mutex> l(l_); in SetUsage()
157 std::lock_guard<std::mutex> l(l_); in SetPhyAddress()
164 std::lock_guard<std::mutex> l(l_); in SetFileDescriptor()
171 std::lock_guard<std::mutex> l(l_); in SetTimestamp()
[all …]
|
| /foundation/ace/ace_engine/frameworks/base/subwindow/ |
| D | subwindow_manager.cpp | 29 std::mutex SubwindowManager::instanceMutex_;
34 std::lock_guard<std::mutex> lock(instanceMutex_); in GetInstance()
43 std::lock_guard<std::mutex> lock(mutex_); in AddContainerId()
52 std::lock_guard<std::mutex> lock(mutex_); in RemoveContainerId()
58 std::lock_guard<std::mutex> lock(mutex_); in GetContainerId()
70 std::lock_guard<std::mutex> lock(parentMutex_); in AddParentContainerId()
79 std::lock_guard<std::mutex> lock(parentMutex_); in RemoveParentContainerId()
85 std::lock_guard<std::mutex> lock(parentMutex_); in GetParentContainerId()
102 std::lock_guard<std::mutex> lock(subwindowMutex_); in AddSubwindow()
114 std::lock_guard<std::mutex> lock(subwindowMutex_); in RemoveSubwindow()
[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/distributedschedule/samgr_lite/samgr/adapter/cmsis/ |
| D | thread_adapter.c | 26 void MUTEX_Lock(MutexId mutex) in MUTEX_Lock() argument
28 if (mutex == NULL) { in MUTEX_Lock()
31 osMutexAcquire(mutex, osWaitForever); in MUTEX_Lock()
34 void MUTEX_Unlock(MutexId mutex) in MUTEX_Unlock() argument
36 if (mutex == NULL) { in MUTEX_Unlock()
39 osMutexRelease(mutex); in MUTEX_Unlock()
|
| /foundation/communication/dsoftbus/adapter/common/kernel/liteos_a/ |
| D | softbus_adapter_thread.c | 43 int32_t SoftBusMutexInit(SoftBusMutex *mutex, SoftBusMutexAttr *mutexAttr) in SoftBusMutexInit() argument
45 if (mutex == NULL) { in SoftBusMutexInit()
80 *mutex = (SoftBusMutex)tempMutex; in SoftBusMutexInit()
84 int32_t SoftBusMutexLock(SoftBusMutex *mutex) in SoftBusMutexLock() argument
86 if ((mutex == NULL) || ((void *)(*mutex) == NULL)) { in SoftBusMutexLock()
92 ret = pthread_mutex_lock((pthread_mutex_t *)*mutex); in SoftBusMutexLock()
100 int32_t SoftBusMutexUnlock(SoftBusMutex *mutex) in SoftBusMutexUnlock() argument
102 if ((mutex == NULL) || ((void *)(*mutex) == NULL)) { in SoftBusMutexUnlock()
108 ret = pthread_mutex_unlock((pthread_mutex_t *)*mutex); in SoftBusMutexUnlock()
117 int32_t SoftBusMutexDestroy(SoftBusMutex *mutex) in SoftBusMutexDestroy() argument
[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/graphic/standard/utils/promise/export/ |
| D | promise.h | 39 std::mutex mutex; variable
63 std::unique_lock<std::mutex> lock(mutex); in Await()
72 std::unique_lock<std::mutex> lock(mutex); in Then()
84 std::unique_lock<std::mutex> lock(mutex); in Resolve()
|
| /foundation/graphic/standard/frameworks/dumper/src/ |
| D | graphic_dumper_helper_impl.cpp | 65 static std::mutex mutex; in GetInstance() local
66 std::lock_guard<std::mutex> guard(mutex); in GetInstance()
76 static std::mutex mutex; in SetNoopInstance() local
77 std::lock_guard<std::mutex> guard(mutex); in SetNoopInstance()
107 std::lock_guard<std::mutex> guard(onConfigChangeMutex_); in Init()
117 std::lock_guard<std::mutex> guard(onDumperFuncsMutex_); in Init()
127 std::lock_guard<std::mutex> guard(cacheInfoMutex_); in Init()
180 std::lock_guard<std::mutex> guard(clientListenerMutex_); in AddClientListener()
195 static std::mutex sprintfMutex_; in SendInfo()
196 std::lock_guard<std::mutex> lock(sprintfMutex_); in SendInfo()
[all …]
|
| /foundation/communication/bluetooth/services/bluetooth_standard/service/src/common/ |
| D | profile_list.h | 46 std::lock_guard<std::mutex> lock(lock_); in ~ProfilesList()
59 std::lock_guard<std::mutex> lock(lock_); in Get()
69 std::lock_guard<std::mutex> lock(lock_); in Clear()
81 std::lock_guard<std::mutex> lock(lock_); in GetProfiles()
100 std::lock_guard<std::mutex> lock(lock_); in SetProfile()
115 std::lock_guard<std::mutex> lock(lock_); in Contains()
136 std::lock_guard<std::mutex> lock(lock_); in Contains()
159 std::lock_guard<std::mutex> lock(lock_); in Find()
183 std::lock_guard<std::mutex> lock(lock_); in Find()
204 std::lock_guard<std::mutex> lock(lock_); in IsEmpty()
[all …]
|
| /foundation/communication/dsoftbus/components/nstackx_mini/nstackx_util/platform/liteos/ |
| D | sys_util.c | 78 int32_t PthreadMutexInit(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr) in PthreadMutexInit() argument
80 return pthread_mutex_init(mutex, attr); in PthreadMutexInit()
83 void PthreadMutexDestroy(pthread_mutex_t *mutex) in PthreadMutexDestroy() argument
85 if (pthread_mutex_destroy(mutex) != 0) { in PthreadMutexDestroy()
90 int32_t PthreadMutexLock(pthread_mutex_t *mutex) in PthreadMutexLock() argument
92 return pthread_mutex_lock(mutex); in PthreadMutexLock()
95 int32_t PthreadMutexUnlock(pthread_mutex_t *mutex) in PthreadMutexUnlock() argument
97 return pthread_mutex_unlock(mutex); in PthreadMutexUnlock()
|
| /foundation/communication/wifi/services/wifi_standard/ipc_framework/cRPC/src/ |
| D | client.c | 75 pthread_mutex_lock(&client->mutex); in RpcClientDealReadMsg()
81 pthread_mutex_unlock(&client->mutex); in RpcClientDealReadMsg()
83 pthread_mutex_lock(&client->mutex); in RpcClientDealReadMsg()
85 pthread_cond_wait(&client->condW, &client->mutex); in RpcClientDealReadMsg()
87 pthread_mutex_unlock(&client->mutex); in RpcClientDealReadMsg()
111 pthread_mutex_lock(&client->mutex); in RpcClientThreadDeal()
114 pthread_mutex_unlock(&client->mutex); in RpcClientThreadDeal()
142 pthread_mutex_init(&client->mutex, NULL); in CreateRpcClient()
149 pthread_mutex_destroy(&client->mutex); in CreateRpcClient()
169 pthread_mutex_destroy(&client->mutex); in ReleaseRpcClient()
[all …]
|