Home
last modified time | relevance | path

Searched refs:nxt_port_queue_t (Results 1 – 6 of 6) sorted by relevance

/unit/src/
H A Dnxt_port_queue.h30 } nxt_port_queue_t; typedef
34 nxt_port_queue_init(nxt_port_queue_t volatile *q) in nxt_port_queue_init()
50 nxt_port_queue_send(nxt_port_queue_t volatile *q, const void *p, uint8_t size, in nxt_port_queue_send()
78 nxt_port_queue_recv(nxt_port_queue_t volatile *q, void *p) in nxt_port_queue_recv()
H A Dnxt_port.c118 : sizeof(nxt_port_queue_t); in nxt_port_close()
335 port->queue = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_port_process_ready_handler()
H A Dnxt_unit.c503 queue_fd = nxt_unit_shm_open(ctx, sizeof(nxt_port_queue_t)); in nxt_unit_init()
508 mem = mmap(NULL, sizeof(nxt_port_queue_t), in nxt_unit_init()
572 munmap(mem, sizeof(nxt_port_queue_t)); in nxt_unit_init()
1218 mem = mmap(NULL, sizeof(nxt_port_queue_t), PROT_READ | PROT_WRITE, in nxt_unit_process_new_port()
5139 queue_fd = nxt_unit_shm_open(&new_ctx->ctx, sizeof(nxt_port_queue_t)); in nxt_unit_ctx_alloc()
5144 mem = mmap(NULL, sizeof(nxt_port_queue_t), in nxt_unit_ctx_alloc()
5423 : sizeof(nxt_port_queue_t)); in nxt_unit_port_release()
H A Dnxt_port_socket.c820 nxt_port_queue_t *queue; in nxt_port_queue_read_handler()
H A Dnxt_main_process.c428 mem = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_main_new_port_handler()
H A Dnxt_router.c2502 fd = nxt_shm_open(task, sizeof(nxt_port_queue_t)); in nxt_router_port_queue_init()
2507 mem = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_router_port_queue_init()
2531 mem = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_router_port_queue_map()