Lines Matching refs:size

374     size_t               size;  in nxt_router_start_app_process_handler()  local
414 size = app->name.length + 1 + app->conf.length; in nxt_router_start_app_process_handler()
416 b = nxt_buf_mem_alloc(task->thread->engine->mem_pool, size, 0); in nxt_router_start_app_process_handler()
739 size_t size; in nxt_router_conf_data_handler() local
758 size = 0; in nxt_router_conf_data_handler()
776 nxt_memcpy(&size, msg->buf->mem.pos, sizeof(size_t)); in nxt_router_conf_data_handler()
778 p = nxt_mem_mmap(NULL, size, PROT_READ, MAP_SHARED, msg->fd[0], 0); in nxt_router_conf_data_handler()
787 nxt_debug(task, "conf_data_handler(%uz): %*s", size, size, p); in nxt_router_conf_data_handler()
795 ret = nxt_router_conf_create(task, tmcf, p, nxt_pointer_to(p, size)); in nxt_router_conf_data_handler()
818 nxt_mem_munmap(p, size); in nxt_router_conf_data_handler()
1542 size_t size; in nxt_router_conf_create() local
1628 size = nxt_conf_json_length(application, NULL); in nxt_router_conf_create()
1635 app = nxt_mp_get(app_mp, sizeof(nxt_app_t) + name.length + size); in nxt_router_conf_create()
1651 nxt_assert(app->conf.length <= size); in nxt_router_conf_create()
2513 size_t size; in nxt_router_socket_conf() local
2536 size = nxt_sockaddr_size(sa); in nxt_router_socket_conf()
2542 ls = nxt_zalloc(sizeof(nxt_listen_socket_t) + size); in nxt_router_socket_conf()
2550 nxt_memcpy(ls->sockaddr, sa, size); in nxt_router_socket_conf()
2578 skcf->sockaddr = nxt_mp_zget(tmcf->router_conf->mem_pool, size); in nxt_router_socket_conf()
2583 nxt_memcpy(skcf->sockaddr, sa, size); in nxt_router_socket_conf()
2628 size_t size; in nxt_router_listen_socket_rpc_create() local
2644 size = nxt_sockaddr_size(skcf->listen->sockaddr); in nxt_router_listen_socket_rpc_create()
2646 b = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_listen_socket_rpc_create()
2653 b->mem.free = nxt_cpymem(b->mem.free, skcf->listen->sockaddr, size); in nxt_router_listen_socket_rpc_create()
2734 size_t size; in nxt_router_listen_socket_error()
2751 in = nxt_buf_chk_make_plain(tmcf->mem_pool, msg->buf, msg->size); in nxt_router_listen_socket_error()
2761 size = nxt_length("listen socket error: ") in nxt_router_listen_socket_error()
2765 out = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_listen_socket_error()
2857 size_t size; in nxt_router_app_rpc_create() local
2873 size = app->name.length + 1 + app->conf.length; in nxt_router_app_rpc_create()
2875 b = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_app_rpc_create()
3874 b = (msg->size == 0) ? NULL : msg->buf; in nxt_router_response_ready_handler()
5104 msg.mm.size = nxt_buf_used_size(buf); in nxt_router_app_prepare_request()
5191 size_t fields_count, req_size, size, free_size; in nxt_router_prepare_msg() local
5413 size = nxt_buf_mem_used_size(&b->mem); in nxt_router_prepare_msg()
5416 while (size > 0) { in nxt_router_prepare_msg()
5418 free_size = nxt_min(size, PORT_MMAP_DATA_SIZE); in nxt_router_prepare_msg()
5436 if (free_size < size in nxt_router_prepare_msg()
5437 && nxt_port_mmap_increase_buf(task, buf, size, 1) in nxt_router_prepare_msg()
5445 copy_size = nxt_min(free_size, size); in nxt_router_prepare_msg()
5449 size -= copy_size; in nxt_router_prepare_msg()
5452 if (size == 0) { in nxt_router_prepare_msg()
5534 for (i = 0; i < process->incoming.size; i++) { in nxt_router_oosm_handler()
5611 if (nxt_slow_path(get_mmap_msg->id >= mmaps->size)) { in nxt_router_get_mmap_handler()