Lines Matching refs:size

370     size_t               size;  in nxt_router_start_app_process_handler()  local
410 size = app->name.length + 1 + app->conf.length; in nxt_router_start_app_process_handler()
412 b = nxt_buf_mem_alloc(task->thread->engine->mem_pool, size, 0); in nxt_router_start_app_process_handler()
735 size_t size; in nxt_router_conf_data_handler() local
754 size = 0; in nxt_router_conf_data_handler()
772 nxt_memcpy(&size, msg->buf->mem.pos, sizeof(size_t)); in nxt_router_conf_data_handler()
774 p = nxt_mem_mmap(NULL, size, PROT_READ, MAP_SHARED, msg->fd[0], 0); in nxt_router_conf_data_handler()
783 nxt_debug(task, "conf_data_handler(%uz): %*s", size, size, p); in nxt_router_conf_data_handler()
791 ret = nxt_router_conf_create(task, tmcf, p, nxt_pointer_to(p, size)); in nxt_router_conf_data_handler()
814 nxt_mem_munmap(p, size); in nxt_router_conf_data_handler()
1456 size_t size; in nxt_router_conf_create() local
1542 size = nxt_conf_json_length(application, NULL); in nxt_router_conf_create()
1549 app = nxt_mp_get(app_mp, sizeof(nxt_app_t) + name.length + size); in nxt_router_conf_create()
1565 nxt_assert(app->conf.length <= size); in nxt_router_conf_create()
2422 size_t size; in nxt_router_socket_conf() local
2445 size = nxt_sockaddr_size(sa); in nxt_router_socket_conf()
2451 ls = nxt_zalloc(sizeof(nxt_listen_socket_t) + size); in nxt_router_socket_conf()
2459 nxt_memcpy(ls->sockaddr, sa, size); in nxt_router_socket_conf()
2487 skcf->sockaddr = nxt_mp_zget(tmcf->router_conf->mem_pool, size); in nxt_router_socket_conf()
2492 nxt_memcpy(skcf->sockaddr, sa, size); in nxt_router_socket_conf()
2537 size_t size; in nxt_router_listen_socket_rpc_create() local
2553 size = nxt_sockaddr_size(skcf->listen->sockaddr); in nxt_router_listen_socket_rpc_create()
2555 b = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_listen_socket_rpc_create()
2562 b->mem.free = nxt_cpymem(b->mem.free, skcf->listen->sockaddr, size); in nxt_router_listen_socket_rpc_create()
2643 size_t size; in nxt_router_listen_socket_error()
2660 in = nxt_buf_chk_make_plain(tmcf->mem_pool, msg->buf, msg->size); in nxt_router_listen_socket_error()
2670 size = nxt_length("listen socket error: ") in nxt_router_listen_socket_error()
2674 out = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_listen_socket_error()
2766 size_t size; in nxt_router_app_rpc_create() local
2782 size = app->name.length + 1 + app->conf.length; in nxt_router_app_rpc_create()
2784 b = nxt_buf_mem_alloc(tmcf->mem_pool, size, 0); in nxt_router_app_rpc_create()
3783 b = (msg->size == 0) ? NULL : msg->buf; in nxt_router_response_ready_handler()
5013 msg.mm.size = nxt_buf_used_size(buf); in nxt_router_app_prepare_request()
5100 size_t fields_count, req_size, size, free_size; in nxt_router_prepare_msg() local
5316 size = nxt_buf_mem_used_size(&b->mem); in nxt_router_prepare_msg()
5319 while (size > 0) { in nxt_router_prepare_msg()
5321 free_size = nxt_min(size, PORT_MMAP_DATA_SIZE); in nxt_router_prepare_msg()
5339 if (free_size < size in nxt_router_prepare_msg()
5340 && nxt_port_mmap_increase_buf(task, buf, size, 1) in nxt_router_prepare_msg()
5348 copy_size = nxt_min(free_size, size); in nxt_router_prepare_msg()
5352 size -= copy_size; in nxt_router_prepare_msg()
5355 if (size == 0) { in nxt_router_prepare_msg()
5437 for (i = 0; i < process->incoming.size; i++) { in nxt_router_oosm_handler()
5514 if (nxt_slow_path(get_mmap_msg->id >= mmaps->size)) { in nxt_router_get_mmap_handler()