Home
last modified time | relevance | path

Searched refs:sem (Results 1 – 25 of 59) sorted by relevance

123

/components/libc/posix/ipc/
A Dsemaphore.c169 if ((!sem) || !(sem->unamed)) in sem_destroy()
178 if(rt_list_len(&sem->sem->parent.suspend_thread) != 0) in sem_destroy()
254 *sval = sem->sem->value; in sem_getvalue()
289 if (sem->sem == RT_NULL) in sem_init()
362 if (sem->sem == RT_NULL) /* create failed */ in sem_open()
401 if (sem->sem != RT_NULL) in sem_open()
402 rt_sem_delete(sem->sem); in sem_open()
432 result = rt_sem_release(sem->sem); in sem_post()
469 result = rt_sem_take(sem->sem, tick); in sem_timedwait()
510 result = rt_sem_take(sem->sem, 0); in sem_trywait()
[all …]
A Dsemaphore.h25 rt_sem_t sem; member
32 int sem_close(sem_t *sem);
33 int sem_destroy(sem_t *sem);
34 int sem_getvalue(sem_t *sem, int *sval);
35 int sem_init(sem_t *sem, int pshared, unsigned int value);
37 int sem_post(sem_t *sem);
38 int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);
39 int sem_trywait(sem_t *sem);
41 int sem_wait(sem_t *sem);
/components/net/lwip/lwip-2.1.2/test/unit/arch/
A Dsys_arch.c78 *sem = count + 1; in sys_sem_new()
83 sys_sem_free(sys_sem_t *sem) in sys_sem_free() argument
86 *sem = 0; in sys_sem_free()
93 *sem = 0; in sys_sem_set_invalid()
103 if (*sem == 1) { in sys_arch_sem_wait()
117 } while(*sem == 1); in sys_arch_sem_wait()
126 if (*sem == 1) { in sys_arch_sem_wait()
133 (*sem)--; in sys_arch_sem_wait()
144 (*sem)++; in sys_sem_signal()
235 mbox->sem = NULL; in sys_mbox_free()
[all …]
A Dsys_arch.h42 void* sem; member
50 #define sys_mbox_valid(mbox) ((mbox != NULL) && ((mbox)->sem != NULL) && ((mbox)->sem != (void*)-1…
51 #define sys_mbox_valid_val(mbox) (((mbox).sem != NULL) && ((mbox).sem != (void*)-1))
/components/libc/posix/pthreads/
A Dpthread_cond.c179 result = rt_sem_trytake(&(cond->sem)); in pthread_cond_destroy()
230 result = rt_sem_trytake(&(cond->sem)); in pthread_cond_broadcast()
234 rt_sem_release(&(cond->sem)); in pthread_cond_broadcast()
239 rt_sem_release(&(cond->sem)); in pthread_cond_broadcast()
298 result = rt_sem_release(&(cond->sem)); in pthread_cond_signal()
343 rt_sem_t sem; in _pthread_cond_timedwait() local
346 sem = &(cond->sem); in _pthread_cond_timedwait()
347 if (sem == RT_NULL) in _pthread_cond_timedwait()
373 RT_ASSERT(sem != RT_NULL); in _pthread_cond_timedwait()
378 if (sem->value > 0) in _pthread_cond_timedwait()
[all …]
A Dpthread_rwlock.c144 result = rt_sem_trytake(&(rwlock->rw_condreaders.sem)); in pthread_rwlock_destroy()
147 result = rt_sem_trytake(&(rwlock->rw_condwriters.sem)); in pthread_rwlock_destroy()
150 rt_sem_release(&(rwlock->rw_condreaders.sem)); in pthread_rwlock_destroy()
151 rt_sem_release(&(rwlock->rw_condwriters.sem)); in pthread_rwlock_destroy()
158 rt_sem_release(&(rwlock->rw_condreaders.sem)); in pthread_rwlock_destroy()
/components/drivers/usb/cherryusb/osal/
A Dusb_osal_rtthread.c57 if (sem == NULL) { in usb_osal_sem_create()
62 return sem; in usb_osal_sem_create()
65 void usb_osal_sem_delete(usb_osal_sem_t sem) in usb_osal_sem_delete() argument
67 rt_sem_delete((rt_sem_t)sem); in usb_osal_sem_delete()
70 int usb_osal_sem_take(usb_osal_sem_t sem, uint32_t timeout) in usb_osal_sem_take() argument
76 result = rt_sem_take((rt_sem_t)sem, RT_WAITING_FOREVER); in usb_osal_sem_take()
78 result = rt_sem_take((rt_sem_t)sem, rt_tick_from_millisecond(timeout)); in usb_osal_sem_take()
91 int usb_osal_sem_give(usb_osal_sem_t sem) in usb_osal_sem_give() argument
93 return (int)rt_sem_release((rt_sem_t)sem); in usb_osal_sem_give()
96 void usb_osal_sem_reset(usb_osal_sem_t sem) in usb_osal_sem_reset() argument
[all …]
/components/net/lwip/lwip-2.1.2/src/include/lwip/
A Dsys.h195 err_t sys_sem_new(sys_sem_t *sem, u8_t count);
201 void sys_sem_signal(sys_sem_t *sem);
219 u32_t sys_arch_sem_wait(sys_sem_t *sem, u32_t timeout);
225 void sys_sem_free(sys_sem_t *sem);
227 #define sys_sem_wait(sem) sys_arch_sem_wait(sem, 0)
236 int sys_sem_valid(sys_sem_t *sem);
246 void sys_sem_set_invalid(sys_sem_t *sem);
252 #define sys_sem_valid_val(sem) sys_sem_valid(&(sem))
258 #define sys_sem_set_invalid_val(sem) sys_sem_set_invalid(&(sem))
/components/net/lwip/lwip-2.0.3/src/include/lwip/
A Dsys.h175 err_t sys_sem_new(sys_sem_t *sem, u8_t count);
181 void sys_sem_signal(sys_sem_t *sem);
190 u32_t sys_arch_sem_wait(sys_sem_t *sem, u32_t timeout);
196 void sys_sem_free(sys_sem_t *sem);
198 #define sys_sem_wait(sem) sys_arch_sem_wait(sem, 0)
204 int sys_sem_valid(sys_sem_t *sem);
211 void sys_sem_set_invalid(sys_sem_t *sem);
217 #define sys_sem_valid_val(sem) sys_sem_valid(&(sem))
223 #define sys_sem_set_invalid_val(sem) sys_sem_set_invalid(&(sem))
/components/net/lwip/lwip-2.1.2/src/include/lwip/priv/
A Dsockets_priv.h149 #define SELECT_SEM_PTR(sem) (sem) argument
152 #define SELECT_SEM_PTR(sem) (&(sem)) argument
178 SELECT_SEM_T sem; member
A Dtcpip_priv.h97 err_t tcpip_send_msg_wait_sem(tcpip_callback_fn fn, void *apimsg, sys_sem_t* sem);
104 sys_sem_t sem; member
140 sys_sem_t *sem; member
/components/net/lwip/lwip-1.4.1/src/include/lwip/
A Dsys.h139 err_t sys_sem_new(sys_sem_t *sem, u8_t count);
142 void sys_sem_signal(sys_sem_t *sem);
148 u32_t sys_arch_sem_wait(sys_sem_t *sem, u32_t timeout);
151 void sys_sem_free(sys_sem_t *sem);
153 #define sys_sem_wait(sem) sys_arch_sem_wait(sem, 0)
156 int sys_sem_valid(sys_sem_t *sem);
160 void sys_sem_set_invalid(sys_sem_t *sem);
/components/net/lwip/port/
A Dsys_arch.c120 err_t sys_sem_new(sys_sem_t *sem, u8_t count) in sys_sem_new() argument
138 *sem = tmpsem; in sys_sem_new()
147 void sys_sem_free(sys_sem_t *sem) in sys_sem_free() argument
150 rt_sem_delete(*sem); in sys_sem_free()
156 void sys_sem_signal(sys_sem_t *sem) in sys_sem_signal() argument
158 rt_sem_release(*sem); in sys_sem_signal()
192 ret = rt_sem_take(*sem, t); in sys_arch_sem_wait()
219 int sys_sem_valid(sys_sem_t *sem) in sys_sem_valid() argument
223 if (*sem) ret = 1; in sys_sem_valid()
232 void sys_sem_set_invalid(sys_sem_t *sem) in sys_sem_set_invalid() argument
[all …]
/components/net/lwip/lwip-2.0.3/src/api/
A Dtcpip.c117 sys_sem_signal(msg->msg.api_call.sem); in tcpip_thread()
329 tcpip_send_msg_wait_sem(tcpip_callback_fn fn, void *apimsg, sys_sem_t* sem) in tcpip_send_msg_wait_sem() argument
332 LWIP_UNUSED_ARG(sem); in tcpip_send_msg_wait_sem()
340 LWIP_ASSERT("semaphore not initialized", sys_sem_valid(sem)); in tcpip_send_msg_wait_sem()
348 sys_arch_sem_wait(sem, 0); in tcpip_send_msg_wait_sem()
377 err_t err = sys_sem_new(&call->sem, 0); in tcpip_api_call()
390 TCPIP_MSG_VAR_REF(msg).msg.api_call.sem = LWIP_NETCONN_THREAD_SEM_GET(); in tcpip_api_call()
392 TCPIP_MSG_VAR_REF(msg).msg.api_call.sem = &call->sem; in tcpip_api_call()
395 sys_arch_sem_wait(TCPIP_MSG_VAR_REF(msg).msg.api_call.sem, 0); in tcpip_api_call()
399 sys_sem_free(&call->sem); in tcpip_api_call()
A Dapi_lib.c928 sys_sem_t sem; in netconn_gethostbyname_addrtype() local
947 msg.sem = &sem; in netconn_gethostbyname_addrtype()
955 API_VAR_REF(msg).sem = LWIP_NETCONN_THREAD_SEM_GET(); in netconn_gethostbyname_addrtype()
957 err = sys_sem_new(API_EXPR_REF(API_VAR_REF(msg).sem), 0); in netconn_gethostbyname_addrtype()
967 sys_sem_free(API_EXPR_REF(API_VAR_REF(msg).sem)); in netconn_gethostbyname_addrtype()
972 sys_sem_wait(API_EXPR_REF_SEM(API_VAR_REF(msg).sem)); in netconn_gethostbyname_addrtype()
974 sys_sem_free(API_EXPR_REF(API_VAR_REF(msg).sem)); in netconn_gethostbyname_addrtype()
991 sys_sem_t *sem = LWIP_NETCONN_THREAD_SEM_GET(); in netconn_thread_init() local
992 if ((sem == NULL) || !sys_sem_valid(sem)) { in netconn_thread_init()
1002 sys_sem_t *sem = LWIP_NETCONN_THREAD_SEM_GET(); in netconn_thread_cleanup() local
[all …]
/components/drivers/usb/cherryusb/common/
A Dusb_osal.h48 void usb_osal_sem_delete(usb_osal_sem_t sem);
49 int usb_osal_sem_take(usb_osal_sem_t sem, uint32_t timeout);
50 int usb_osal_sem_give(usb_osal_sem_t sem);
51 void usb_osal_sem_reset(usb_osal_sem_t sem);
/components/net/lwip/lwip-2.1.2/src/api/
A Dtcpip.c167 sys_sem_signal(msg->msg.api_call.sem); in tcpip_thread_handle_msg()
437 tcpip_send_msg_wait_sem(tcpip_callback_fn fn, void *apimsg, sys_sem_t *sem) in tcpip_send_msg_wait_sem() argument
440 LWIP_UNUSED_ARG(sem); in tcpip_send_msg_wait_sem()
448 LWIP_ASSERT("semaphore not initialized", sys_sem_valid(sem)); in tcpip_send_msg_wait_sem()
456 sys_arch_sem_wait(sem, 0); in tcpip_send_msg_wait_sem()
485 err_t err = sys_sem_new(&call->sem, 0); in tcpip_api_call()
498 TCPIP_MSG_VAR_REF(msg).msg.api_call.sem = LWIP_NETCONN_THREAD_SEM_GET(); in tcpip_api_call()
500 TCPIP_MSG_VAR_REF(msg).msg.api_call.sem = &call->sem; in tcpip_api_call()
503 sys_arch_sem_wait(TCPIP_MSG_VAR_REF(msg).msg.api_call.sem, 0); in tcpip_api_call()
507 sys_sem_free(&call->sem); in tcpip_api_call()
/components/net/lwip/lwip-2.0.3/src/apps/snmp/
A Dsnmp_threadsync.c49 sys_sem_wait(&call_data->threadsync_node->instance->sem); in call_synced_function()
60 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_get_value_synced()
81 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_set_test_synced()
103 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_set_value_synced()
125 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_release_instance_synced()
146 sys_sem_signal(&call_data->threadsync_node->instance->sem); in get_instance_synced()
157 sys_sem_signal(&call_data->threadsync_node->instance->sem); in get_next_instance_synced()
213 err = sys_sem_new(&instance->sem, 0); in snmp_threadsync_init()
/components/net/lwip/lwip-2.1.2/src/apps/snmp/
A Dsnmp_threadsync.c49 sys_sem_wait(&call_data->threadsync_node->instance->sem); in call_synced_function()
64 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_get_value_synced()
89 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_set_test_synced()
115 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_set_value_synced()
137 sys_sem_signal(&call_data->threadsync_node->instance->sem); in threadsync_release_instance_synced()
158 sys_sem_signal(&call_data->threadsync_node->instance->sem); in get_instance_synced()
169 sys_sem_signal(&call_data->threadsync_node->instance->sem); in get_next_instance_synced()
225 err = sys_sem_new(&instance->sem, 0); in snmp_threadsync_init()
/components/drivers/cputime/
A Dcputimer.c21 struct rt_semaphore *sem; in _cputime_sleep_timeout() local
22 sem = (struct rt_semaphore *)parameter; in _cputime_sleep_timeout()
23 rt_sem_release(sem); in _cputime_sleep_timeout()
100 rt_sem_init(&(timer->sem), "cputime", 0, RT_IPC_FLAG_PRIO); in rt_cputimer_init()
290 rt_sem_detach(&(timer->sem)); in rt_cputimer_detach()
311 rt_cputimer_init(&cputimer, "cputime_sleep", _cputime_sleep_timeout, &(cputimer.sem), tick, in rt_cputime_sleep()
319 rt_sem_take_interruptible(&(cputimer.sem), RT_WAITING_FOREVER); in rt_cputime_sleep()
/components/net/lwip/lwip-2.0.3/src/include/lwip/priv/
A Dtcpip_priv.h95 err_t tcpip_send_msg_wait_sem(tcpip_callback_fn fn, void *apimsg, sys_sem_t* sem);
102 sys_sem_t sem; member
133 sys_sem_t *sem; member
/components/drivers/ipc/
A Dworkqueue.c28 result = rt_sem_trytake(&(queue->sem)); in _workqueue_work_completion()
32 rt_sem_release(&(queue->sem)); in _workqueue_work_completion()
228 rt_sem_init(&(queue->sem), "wqueue", 0, RT_IPC_FLAG_FIFO); in rt_workqueue_create()
235 rt_sem_detach(&(queue->sem)); in rt_workqueue_create()
260 rt_sem_detach(&(queue->sem)); in rt_workqueue_destroy()
368 rt_sem_take(&(queue->sem), RT_WAITING_FOREVER); in rt_workqueue_cancel_work_sync()
/components/net/lwip/lwip-2.1.2/src/core/
A Dstats.c130 LWIP_PLATFORM_DIAG(("sem.used: %"STAT_COUNTER_F"\n\t", sys->sem.used)); in stats_display_sys()
131 LWIP_PLATFORM_DIAG(("sem.max: %"STAT_COUNTER_F"\n\t", sys->sem.max)); in stats_display_sys()
132 LWIP_PLATFORM_DIAG(("sem.err: %"STAT_COUNTER_F"\n\t", sys->sem.err)); in stats_display_sys()
/components/utilities/ymodem/
A Dymodem.c91 return rt_sem_release(&_rym_the_ctx->sem); in _rym_rx_ind()
112 if (rt_sem_take(&ctx->sem, timeout) != RT_EOK) in _rym_read_code()
139 while (rt_sem_take(&ctx->sem, RYM_WAIT_CHR_TICK) == RT_EOK); in _rym_read_data()
195 rt_sem_take(&ctx->sem, RT_WAITING_FOREVER); in _rym_getchar()
672 rt_sem_init(&ctx->sem, "rymsem", 0, RT_IPC_FLAG_FIFO); in rym_recv_on_device()
697 rt_sem_detach(&ctx->sem); in rym_recv_on_device()
729 rt_sem_init(&ctx->sem, "rymsem", 0, RT_IPC_FLAG_FIFO); in rym_send_on_device()
753 rt_sem_detach(&ctx->sem); in rym_send_on_device()
/components/net/lwip/lwip-2.0.3/src/core/
A Dstats.c130 LWIP_PLATFORM_DIAG(("sem.used: %"U32_F"\n\t", (u32_t)sys->sem.used)); in stats_display_sys()
131 LWIP_PLATFORM_DIAG(("sem.max: %"U32_F"\n\t", (u32_t)sys->sem.max)); in stats_display_sys()
132 LWIP_PLATFORM_DIAG(("sem.err: %"U32_F"\n\t", (u32_t)sys->sem.err)); in stats_display_sys()

Completed in 32 milliseconds

123