Lines Matching refs:wsh

27     nxt_h1proto_t *h1p, nxt_websocket_header_t *wsh);
167 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_keepalive() local
190 wsh = (nxt_websocket_header_t *) out->mem.start; in nxt_h1p_conn_ws_keepalive()
191 out->mem.free = nxt_websocket_frame_init(wsh, 0); in nxt_h1p_conn_ws_keepalive()
193 wsh->fin = 1; in nxt_h1p_conn_ws_keepalive()
194 wsh->opcode = NXT_WEBSOCKET_OP_PING; in nxt_h1p_conn_ws_keepalive()
225 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_header_read() local
245 wsh = (nxt_websocket_header_t *) c->read->mem.pos; in nxt_h1p_conn_ws_frame_header_read()
247 hsize = nxt_websocket_frame_header_size(wsh); in nxt_h1p_conn_ws_frame_header_read()
265 if (nxt_slow_path(wsh->mask == 0)) { in nxt_h1p_conn_ws_frame_header_read()
270 if ((wsh->opcode & NXT_WEBSOCKET_OP_CTRL) != 0) { in nxt_h1p_conn_ws_frame_header_read()
271 if (nxt_slow_path(wsh->fin == 0)) { in nxt_h1p_conn_ws_frame_header_read()
276 if (nxt_slow_path(wsh->opcode != NXT_WEBSOCKET_OP_PING in nxt_h1p_conn_ws_frame_header_read()
277 && wsh->opcode != NXT_WEBSOCKET_OP_PONG in nxt_h1p_conn_ws_frame_header_read()
278 && wsh->opcode != NXT_WEBSOCKET_OP_CLOSE)) in nxt_h1p_conn_ws_frame_header_read()
281 wsh->opcode); in nxt_h1p_conn_ws_frame_header_read()
285 if (nxt_slow_path(wsh->payload_len > 125)) { in nxt_h1p_conn_ws_frame_header_read()
287 nxt_websocket_frame_payload_len(wsh)); in nxt_h1p_conn_ws_frame_header_read()
291 if (nxt_slow_path(wsh->opcode == NXT_WEBSOCKET_OP_CLOSE in nxt_h1p_conn_ws_frame_header_read()
292 && wsh->payload_len == 1)) in nxt_h1p_conn_ws_frame_header_read()
300 if (nxt_slow_path(wsh->opcode != NXT_WEBSOCKET_OP_CONT)) { in nxt_h1p_conn_ws_frame_header_read()
302 wsh->opcode); in nxt_h1p_conn_ws_frame_header_read()
307 if (nxt_slow_path(wsh->opcode != NXT_WEBSOCKET_OP_BINARY in nxt_h1p_conn_ws_frame_header_read()
308 && wsh->opcode != NXT_WEBSOCKET_OP_TEXT)) in nxt_h1p_conn_ws_frame_header_read()
311 wsh->opcode); in nxt_h1p_conn_ws_frame_header_read()
316 h1p->websocket_cont_expected = !wsh->fin; in nxt_h1p_conn_ws_frame_header_read()
321 payload_len = nxt_websocket_frame_payload_len(wsh); in nxt_h1p_conn_ws_frame_header_read()
337 nxt_h1p_conn_ws_frame_process(task, c, h1p, wsh); in nxt_h1p_conn_ws_frame_header_read()
400 nxt_h1proto_t *h1p, nxt_websocket_header_t *wsh) in nxt_h1p_conn_ws_frame_process() argument
411 if (nxt_slow_path(wsh->opcode == NXT_WEBSOCKET_OP_PING)) { in nxt_h1p_conn_ws_frame_process()
416 if (nxt_slow_path(wsh->opcode == NXT_WEBSOCKET_OP_CLOSE)) { in nxt_h1p_conn_ws_frame_process()
417 if (wsh->payload_len >= 2) { in nxt_h1p_conn_ws_frame_process()
418 hsize = nxt_websocket_frame_header_size(wsh); in nxt_h1p_conn_ws_frame_process()
419 mask = nxt_pointer_to(wsh, hsize - 4); in nxt_h1p_conn_ws_frame_process()
420 p = nxt_pointer_to(wsh, hsize); in nxt_h1p_conn_ws_frame_process()
548 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_frame_payload_read() local
563 wsh = (nxt_websocket_header_t *) r->ws_frame->mem.pos; in nxt_h1p_conn_ws_frame_payload_read()
565 nxt_h1p_conn_ws_frame_process(task, c, h1p, wsh); in nxt_h1p_conn_ws_frame_payload_read()
585 nxt_websocket_header_t *wsh; in hxt_h1p_send_ws_error() local
612 wsh = (nxt_websocket_header_t *) out->mem.start; in hxt_h1p_send_ws_error()
613 p = nxt_websocket_frame_init(wsh, sizeof(err->code) + desc.length); in hxt_h1p_send_ws_error()
615 wsh->fin = 1; in hxt_h1p_send_ws_error()
616 wsh->opcode = NXT_WEBSOCKET_OP_CLOSE; in hxt_h1p_send_ws_error()
651 nxt_websocket_header_t *wsh; in nxt_h1p_conn_ws_pong() local
659 wsh = (nxt_websocket_header_t *) b->mem.pos; in nxt_h1p_conn_ws_pong()
660 payload_len = wsh->payload_len; in nxt_h1p_conn_ws_pong()
677 wsh = (nxt_websocket_header_t *) out->mem.start; in nxt_h1p_conn_ws_pong()
678 out->mem.free = nxt_websocket_frame_init(wsh, payload_len); in nxt_h1p_conn_ws_pong()
680 wsh->fin = 1; in nxt_h1p_conn_ws_pong()
681 wsh->opcode = NXT_WEBSOCKET_OP_PONG; in nxt_h1p_conn_ws_pong()