| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
| H A D | callbacks.c | 704 #define FILLP_ADAPT_SYS_ARCH_SEM_WAIT(sem) sem_wait(sem) argument
814 sem->sem = 0x0; in FillpAdaptSysArchRwsemInit()
824 oldValue = sem->sem; in FillpAdaptSysArchRwsemTryrdwait()
829 } while (!CAS(&sem->sem, oldValue, nextValue)); in FillpAdaptSysArchRwsemTryrdwait()
840 oldValue = sem->sem; in FillpAdaptSysArchRwsemTrywrwait()
845 } while (!CAS(&sem->sem, oldValue, nextValue)); in FillpAdaptSysArchRwsemTrywrwait()
856 oldValue = sem->sem; in FillpAdaptSysArchRwsemRdPost()
858 } while (!CAS(&sem->sem, oldValue, nextValue)); in FillpAdaptSysArchRwsemRdPost()
869 oldValue = sem->sem; in FillpAdaptSysArchRwsemWrPost()
871 } while (!CAS(&sem->sem, oldValue, nextValue)); in FillpAdaptSysArchRwsemWrPost()
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | semaphore_linux.c | 65 if (sem == NULL) { in SemaphoreDelete()
69 if (sem->fd != -1) { in SemaphoreDelete()
70 close(sem->fd); in SemaphoreDelete()
74 free(sem); in SemaphoreDelete()
79 ASSERT(sem); in SemaphoreWait()
87 ASSERT(sem); in SemaphoreTryWait()
89 MutexLock(sem->mutex); in SemaphoreTryWait()
118 ASSERT(sem); in SemaphorePost()
125 ASSERT(sem); in SemaphoreTryPost()
155 ASSERT(sem); in SemaphoreGetfd()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | semaphore_test.rs | 30 let sem2 = sem.clone(); in sdv_auto_release_sem_acquire_test()
50 let permit = sem.try_acquire(); in sdv_auto_release_sem_try_acquire_test()
69 sem.release(); in sdv_release_test()
82 let sem2 = sem.clone(); in sdv_auto_release_sem_close_test()
83 assert!(!sem.is_closed()); in sdv_auto_release_sem_close_test()
84 sem.close(); in sdv_auto_release_sem_close_test()
85 assert!(sem.is_closed()); in sdv_auto_release_sem_close_test()
107 let sem2 = sem.clone(); in sdv_auto_release_sem_stress_test()
142 let sem2 = sem.clone(); in sdv_async_stress_test()
186 let sem2 = sem.clone(); in sdv_acquire_test()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | semaphore.rs | 91 sem: &'a AutoRelSemaphore, field
343 self.sem.inner.release(); in drop()
364 sem.close(); in ut_sem_close_test()
365 assert!(sem.is_closed()); in ut_sem_close_test()
378 let sem2 = sem.clone(); in ut_auto_release_sem_acquire_test()
397 sem.release(); in ut_release_test()
410 let sem2 = sem.clone(); in ut_auto_release_sem_close_test()
412 sem.close(); in ut_auto_release_sem_close_test()
413 assert!(sem.is_closed()); in ut_auto_release_sem_close_test()
514 let sem2 = sem.clone(); in ut_acquire_test()
[all …]
|
| H A D | waiter.rs | 42 sem: SemaphoreInner, field
60 sem: SemaphoreInner::new(0).unwrap(), in new()
86 self.sem.acquire().await.unwrap(); in wait()
117 self.sem.release_notify(); in wake_one()
146 self.sem.release_all(); in wake_all()
|
| /ohos5.0/drivers/hdf_core/framework/support/posix/src/ |
| H A D | osal_sem.c | 25 if (sem == NULL) { in OsalSemInit()
30 sem->realSemaphore = NULL; in OsalSemInit()
43 sem->realSemaphore = (void *)semTmp; in OsalSemInit()
48 int32_t OsalSemWait(struct OsalSem *sem, uint32_t ms) in OsalSemWait() argument
50 if (sem == NULL || sem->realSemaphore == NULL) { in OsalSemWait()
84 int32_t OsalSemPost(struct OsalSem *sem) in OsalSemPost() argument
86 if (sem == NULL || sem->realSemaphore == NULL) { in OsalSemPost()
99 int32_t OsalSemDestroy(struct OsalSem *sem) in OsalSemDestroy() argument
101 if (sem == NULL || sem->realSemaphore == NULL) { in OsalSemDestroy()
111 OsalMemFree(sem->realSemaphore); in OsalSemDestroy()
[all …]
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/osal/src/ |
| H A D | osal_sem.c | 28 int32_t OsalSemInit(struct OsalSem *sem, uint32_t value) in OsalSemInit() argument
32 if (sem == NULL) { in OsalSemInit()
43 sem->realSemaphore = (void *)sem_tmp; in OsalSemInit()
53 if (sem == NULL || sem->realSemaphore == NULL) { in OsalSemWait()
78 int32_t OsalSemPost(struct OsalSem *sem) in OsalSemPost() argument
80 if (sem == NULL || sem->realSemaphore == NULL) { in OsalSemPost()
85 up((struct semaphore *)sem->realSemaphore); in OsalSemPost()
91 int32_t OsalSemDestroy(struct OsalSem *sem) in OsalSemDestroy() argument
93 if (sem == NULL || sem->realSemaphore == NULL) { in OsalSemDestroy()
98 OsalMemFree(sem->realSemaphore); in OsalSemDestroy()
[all …]
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos/osal/src/ |
| H A D | osal_sem.c | 40 int32_t OsalSemInit(struct OsalSem *sem, uint32_t value) in OsalSemInit() argument
45 if (sem == NULL) { in OsalSemInit()
52 sem->realSemaphore = (void *)(uintptr_t)semId; in OsalSemInit()
61 int32_t OsalSemWait(struct OsalSem *sem, uint32_t ms) in OsalSemWait() argument
65 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemWait()
82 int32_t OsalSemPost(struct OsalSem *sem) in OsalSemPost() argument
86 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemPost()
91 ret = LOS_SemPost((uint32_t)(uintptr_t)sem->realSemaphore); in OsalSemPost()
100 int32_t OsalSemDestroy(struct OsalSem *sem) in OsalSemDestroy() argument
104 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemDestroy()
[all …]
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos_m/osal/src/ |
| H A D | osal_sem.c | 44 int32_t OsalSemInit(struct OsalSem *sem, uint32_t value) in OsalSemInit() argument
49 if (sem == NULL) { in OsalSemInit()
56 sem->realSemaphore = (void *)(uintptr_t)semId; in OsalSemInit()
65 int32_t OsalSemWait(struct OsalSem *sem, uint32_t ms) in OsalSemWait() argument
69 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemWait()
86 int32_t OsalSemPost(struct OsalSem *sem) in OsalSemPost() argument
90 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemPost()
95 ret = LOS_SemPost((uint32_t)(uintptr_t)sem->realSemaphore); in OsalSemPost()
104 int32_t OsalSemDestroy(struct OsalSem *sem) in OsalSemDestroy() argument
108 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemDestroy()
[all …]
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/uniproton/osal/src/ |
| H A D | osal_sem.c | 39 int32_t OsalSemInit(struct OsalSem *sem, uint32_t value) in OsalSemInit() argument
44 if (sem == NULL) { in OsalSemInit()
51 sem->realSemaphore = (void *)(uintptr_t)semId; in OsalSemInit()
60 int32_t OsalSemWait(struct OsalSem *sem, uint32_t ms) in OsalSemWait() argument
65 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemWait()
82 int32_t OsalSemPost(struct OsalSem *sem) in OsalSemPost() argument
86 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemPost()
91 ret = PRT_SemPost((uint32_t)(uintptr_t)sem->realSemaphore); in OsalSemPost()
100 int32_t OsalSemDestroy(struct OsalSem *sem) in OsalSemDestroy() argument
104 if (sem == NULL || sem->realSemaphore == (void *)(uintptr_t)HDF_INVALID_SEM_ID) { in OsalSemDestroy()
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/test/moduletest/ipc_ability_scheduler_test/ |
| H A D | ipc_ability_scheduler_module_test.cpp | 73 Semaphore sem(0); variable
101 sem.Wait();
118 Semaphore sem(0); variable
147 sem.Wait();
187 sem.Wait();
223 sem.Wait();
253 sem.Wait();
286 sem.Wait();
325 sem.Wait();
365 sem.Wait();
[all …]
|
| /ohos5.0/docs/zh-cn/device-dev/kernel/ |
| H A D | kernel-small-basic-trans-semaphore.md | 157 dprintf("ExampleSemTask1 wait_forever and get sem g_semId.\n");
159 dprintf("ExampleSemTask1 post sem g_semId.\n");
169 dprintf("ExampleSemTask2 try get sem g_semId wait forever.\n");
180 dprintf("ExampleSemTask2 post sem g_semId.\n");
246 ExampleSemTask2 try get sem g_semId wait forever.
247 ExampleSemTask1 try get sem g_semId, timeout 10 ticks.
248 ExampleSemTask1 timeout and try get sem g_semId wait forever.
249 ExampleSemTask2 get sem g_semId and then delay 20 ticks.
250 ExampleSemTask2 post sem g_semId.
251 ExampleSemTask1 wait_forever and get sem g_semId.
[all …]
|
| H A D | kernel-mini-basic-ipc-sem.md | 117 printf("ExampleSemTask1 try get sem g_semId, timeout 10 ticks.\n");
131 printf("ExampleSemTask1 wait_forever and get sem g_semId.\n");
142 printf("ExampleSemTask2 try get sem g_semId wait forever.\n");
147 printf("ExampleSemTask2 get sem g_semId and then delay 20 ticks.\n");
152 printf("ExampleSemTask2 post sem g_semId.\n");
217 ExampleSemTask2 try get sem g_semId wait forever.
218 ExampleSemTask1 try get sem g_semId, timeout 10 ticks.
219 ExampleSemTask2 get sem g_semId and then delay 20 ticks.
220 ExampleSemTask1 timeout and try get sem g_semId wait forever.
221 ExampleSemTask2 post sem g_semId.
[all …]
|
| H A D | kernel-small-debug-shell-cmd-sem.md | 1 # sem chapter
6 sem命令用于查询系统内核信号量相关信息。
11 sem [_ID__ / fulldata_]
28 - sem后加ID，显示对应ID信号量的使用数。
36 - 输入sem
38 - 配置LOSCFG_DEBUG_SEMAPHORE标志，输入 sem fulldata
46 OHOS # sem
78 > ● sem命令的ID参数输入形式以十进制形式表示或十六进制形式表示皆可。
80 > ● sem命令的ID参数在[0, 1023]范围内时，返回对应ID的信号量的状态（如果对应ID的信号量未被使用则进行提示）；其他取值时返回参数错误的提示。
85 OHOS # sem fulldata
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
| H A D | sys_util.c | 93 int32_t SemInit(sem_t *sem, int pshared, unsigned int value) in SemInit() argument
95 return sem_init(sem, pshared, value); in SemInit()
98 void SemGetValue(sem_t *sem, int *sval) in SemGetValue() argument
100 if (sem_getvalue(sem, sval) != 0) { in SemGetValue()
105 void SemPost(sem_t *sem) in SemPost() argument
107 if (sem_post(sem) != 0) { in SemPost()
112 void SemWait(sem_t *sem) in SemWait() argument
114 if (sem_wait(sem) != 0) { in SemWait()
119 void SemDestroy(sem_t *sem) in SemDestroy() argument
121 if (sem_destroy(sem) != 0) { in SemDestroy()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/include/ |
| H A D | semaphore.h | 42 void SemaphoreDelete(Semaphore *sem);
50 void SemaphoreWait(const Semaphore *sem);
59 int32_t SemaphoreTryWait(Semaphore *sem);
67 void SemaphorePost(const Semaphore *sem);
76 int32_t SemaphoreTryPost(Semaphore *sem);
85 int32_t SemaphoreGetfd(const Semaphore *sem);
|
| /ohos5.0/drivers/hdf_core/interfaces/inner_api/osal/shared/ |
| H A D | osal_sem.h | 52 #define OSAL_DECLARE_SEMAPHORE(sem) struct OsalSem sem argument
70 int32_t OsalSemInit(struct OsalSem *sem, uint32_t value);
89 int32_t OsalSemWait(struct OsalSem *sem, uint32_t ms);
106 int32_t OsalSemPost(struct OsalSem *sem);
123 int32_t OsalSemDestroy(struct OsalSem *sem);
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/ |
| H A D | callbacks.h | 244 FILLP_INT FillpSemTryWait(IN SYS_ARCH_SEM *sem);
251 FILLP_INT FillpSemWait(IN SYS_ARCH_SEM *sem);
253 FILLP_INT FillpRwSemTryRdWait(IN SYS_ARCH_RW_SEM *sem);
255 FILLP_INT FillpRwSemTryWrWait(IN SYS_ARCH_RW_SEM *sem);
263 FILLP_INT FillpRwSemRdPost(IN SYS_ARCH_RW_SEM *sem);
271 FILLP_INT FillpRwSemWrPost(IN SYS_ARCH_RW_SEM *sem);
278 FILLP_INT FillpRwSemDestroy(IN SYS_ARCH_RW_SEM *sem);
285 FILLP_INT FillpSemPost(IN SYS_ARCH_SEM *sem);
292 FILLP_INT FillpSemDestroy(IN SYS_ARCH_SEM *sem);
380 FILLP_INT FillpSysArchSemClose(SYS_ARCH_SEM *sem);
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/test/moduletest/common/ams/app_mgr_service_test/ |
| H A D | ams_app_mgr_service_module_test.cpp | 260 Semaphore sem(0); variable
264 sem.Post(); in __anone22fe8df0202()
294 Semaphore sem(0); variable
298 sem.Post(); in __anone22fe8df0302()
332 sem.Post(); in __anone22fe8df0402()
388 sem.Post(); in __anone22fe8df0502()
397 sem.Wait();
468 sem.Post(); in __anone22fe8df0602()
479 sem.Wait();
502 sem.Post(); in __anone22fe8df0702()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/include/ |
| H A D | fillpcallbacks.h | 422 typedef FILLP_INT (*FillpSemTryWaitFunc)(IN SYS_ARCH_SEM *sem);
435 typedef FILLP_INT (*FillpSemWaitFunc)(IN SYS_ARCH_SEM *sem);
448 typedef FILLP_INT (*FillpSemPostFunc)(IN SYS_ARCH_SEM *sem);
460 typedef FILLP_INT (*FillpSemDestroyFunc)(IN SYS_ARCH_SEM *sem);
474 typedef FILLP_INT (*FillpRWSemInitFunc)(IO SYS_ARCH_RW_SEM *sem);
487 typedef FILLP_INT (*FillpRWSemTryRDWaitFunc)(IN SYS_ARCH_RW_SEM *sem);
511 typedef FILLP_INT (*FillpRWSemWRWaitFunc)(IN SYS_ARCH_RW_SEM *sem);
523 typedef FILLP_INT (*FillpRWSemRDPostFunc)(IN SYS_ARCH_RW_SEM *sem);
535 typedef FILLP_INT (*FillpRWSemWRPostFunc)(IN SYS_ARCH_RW_SEM *sem);
547 typedef FILLP_INT (*FillpRWSemDestroyFunc)(IN SYS_ARCH_RW_SEM *sem);
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| H A D | sys_util.c | 146 int32_t SemInit(sem_t *sem, int pshared, unsigned int value) in SemInit() argument
148 return sem_init(sem, pshared, value); in SemInit()
151 void SemGetValue(sem_t *sem, int *sval) in SemGetValue() argument
153 if (sem_getvalue(sem, sval) != 0) { in SemGetValue()
158 void SemPost(sem_t *sem) in SemPost() argument
160 if (sem_post(sem) != 0) { in SemPost()
165 void SemWait(sem_t *sem) in SemWait() argument
167 if (sem_wait(sem) != 0) { in SemWait()
172 void SemDestroy(sem_t *sem) in SemDestroy() argument
174 if (sem_destroy(sem) != 0) { in SemDestroy()
|
| /ohos5.0/foundation/multimodalinput/input/frameworks/proxy/events/test/ |
| H A D | input_manager_filter_manual_test.cpp | 233 sem_t &sem; member
236 : exceptX(exceptX), exceptY(exceptY), sem(sem), result(result) in PointerFilter()
291 void WaitPointerEnd(sem_t &sem) in WaitPointerEnd() argument
305 sem_t sem; variable
318 WaitPointerEnd(sem);
322 WaitPointerEnd(sem);
339 sem_t &sem; member
342 : exceptKeyCode(exceptKeyCode), sem(sem), result(result) in KeyFilter002()
367 void WaitKeyEnd(sem_t &sem) in WaitKeyEnd() argument
391 WaitKeyEnd(sem); in SimulateKeyEvent()
[all …]
|
| /ohos5.0/drivers/hdf_core/framework/test/fuzztest/framework_fuzzer/support/posix_fuzzer/ |
| H A D | posix_fuzzer.cpp | 86 struct OsalSem sem; in FuncOsalSemWait() local
87 OsalSemInit(&sem, 1); in FuncOsalSemWait()
88 OsalSemWait(&sem, ~HDF_WAIT_FOREVER); in FuncOsalSemWait()
89 OsalSemDestroy(&sem); in FuncOsalSemWait()
95 struct OsalSem sem; in FuncOsalSemPost() local
96 OsalSemInit(&sem, 1); in FuncOsalSemPost()
97 OsalSemPost(&sem); in FuncOsalSemPost()
98 OsalSemDestroy(&sem); in FuncOsalSemPost()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/ |
| H A D | l2cap_if.c | 655 Semaphore *sem; member
676 Semaphore *sem = NULL; in L2CIF_Startup() local
684 if (sem == NULL) { in L2CIF_Startup()
695 ctx->sem = sem; in L2CIF_Startup()
705 SemaphoreWait(sem); in L2CIF_Startup()
706 SemaphoreDelete(sem); in L2CIF_Startup()
729 Semaphore *sem = NULL; in L2CIF_Shutdown() local
732 if (sem == NULL) { in L2CIF_Shutdown()
742 ctx->sem = sem; in L2CIF_Shutdown()
752 SemaphoreWait(sem); in L2CIF_Shutdown()
[all …]
|
| /ohos5.0/drivers/hdf_core/framework/test/unittest/platform/common/ |
| H A D | platform_queue_test.c | 21 struct OsalSem sem; member
52 (void)OsalSemPost(&tmsg->sem); in PlatformQueueTestHandle()
67 (void)OsalSemInit(&tmsg.sem, 0); in PlatformQueueTestAddAndWait()
71 (void)OsalSemDestroy(&tmsg.sem); in PlatformQueueTestAddAndWait()
76 ret = OsalSemWait(&tmsg.sem, PLAT_QUEUE_TEST_TIMEOUT); in PlatformQueueTestAddAndWait()
78 (void)OsalSemDestroy(&tmsg.sem); in PlatformQueueTestAddAndWait()
82 (void)OsalSemDestroy(&tmsg.sem); in PlatformQueueTestAddAndWait()
86 (void)OsalSemDestroy(&tmsg.sem); in PlatformQueueTestAddAndWait()
|