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

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

83
84 copy_size -= chunk_copy_size;
85 b->mem.pos += chunk_copy_size;
86 buf_free_size -= chunk_copy_size;
87 }
88
89 frame_size -= copy_size;
90 next = b->next;
1
2/*
3 * Copyright (C) NGINX, Inc.
4 */
5
6#include <nxt_main.h>
7#include <nxt_router.h>
8#include <nxt_http.h>

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

83
84 copy_size -= chunk_copy_size;
85 b->mem.pos += chunk_copy_size;
86 buf_free_size -= chunk_copy_size;
87 }
88
89 frame_size -= copy_size;
90 next = b->next;
91 b->next = NULL;
91
92 if (nxt_buf_mem_used_size(&b->mem) == 0) {
93 nxt_work_queue_add(&task->thread->engine->fast_work_queue,
94 b->completion_handler, task, b, b->parent);
95
96 r->ws_frame = next;
97 }
98

--- 63 unchanged lines hidden --- 		92
93 if (nxt_buf_mem_used_size(&b->mem) == 0) {
94 nxt_work_queue_add(&task->thread->engine->fast_work_queue,
95 b->completion_handler, task, b, b->parent);
96
97 r->ws_frame = next;
98 }
99

--- 63 unchanged lines hidden ---