Deleted
Added
1 2/* 3 * Copyright (C) NGINX, Inc. 4 */ 5 6#include <nxt_main.h> 7#include <nxt_router.h> 8#include <nxt_http.h> --- 12 unchanged lines hidden (view full) --- 21 void *data); 22static void nxt_h1p_conn_ws_keepalive_disable(nxt_task_t *task, 23 nxt_h1proto_t *h1p); 24static void nxt_h1p_conn_ws_keepalive_enable(nxt_task_t *task, 25 nxt_h1proto_t *h1p); 26static void nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, 27 nxt_h1proto_t *h1p, nxt_websocket_header_t *wsh); 28static void nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data); |
29static ssize_t nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c); |
30static void nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data); 31static void nxt_h1p_conn_ws_frame_payload_read(nxt_task_t *task, void *obj, 32 void *data); 33static void hxt_h1p_send_ws_error(nxt_task_t *task, nxt_http_request_t *r, 34 const nxt_ws_error_t *err, ...); 35static void nxt_h1p_conn_ws_error_sent(nxt_task_t *task, void *obj, void *data); 36static void nxt_h1p_conn_ws_pong(nxt_task_t *task, void *obj, void *data); 37 --- 430 unchanged lines hidden (view full) --- 468 469 if (nxt_fast_path(r != NULL)) { 470 r->state->error_handler(task, r, h1p); 471 } 472} 473 474 475static ssize_t |
476nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c) |
477{ 478 size_t size; 479 ssize_t n; 480 nxt_buf_t *b; 481 482 b = c->read; 483 484 if (b == NULL) { --- 231 unchanged lines hidden --- |