| /lib/lwip/lwip/contrib/ports/unix/port/ |
| A D | sys_arch.c | 477 pthread_cond_init(&(sem->cond), &(sem->condattr)); in sys_sem_new_internal() 480 return sem; in sys_sem_new_internal() 559 sem = *s; in sys_arch_sem_wait() 583 sem->c--; in sys_arch_sem_wait() 593 sem = *s; in sys_sem_signal() 596 sem->c++; in sys_sem_signal() 612 free(sem); in sys_sem_free_internal() 618 if ((sem != NULL) && (*sem != SYS_SEM_NULL)) { in sys_sem_free() 681 if (sem) { in sys_thread_sem_free() 700 return sem; in sys_thread_sem_alloc() [all …]
|
| /lib/lwip/lwip/contrib/ports/win32/ |
| A D | sys_arch.c | 257 sem->sem = new_sem; in sys_sem_new() 267 sem->sem = NULL; in sys_sem_new() 276 LWIP_ASSERT("sem->sem != NULL", sem->sem != NULL); in sys_sem_free() 278 CloseHandle(sem->sem); in sys_sem_free() 284 sem->sem = NULL; in sys_sem_free() 293 LWIP_ASSERT("sem->sem != NULL", sem->sem != NULL); in sys_arch_sem_wait() 298 ret = WaitForSingleObject(sem->sem, INFINITE); in sys_arch_sem_wait() 305 ret = WaitForSingleObject(sem->sem, timeout); in sys_arch_sem_wait() 324 LWIP_ASSERT("sem->sem != NULL", sem->sem != NULL); in sys_sem_signal() 326 ret = ReleaseSemaphore(sem->sem, 1, NULL); in sys_sem_signal() [all …]
|
| /lib/lwip/lwip/test/unit/arch/ |
| A D | sys_arch.c | 78 *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 D | sys_arch.h | 42 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))
|
| /lib/lwip/lwip/contrib/ports/freertos/ |
| A D | sys_arch.c | 255 sem->sem = xSemaphoreCreateBinary(); in sys_sem_new() 256 if(sem->sem == NULL) { in sys_sem_new() 263 BaseType_t ret = xSemaphoreGive(sem->sem); in sys_sem_new() 274 LWIP_ASSERT("sem->sem != NULL", sem->sem != NULL); in sys_sem_signal() 276 ret = xSemaphoreGive(sem->sem); in sys_sem_signal() 287 LWIP_ASSERT("sem->sem != NULL", sem->sem != NULL); in sys_arch_sem_wait() 291 ret = xSemaphoreTake(sem->sem, portMAX_DELAY); in sys_arch_sem_wait() 295 ret = xSemaphoreTake(sem->sem, timeout_ticks); in sys_arch_sem_wait() 313 LWIP_ASSERT("sem->sem != NULL", sem->sem != NULL); in sys_sem_free() 316 vSemaphoreDelete(sem->sem); in sys_sem_free() [all …]
|
| /lib/lwip/lwip/contrib/ports/unix/port/include/arch/ |
| A D | sys_arch.h | 42 #define sys_sem_valid(sem) (((sem) != NULL) && (*(sem) != NULL)) argument 43 #define sys_sem_valid_val(sem) ((sem) != NULL) argument 44 #define sys_sem_set_invalid(sem) do { if((sem) != NULL) { *(sem) = NULL; }}while(0) argument 45 #define sys_sem_set_invalid_val(sem) do { (sem) = NULL; }while(0) argument
|
| /lib/lwip/lwip/contrib/ports/win32/include/arch/ |
| A D | sys_arch.h | 37 void *sem; member 40 #define sys_sem_valid_val(sema) (((sema).sem != NULL) && ((sema).sem != (void*)-1)) 42 #define sys_sem_set_invalid(sema) ((sema)->sem = NULL) 57 void* sem; member 63 #define sys_mbox_valid_val(mbox) (((mbox).sem != NULL) && ((mbox).sem != (void*)-1)) 65 #define sys_mbox_set_invalid(mbox) ((mbox)->sem = NULL)
|
| /lib/lwip/lwip/contrib/ports/unix/port/netif/ |
| A D | fifo.c | 29 sys_sem_wait(&fifo->sem); /* enter critical section */ in fifoGet() 34 … sys_sem_signal(&fifo->sem); /* leave critical section (allow input from serial port..) */ in fifoGet() 36 sys_sem_wait(&fifo->sem); /* reenter critical section */ in fifoGet() 46 sys_sem_signal(&fifo->sem); /* leave critical section */ in fifoGet() 55 sys_sem_wait(&fifo->sem); /* enter critical section */ in fifoGetNonBlock() 72 sys_sem_signal(&fifo->sem); /* leave critical section */ in fifoGetNonBlock() 82 sys_sem_wait(&fifo->sem ); /* enter critical */ in fifoPut() 112 sys_sem_signal(&fifo->sem ); /* leave critical */ in fifoPut() 122 sys_sem_signal(&fifo->sem ); /* leave critical */ in fifoPut() 132 if(sys_sem_new(&fifo->sem, 1) != ERR_OK) { /* critical section 1=free to enter */ in fifoInit()
|
| A D | pcapif.c | 65 sys_sem_t sem; member 131 sys_sem_signal(&pcapif->sem); in timeout() 171 sys_sem_wait(&pcapif->sem); in pcapif_thread() 197 if(sys_sem_new(&p->sem, 0) != ERR_OK) { in pcapif_init()
|
| /lib/lwip/lwip/src/include/lwip/ |
| A D | sys.h | 195 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))
|
| A D | stats.h | 118 struct stats_syselem sem; member
|
| /lib/lwip/lwip/src/api/ |
| A D | tcpip.c | 172 sys_sem_signal(msg->msg.cb_wait.sem); in tcpip_thread_handle_msg() 445 LWIP_UNUSED_ARG(sem); in tcpip_send_msg_wait_sem() 461 sys_arch_sem_wait(sem, 0); in tcpip_send_msg_wait_sem() 490 err_t err = sys_sem_new(&call->sem, 0); in tcpip_api_call() 505 TCPIP_MSG_VAR_REF(msg).msg.api_call.sem = &call->sem; in tcpip_api_call() 512 sys_sem_free(&call->sem); in tcpip_api_call() 619 sys_sem_t sem; in tcpip_callback_wait() 624 err = sys_sem_new(&sem, 0); in tcpip_callback_wait() 632 msg.msg.cb_wait.sem = &sem; in tcpip_callback_wait() 634 sys_arch_sem_wait(&sem, 0); in tcpip_callback_wait() [all …]
|
| A D | api_lib.c | 1279 sys_sem_t sem; local 1308 msg.sem = &sem; 1316 API_VAR_REF(msg).sem = LWIP_NETCONN_THREAD_SEM_GET(); 1318 err = sys_sem_new(API_EXPR_REF(API_VAR_REF(msg).sem), 0); 1325 …msg_wait_sem(lwip_netconn_do_gethostbyname, &API_VAR_REF(msg), API_EXPR_REF(API_VAR_REF(msg).sem)); 1327 sys_sem_free(API_EXPR_REF(API_VAR_REF(msg).sem)); 1348 sys_sem_t *sem = LWIP_NETCONN_THREAD_SEM_GET(); local 1349 if (!sys_sem_valid(sem)) { 1359 sys_sem_t *sem = LWIP_NETCONN_THREAD_SEM_GET(); local 1360 if (sys_sem_valid(sem)) {
|
| A D | sockets.c | 2063 API_SELECT_CB_VAR_REF(select_cb).sem = LWIP_NETCONN_THREAD_SEM_GET(); in lwip_select() 2065 if (sys_sem_new(&API_SELECT_CB_VAR_REF(select_cb).sem, 0) != ERR_OK) { in lwip_select() 2131 … waitres = sys_arch_sem_wait(SELECT_SEM_PTR(API_SELECT_CB_VAR_REF(select_cb).sem), msectimeout); in lwip_select() 2168 sys_arch_sem_wait(API_SELECT_CB_VAR_REF(select_cb).sem, 1); in lwip_select() 2171 sys_sem_free(&API_SELECT_CB_VAR_REF(select_cb).sem); in lwip_select() 2408 API_SELECT_CB_VAR_REF(select_cb).sem = LWIP_NETCONN_THREAD_SEM_GET(); in lwip_poll() 2410 if (sys_sem_new(&API_SELECT_CB_VAR_REF(select_cb).sem, 0) != ERR_OK) { in lwip_poll() 2436 … waitres = sys_arch_sem_wait(SELECT_SEM_PTR(API_SELECT_CB_VAR_REF(select_cb).sem), msectimeout); in lwip_poll() 2451 sys_arch_sem_wait(API_SELECT_CB_VAR_REF(select_cb).sem, 1); in lwip_poll() 2454 sys_sem_free(&API_SELECT_CB_VAR_REF(select_cb).sem); in lwip_poll() [all …]
|
| /lib/lwip/lwip/src/include/lwip/priv/ |
| A D | sockets_priv.h | 140 #define SELECT_SEM_PTR(sem) (sem) argument 143 #define SELECT_SEM_PTR(sem) (&(sem)) argument 169 SELECT_SEM_T sem; member
|
| A D | tcpip_priv.h | 97 err_t tcpip_send_msg_wait_sem(tcpip_callback_fn fn, void *apimsg, sys_sem_t* sem); 104 sys_sem_t sem; member 141 sys_sem_t *sem; member 146 sys_sem_t *sem; member
|
| A D | api_msg.h | 184 sys_sem_t API_MSG_M_DEF_SEM(sem);
|
| /lib/lwip/lwip/contrib/addons/netconn/external_resolve/ |
| A D | dnssd.c | 74 sys_sem_t sem; member 108 msg.err = sys_sem_new(&msg.sem, 0); in lwip_dnssd_gethostbyname() 116 sys_arch_sem_wait(&msg.sem, GETADDR_TIMEOUT_MS); in lwip_dnssd_gethostbyname() 130 sys_sem_free(&msg.sem); in lwip_dnssd_gethostbyname() 163 sys_sem_signal(&msg->sem); in addr_info_callback()
|
| /lib/lwip/lwip/src/apps/snmp/ |
| A D | snmp_threadsync.c | 49 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()
|
| /lib/lwip/lwip/contrib/Coverity/ |
| A D | coverity.c | 39 u32_t sys_arch_sem_wait(sys_sem_t *sem, u32_t timeout) in sys_arch_sem_wait() argument 41 __coverity_recursive_lock_acquire__(sem); in sys_arch_sem_wait() 43 void sys_sem_signal(sys_sem_t *sem) in sys_sem_signal() argument 45 __coverity_recursive_lock_release__(sem); in sys_sem_signal()
|
| /lib/lwip/lwip/contrib/ports/freertos/include/arch/ |
| A D | sys_arch.h | 66 void *sem; member 69 #define sys_sem_valid_val(sema) ((sema).sem != NULL) 71 #define sys_sem_set_invalid(sema) ((sema)->sem = NULL)
|
| /lib/lwip/lwip/contrib/apps/socket_examples/ |
| A D | socket_examples.c | 472 sys_sem_t sem; member 526 sys_sem_signal(&helper->sem); in sockex_select_waiter() 593 lwiperr = sys_sem_new(&h1.sem, 0); in sockex_testtwoselects() 599 lwiperr = sys_sem_new(&h2.sem, 0); in sockex_testtwoselects() 605 lwiperr = sys_sem_new(&h3.sem, 0); in sockex_testtwoselects() 611 lwiperr = sys_sem_new(&h4.sem, 0); in sockex_testtwoselects() 627 sys_sem_wait(&h1.sem); in sockex_testtwoselects() 628 sys_sem_wait(&h2.sem); in sockex_testtwoselects() 629 sys_sem_wait(&h3.sem); in sockex_testtwoselects() 630 sys_sem_wait(&h4.sem); in sockex_testtwoselects()
|
| /lib/lwip/lwip/src/core/ |
| A D | stats.c | 130 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()
|
| /lib/lwip/lwip/contrib/ports/unix/port/include/netif/ |
| A D | fifo.h | 16 sys_sem_t sem; /* semaphore protecting simultaneous data manipulation */ member
|
| /lib/lwip/lwip/src/include/lwip/apps/ |
| A D | snmp_threadsync.h | 78 sys_sem_t sem; member
|