nxt_h1proto_websocket.c (1155:8f70f87d0254) nxt_h1proto_websocket.c (1268:dc403927ab0b)
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);
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_conn_t *c);
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
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_conn_t *c)
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 ---
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 ---