Lines Matching refs:size
395 size_t size; in nxt_router_start_app_process_handler() local
435 size = app->name.length + 1 + app->conf.length; in nxt_router_start_app_process_handler()
437 b = nxt_buf_mem_alloc(task->thread->engine->mem_pool, size, 0); in nxt_router_start_app_process_handler()
760 size_t size; in nxt_router_conf_data_handler() local
779 size = 0; in nxt_router_conf_data_handler()
797 nxt_memcpy(&size, msg->buf->mem.pos, sizeof(size_t)); in nxt_router_conf_data_handler()
799 p = nxt_mem_mmap(NULL, size, PROT_READ, MAP_SHARED, msg->fd[0], 0); in nxt_router_conf_data_handler()
808 nxt_debug(task, "conf_data_handler(%uz): %*s", size, size, p); in nxt_router_conf_data_handler()
816 ret = nxt_router_conf_create(task, tmcf, p, nxt_pointer_to(p, size)); in nxt_router_conf_data_handler()
839 nxt_mem_munmap(p, size); in nxt_router_conf_data_handler()
1605 size_t size; in nxt_router_conf_create() local
1697 size = nxt_conf_json_length(application, NULL); in nxt_router_conf_create()
1704 app = nxt_mp_get(app_mp, sizeof(nxt_app_t) + name.length + size); in nxt_router_conf_create()
1720 nxt_assert(app->conf.length <= size); in nxt_router_conf_create()
2680 size_t size; in nxt_router_socket_conf() local
2703 size = nxt_sockaddr_size(sa); in nxt_router_socket_conf()
2709 ls = nxt_zalloc(sizeof(nxt_listen_socket_t) + size); in nxt_router_socket_conf()
2717 nxt_memcpy(ls->sockaddr, sa, size); in nxt_router_socket_conf()
2745 skcf->sockaddr = nxt_mp_zget(tmcf->router_conf->mem_pool, size); in nxt_router_socket_conf()
2750 nxt_memcpy(skcf->sockaddr, sa, size); in nxt_router_socket_conf()
2795 size_t size; in nxt_router_listen_socket_rpc_create() local
2811 size = nxt_sockaddr_size(skcf->listen->sockaddr); in nxt_router_listen_socket_rpc_create()
2813 b = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_listen_socket_rpc_create()
2820 b->mem.free = nxt_cpymem(b->mem.free, skcf->listen->sockaddr, size); in nxt_router_listen_socket_rpc_create()
2901 size_t size; in nxt_router_listen_socket_error()
2918 in = nxt_buf_chk_make_plain(tmcf->mem_pool, msg->buf, msg->size); in nxt_router_listen_socket_error()
2928 size = nxt_length("listen socket error: ") in nxt_router_listen_socket_error()
2932 out = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_listen_socket_error()
3024 size_t size; in nxt_router_app_rpc_create() local
3040 size = app->name.length + 1 + app->conf.length; in nxt_router_app_rpc_create()
3042 b = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_app_rpc_create()
3853 size_t size; in nxt_router_listen_socket_release() local
3890 size = nxt_sockaddr_size(ls->sockaddr); in nxt_router_listen_socket_release()
3892 b = nxt_buf_mem_alloc(task->thread->engine->mem_pool, size, 0); in nxt_router_listen_socket_release()
3897 b->mem.free = nxt_cpymem(b->mem.free, ls->sockaddr, size); in nxt_router_listen_socket_release()
4078 b = (msg->size == 0) ? NULL : msg->buf; in nxt_router_response_ready_handler()
5308 msg.mm.size = nxt_buf_used_size(buf); in nxt_router_app_prepare_request()
5395 size_t fields_count, req_size, size, free_size; in nxt_router_prepare_msg() local
5618 size = nxt_buf_mem_used_size(&b->mem); in nxt_router_prepare_msg()
5621 while (size > 0) { in nxt_router_prepare_msg()
5623 free_size = nxt_min(size, PORT_MMAP_DATA_SIZE); in nxt_router_prepare_msg()
5641 if (free_size < size in nxt_router_prepare_msg()
5642 && nxt_port_mmap_increase_buf(task, buf, size, 1) in nxt_router_prepare_msg()
5650 copy_size = nxt_min(free_size, size); in nxt_router_prepare_msg()
5654 size -= copy_size; in nxt_router_prepare_msg()
5657 if (size == 0) { in nxt_router_prepare_msg()
5739 for (i = 0; i < process->incoming.size; i++) { in nxt_router_oosm_handler()
5816 if (nxt_slow_path(get_mmap_msg->id >= mmaps->size)) { in nxt_router_get_mmap_handler()