Lines Matching refs:mem

422         *b->mem.free++ = '\0';  in nxt_router_start_app_process_handler()
770 if (nxt_buf_mem_used_size(&msg->buf->mem) != sizeof(size_t)) { in nxt_router_conf_data_handler()
772 (int) nxt_buf_mem_used_size(&msg->buf->mem)); in nxt_router_conf_data_handler()
776 nxt_memcpy(&size, msg->buf->mem.pos, sizeof(size_t)); in nxt_router_conf_data_handler()
846 app_name.length = nxt_buf_mem_used_size(&msg->buf->mem); in nxt_router_app_restart_handler()
847 app_name.start = msg->buf->mem.pos; in nxt_router_app_restart_handler()
960 report = (nxt_status_report_t *) b->mem.free; in nxt_router_status_handler()
961 b->mem.free = b->mem.end; in nxt_router_status_handler()
976 p = b->mem.end; in nxt_router_status_handler()
984 app_stat->name.start = (u_char *) (p - b->mem.pos); in nxt_router_status_handler()
2299 void *mem; in nxt_router_app_queue_init() local
2307 mem = nxt_mem_mmap(NULL, sizeof(nxt_app_queue_t), in nxt_router_app_queue_init()
2309 if (nxt_slow_path(mem == MAP_FAILED)) { in nxt_router_app_queue_init()
2315 nxt_app_queue_init(mem); in nxt_router_app_queue_init()
2318 port->queue = mem; in nxt_router_app_queue_init()
2327 void *mem; in nxt_router_port_queue_init() local
2335 mem = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_router_port_queue_init()
2337 if (nxt_slow_path(mem == MAP_FAILED)) { in nxt_router_port_queue_init()
2343 nxt_port_queue_init(mem); in nxt_router_port_queue_init()
2346 port->queue = mem; in nxt_router_port_queue_init()
2355 void *mem; in nxt_router_port_queue_map() local
2359 mem = nxt_mem_mmap(NULL, sizeof(nxt_port_queue_t), in nxt_router_port_queue_map()
2361 if (nxt_slow_path(mem == MAP_FAILED)) { in nxt_router_port_queue_map()
2366 port->queue = mem; in nxt_router_port_queue_map()
2644 b->mem.free = nxt_cpymem(b->mem.free, skcf->listen->sockaddr, size); in nxt_router_listen_socket_rpc_create()
2748 p = in->mem.pos; in nxt_router_listen_socket_error()
2754 + sa->length + socket_errors[error].length + (in->mem.free - p); in nxt_router_listen_socket_error()
2761 out->mem.free = nxt_sprintf(out->mem.free, out->mem.end, in nxt_router_listen_socket_error()
2765 &socket_errors[error], in->mem.free - p, p); in nxt_router_listen_socket_error()
2767 nxt_debug(task, "%*s", out->mem.free - out->mem.pos, out->mem.pos); in nxt_router_listen_socket_error()
2874 *b->mem.free++ = '\0'; in nxt_router_app_rpc_create()
3902 b_size = nxt_buf_is_mem(b) ? nxt_buf_mem_used_size(&b->mem) : 0; in nxt_router_response_ready_handler()
3909 resp = (void *) b->mem.pos; in nxt_router_response_ready_handler()
3959 b->mem.pos = nxt_unit_sptr_get(&resp->piggyback_content); in nxt_router_response_ready_handler()
3960 b->mem.free = b->mem.pos + resp->piggyback_content_length; in nxt_router_response_ready_handler()
3963 b->mem.pos = b->mem.free; in nxt_router_response_ready_handler()
3966 if (nxt_buf_mem_used_size(&b->mem) == 0) { in nxt_router_response_ready_handler()
5094 msg.mm.chunk_id = nxt_port_mmap_chunk_id(hdr, buf->mem.pos); in nxt_router_app_prepare_request()
5112 buf->mem.pos = buf->mem.free; in nxt_router_app_prepare_request()
5225 req = (nxt_unit_request_t *) out->mem.free; in nxt_router_prepare_msg()
5226 out->mem.free += req_size; in nxt_router_prepare_msg()
5392 nxt_unit_sptr_set(&req->preread_content, out->mem.free); in nxt_router_prepare_msg()
5398 size = nxt_buf_mem_used_size(&b->mem); in nxt_router_prepare_msg()
5399 pos = b->mem.pos; in nxt_router_prepare_msg()
5420 free_size = nxt_buf_mem_free_size(&buf->mem); in nxt_router_prepare_msg()
5425 free_size = nxt_buf_mem_free_size(&buf->mem); in nxt_router_prepare_msg()
5432 buf->mem.free = nxt_cpymem(buf->mem.free, pos, copy_size); in nxt_router_prepare_msg()
5578 get_mmap_msg = (nxt_port_msg_get_mmap_t *) msg->buf->mem.pos; in nxt_router_get_mmap_handler()
5648 get_port_msg = (nxt_port_msg_get_port_t *) msg->buf->mem.pos; in nxt_router_get_port_handler()