| /lk-master/external/platform/pico/common/pico_sync/ |
| A D | sem.c | 12 sem->permits = initial_permits; in sem_init()
13 sem->max_permits = max_permits; in sem_init()
18 return *(volatile typeof(sem->permits) *) &sem->permits; in __time_critical_func()
25 if (sem->permits > 0) { in __time_critical_func()
26 sem->permits--; in __time_critical_func()
42 if (sem->permits > 0) { in __time_critical_func()
43 sem->permits--; in __time_critical_func()
64 int32_t count = sem->permits; in __time_critical_func()
65 if (count < sem->max_permits) { in __time_critical_func()
66 sem->permits = count + 1; in __time_critical_func()
[all …]
|
| /lk-master/kernel/ |
| A D | semaphore.c | 24 *sem = (semaphore_t)SEMAPHORE_INITIAL_VALUE(*sem, value); in sem_init()
27 void sem_destroy(semaphore_t *sem) { in sem_destroy() argument
29 sem->count = 0; in sem_destroy()
30 wait_queue_destroy(&sem->wait, true); in sem_destroy()
43 if (unlikely(++sem->count <= 0)) in sem_post()
51 status_t sem_wait(semaphore_t *sem) { in sem_wait() argument
59 if (unlikely(--sem->count < 0)) in sem_wait()
70 if (unlikely(sem->count <= 0)) in sem_trywait()
73 sem->count--; in sem_trywait()
83 if (unlikely(--sem->count < 0)) { in sem_timedwait()
[all …]
|
| /lk-master/external/platform/pico/common/pico_sync/include/pico/ |
| A D | sem.h | 45 void sem_init(semaphore_t *sem, int16_t initial_permits, int16_t max_permits);
53 int sem_available(semaphore_t *sem);
64 bool sem_release(semaphore_t *sem);
74 void sem_reset(semaphore_t *sem, int16_t permits);
83 void sem_acquire_blocking(semaphore_t *sem);
96 bool sem_acquire_timeout_ms(semaphore_t *sem, uint32_t timeout_ms);
|
| /lk-master/external/lib/lwip/ |
| A D | sys_arch.c | 29 err_t sys_sem_new(sys_sem_t *sem, u8_t count) in sys_sem_new() argument
31 sem_init(sem, count); in sys_sem_new()
35 void sys_sem_free(sys_sem_t * sem) in sys_sem_free() argument
37 sem_destroy(sem); in sys_sem_free()
40 int sys_sem_valid(sys_sem_t *sem) in sys_sem_valid() argument
42 return sem->magic == SEMAPHORE_MAGIC; in sys_sem_valid()
45 void sys_sem_set_invalid(sys_sem_t *sem) in sys_sem_set_invalid() argument
50 void sys_sem_signal(sys_sem_t * sem) in sys_sem_signal() argument
52 sem_post(sem, true); in sys_sem_signal()
55 u32_t sys_arch_sem_wait(sys_sem_t * sem, u32_t timeout) in sys_arch_sem_wait() argument
[all …]
|
| /lk-master/external/lib/lwip/include/lwip/ |
| A D | sys.h | 139 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);
|
| A D | tcpip.h | 72 #define TCPIP_NETIFAPI_ACK(m) sys_sem_signal(&m->sem)
135 sys_sem_t *sem; member
|
| A D | api_msg.h | 142 sys_sem_t *sem; member
|
| A D | netifapi.h | 49 sys_sem_t sem; member
|
| A D | stats.h | 108 struct stats_syselem sem; member
|
| /lk-master/external/lib/lwip/core/ |
| A D | stats.c | 142 LWIP_PLATFORM_DIAG(("sem.used: %"U32_F"\n\t", (u32_t)sys->sem.used)); in stats_display_sys()
143 LWIP_PLATFORM_DIAG(("sem.max: %"U32_F"\n\t", (u32_t)sys->sem.max)); in stats_display_sys()
144 LWIP_PLATFORM_DIAG(("sem.err: %"U32_F"\n\t", (u32_t)sys->sem.err)); in stats_display_sys()
|
| /lk-master/app/tests/ |
| A D | thread_tests.c | 37 static semaphore_t sem; variable
49 sem_post(&sem, true); in semaphore_producer()
70 sem_wait(&sem); in semaphore_consumer()
81 sem_init(&sem, sem_start_value); in semaphore_test()
102 if (sem.count == sem_start_value) in semaphore_test()
105 printf("semaphore tests failed: %d != %d\n", sem.count, sem_start_value); in semaphore_test()
107 sem_destroy(&sem); in semaphore_test()
|
| /lk-master/external/lib/lwip/api/ |
| A D | api_lib.c | 757 sys_sem_t sem; in netconn_gethostbyname() local
762 err = sys_sem_new(&sem, 0); in netconn_gethostbyname()
770 msg.sem = &sem; in netconn_gethostbyname()
773 sys_sem_wait(&sem); in netconn_gethostbyname()
774 sys_sem_free(&sem); in netconn_gethostbyname()
|
| A D | tcpip.c | 365 err_t err = sys_sem_new(&netifapimsg->msg.sem, 0); in tcpip_netifapi()
374 sys_sem_wait(&netifapimsg->msg.sem); in tcpip_netifapi()
375 sys_sem_free(&netifapimsg->msg.sem); in tcpip_netifapi()
|
| A D | sockets.c | 100 sys_sem_t sem; member
1129 err = sys_sem_new(&select_cb.sem, 0);
1181 waitres = sys_arch_sem_wait(&select_cb.sem, msectimeout);
1212 sys_sem_free(&select_cb.sem);
1346 sys_sem_signal(&scb->sem);
|
| A D | api_msg.c | 1542 sys_sem_signal(msg->sem);
1560 sys_sem_signal(msg->sem);
|