nxt_http_websocket.c (1269:41331471eee7) nxt_http_websocket.c (1546:06017e6e3a5f)
1
2/*
3 * Copyright (C) NGINX, Inc.
4 */
5
6#include <nxt_main.h>
7#include <nxt_router.h>
8#include <nxt_http.h>

--- 55 unchanged lines hidden (view full) ---

64 while (b != NULL && frame_size > 0) {
65 used_size = nxt_buf_mem_used_size(&b->mem);
66 copy_size = nxt_min(used_size, frame_size);
67
68 while (copy_size > 0) {
69 if (buf == NULL || buf_free_size == 0) {
70 buf_free_size = nxt_min(frame_size, PORT_MMAP_DATA_SIZE);
71
1
2/*
3 * Copyright (C) NGINX, Inc.
4 */
5
6#include <nxt_main.h>
7#include <nxt_router.h>
8#include <nxt_http.h>

--- 55 unchanged lines hidden (view full) ---

64 while (b != NULL && frame_size > 0) {
65 used_size = nxt_buf_mem_used_size(&b->mem);
66 copy_size = nxt_min(used_size, frame_size);
67
68 while (copy_size > 0) {
69 if (buf == NULL || buf_free_size == 0) {
70 buf_free_size = nxt_min(frame_size, PORT_MMAP_DATA_SIZE);
71
72 buf = nxt_port_mmap_get_buf(task, req_app_link->app_port,
72 buf = nxt_port_mmap_get_buf(task,
73 &req_app_link->app_port->process->outgoing,
73 buf_free_size);
74
75 *out_tail = buf;
76 out_tail = &buf->next;
77 }
78
79 chunk_copy_size = nxt_min(buf_free_size, copy_size);
80

--- 82 unchanged lines hidden --- 		74 buf_free_size);
75
76 *out_tail = buf;
77 out_tail = &buf->next;
78 }
79
80 chunk_copy_size = nxt_min(buf_free_size, copy_size);
81

--- 82 unchanged lines hidden ---