Home
last modified time | relevance | path

Searched refs:mutex (Results 1 – 9 of 9) 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
673 pthread_mutex_lock(&lib->mutex); in nxt_unit_ctx_init()
677 pthread_mutex_unlock(&lib->mutex); in nxt_unit_ctx_init()
1469 pthread_mutex_lock(&lib->mutex); in nxt_unit_request_check_response_port()
5216 pthread_mutex_lock(&lib->mutex); in nxt_unit_ctx_free()
5296 pthread_mutex_lock(&lib->mutex); in nxt_unit_create_port()
5428 pthread_mutex_lock(&lib->mutex); in nxt_unit_add_port()
5638 pthread_mutex_lock(&lib->mutex); in nxt_unit_remove_port()
5686 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.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()
4383 nxt_thread_mutex_lock(&app->mutex); in nxt_router_req_headers_ack_handler()
4576 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_ready()
4693 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_error()
4738 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_get_port_for_quit()
4849 nxt_thread_mutex_lock(&app->mutex); in nxt_router_app_port_release()
4928 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.h106 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.c1414 nxt_thread_mutex_destroy(&process->incoming.mutex); in nxt_runtime_process_release()