Home
last modified time | relevance | path

Searched refs:mutex (Results 1 – 10 of 10) sorted by relevance

/unit/src/
H A Dnxt_semaphore.c174 if (nxt_thread_mutex_create(&sem->mutex) == NXT_OK) { in nxt_sem_init()
181 nxt_thread_mutex_destroy(&sem->mutex); in nxt_sem_init()
192 nxt_thread_mutex_destroy(&sem->mutex); in nxt_sem_destroy()
201 if (nxt_slow_path(nxt_thread_mutex_lock(&sem->mutex) != NXT_OK)) { in nxt_sem_post()
211 return (nxt_thread_mutex_unlock(&sem->mutex) | ret); in nxt_sem_post()
222 if (nxt_slow_path(nxt_thread_mutex_lock(&sem->mutex) != NXT_OK)) { in nxt_sem_wait()
228 err = nxt_thread_cond_wait(&sem->cond, &sem->mutex, timeout); in nxt_sem_wait()
241 return (nxt_thread_mutex_unlock(&sem->mutex) | err); in nxt_sem_wait()
H A Dnxt_unit.c343 pthread_mutex_t mutex; member
362 pthread_mutex_t mutex; member
687 pthread_mutex_lock(&lib->mutex); in nxt_unit_ctx_init()
691 pthread_mutex_unlock(&lib->mutex); in nxt_unit_ctx_init()
1483 pthread_mutex_lock(&lib->mutex); in nxt_unit_request_check_response_port()
5230 pthread_mutex_lock(&lib->mutex); in nxt_unit_ctx_free()
5310 pthread_mutex_lock(&lib->mutex); in nxt_unit_create_port()
5442 pthread_mutex_lock(&lib->mutex); in nxt_unit_add_port()
5652 pthread_mutex_lock(&lib->mutex); in nxt_unit_remove_port()
5700 pthread_mutex_lock(&lib->mutex); in nxt_unit_remove_pid()
[all …]
H A Dnxt_semaphore.h19 nxt_thread_mutex_t mutex; member
H A Dnxt_router.c386 nxt_thread_mutex_lock(&app->mutex); in nxt_router_start_app_process_handler()
390 nxt_thread_mutex_unlock(&app->mutex); in nxt_router_start_app_process_handler()
505 nxt_thread_mutex_lock(&app->mutex); in nxt_router_start_app_process()
509 nxt_thread_mutex_unlock(&app->mutex); in nxt_router_start_app_process()
4043 nxt_thread_mutex_lock(&app->mutex); in nxt_router_req_headers_ack_handler()
4236 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_ready()
4353 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_error()
4398 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_get_port_for_quit()
4509 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_release()
4588 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_close()
[all …]
H A Dnxt_port_memory.c259 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_port_incoming_port_mmap()
280 nxt_thread_mutex_unlock(&process->incoming.mutex); in nxt_port_incoming_port_mmap()
455 nxt_thread_mutex_lock(&mmaps->mutex); in nxt_port_mmap_get()
508 nxt_thread_mutex_unlock(&mmaps->mutex); in nxt_port_mmap_get()
525 nxt_thread_mutex_lock(&process->incoming.mutex); in nxt_port_get_port_incoming_mmap()
536 nxt_thread_mutex_unlock(&process->incoming.mutex); in nxt_port_get_port_incoming_mmap()
H A Dnxt_router.h108 nxt_thread_mutex_t mutex; /* Protects ports queue. */ member
H A Dnxt_process.h69 nxt_thread_mutex_t mutex; member
H A Dnxt_process.c110 nxt_thread_mutex_create(&process->incoming.mutex); in nxt_process_new()
H A Dnxt_runtime.c1417 nxt_thread_mutex_destroy(&process->incoming.mutex); in nxt_runtime_process_release()
/unit/
H A DCHANGES38 *) Bugfix: mutex leak in the C API.