Searched refs:nxt_app_queue_t (Results 1 – 4 of 4) sorted by relevance
/unit/src/ |
H A D | nxt_app_queue.h | 30 } nxt_app_queue_t; typedef 34 nxt_app_queue_init(nxt_app_queue_t volatile *q) in nxt_app_queue_init() 50 nxt_app_queue_send(nxt_app_queue_t volatile *q, const void *p, in nxt_app_queue_send() 82 nxt_app_queue_notification_received(nxt_app_queue_t volatile *q) in nxt_app_queue_notification_received() 89 nxt_app_queue_cancel(nxt_app_queue_t volatile *q, uint32_t cookie, in nxt_app_queue_cancel() 101 nxt_app_queue_recv(nxt_app_queue_t volatile *q, void *p, uint32_t *cookie) in nxt_app_queue_recv()
|
H A D | nxt_port.c | 117 size = (port->id == (nxt_port_id_t) -1) ? sizeof(nxt_app_queue_t) in nxt_port_close()
|
H A D | nxt_unit.c | 539 mem = mmap(NULL, sizeof(nxt_app_queue_t), PROT_READ | PROT_WRITE, in nxt_unit_init() 5407 ? sizeof(nxt_app_queue_t) in nxt_unit_port_release() 6258 nxt_app_queue_t *queue; in nxt_unit_app_queue_recv()
|
H A D | nxt_router.c | 2264 fd = nxt_shm_open(task, sizeof(nxt_app_queue_t)); in nxt_router_app_queue_init() 2269 mem = nxt_mem_mmap(NULL, sizeof(nxt_app_queue_t), in nxt_router_app_queue_init()
|