Home
last modified time | relevance | path

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

/unit/
H A DCHANGES227 *) Bugfix: mutex leak in the C API.
/unit/src/
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_process.c126 nxt_thread_mutex_create(&process->incoming.mutex); in nxt_process_new()
H A Dnxt_process.h63 nxt_thread_mutex_t mutex; member
H A Dnxt_router.c408 nxt_thread_mutex_lock(&app->mutex); in nxt_router_start_app_process_handler()
412 nxt_thread_mutex_unlock(&app->mutex); in nxt_router_start_app_process_handler()
527 nxt_thread_mutex_lock(&app->mutex); in nxt_router_start_app_process()
531 nxt_thread_mutex_unlock(&app->mutex); in nxt_router_start_app_process()
4252 nxt_thread_mutex_lock(&app->mutex); in nxt_router_req_headers_ack_handler()
4445 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_ready()
4562 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_error()
4607 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_get_port_for_quit()
4718 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_release()
4797 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_close()
[all …]
H A Dnxt_router.h114 nxt_thread_mutex_t mutex; /* Protects ports queue. */ member
H A Dnxt_runtime.c1538 nxt_thread_mutex_destroy(&process->incoming.mutex); in nxt_runtime_process_release()
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_semaphore.h19 nxt_thread_mutex_t mutex; member
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()
5231 pthread_mutex_lock(&lib->mutex); in nxt_unit_ctx_free()
5311 pthread_mutex_lock(&lib->mutex); in nxt_unit_create_port()
5443 pthread_mutex_lock(&lib->mutex); in nxt_unit_add_port()
5653 pthread_mutex_lock(&lib->mutex); in nxt_unit_remove_port()
5701 pthread_mutex_lock(&lib->mutex); in nxt_unit_remove_pid()
[all …]