Lines Matching refs:h1p

23     nxt_h1proto_t *h1p);
25 nxt_h1proto_t *h1p);
27 nxt_h1proto_t *h1p, nxt_websocket_header_t *wsh);
78 nxt_h1proto_t *h1p; in nxt_h1p_websocket_first_frame_start() local
83 h1p = r->proto.h1; in nxt_h1p_websocket_first_frame_start()
84 c = h1p->conn; in nxt_h1p_websocket_first_frame_start()
93 h1p->websocket_timer = nxt_mp_zget(c->mem_pool, in nxt_h1p_websocket_first_frame_start()
95 if (nxt_slow_path(h1p->websocket_timer == NULL)) { in nxt_h1p_websocket_first_frame_start()
100 h1p->websocket_timer->keepalive_interval = in nxt_h1p_websocket_first_frame_start()
102 h1p->websocket_timer->h1p = h1p; in nxt_h1p_websocket_first_frame_start()
104 timer = &h1p->websocket_timer->timer; in nxt_h1p_websocket_first_frame_start()
123 nxt_h1proto_t *h1p; in nxt_h1p_websocket_frame_start() local
127 h1p = r->proto.h1; in nxt_h1p_websocket_frame_start()
129 if (nxt_slow_path(h1p->websocket_closed)) { in nxt_h1p_websocket_frame_start()
133 c = h1p->conn; in nxt_h1p_websocket_frame_start()
136 nxt_h1p_complete_buffers(task, h1p, 0); in nxt_h1p_websocket_frame_start()
143 nxt_h1p_conn_ws_keepalive_enable(task, h1p); in nxt_h1p_websocket_frame_start()
155 nxt_h1p_conn_ws_frame_header_read(task, c, h1p); in nxt_h1p_websocket_frame_start()
165 nxt_h1proto_t *h1p; in nxt_h1p_conn_ws_keepalive() local
174 h1p = ws_timer->h1p; in nxt_h1p_conn_ws_keepalive()
176 r = h1p->request; in nxt_h1p_conn_ws_keepalive()
222 nxt_h1proto_t *h1p; in nxt_h1p_conn_ws_frame_header_read() local
228 h1p = data; in nxt_h1p_conn_ws_frame_header_read()
230 nxt_h1p_conn_ws_keepalive_disable(task, h1p); in nxt_h1p_conn_ws_frame_header_read()
240 nxt_h1p_conn_ws_keepalive_enable(task, h1p); in nxt_h1p_conn_ws_frame_header_read()
253 nxt_h1p_conn_ws_keepalive_enable(task, h1p); in nxt_h1p_conn_ws_frame_header_read()
258 r = h1p->request; in nxt_h1p_conn_ws_frame_header_read()
299 if (h1p->websocket_cont_expected) { in nxt_h1p_conn_ws_frame_header_read()
316 h1p->websocket_cont_expected = !wsh->fin; 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()
353 nxt_h1p_conn_ws_keepalive_enable(task, h1p); in nxt_h1p_conn_ws_frame_header_read()
358 nxt_h1p_conn_ws_keepalive_disable(nxt_task_t *task, nxt_h1proto_t *h1p) in nxt_h1p_conn_ws_keepalive_disable() argument
362 if (h1p->websocket_timer == NULL) { in nxt_h1p_conn_ws_keepalive_disable()
366 timer = &h1p->websocket_timer->timer; in nxt_h1p_conn_ws_keepalive_disable()
378 nxt_h1p_conn_ws_keepalive_enable(nxt_task_t *task, nxt_h1proto_t *h1p) in nxt_h1p_conn_ws_keepalive_enable() argument
382 if (h1p->websocket_timer == NULL) { in nxt_h1p_conn_ws_keepalive_enable()
386 timer = &h1p->websocket_timer->timer; in nxt_h1p_conn_ws_keepalive_enable()
394 h1p->websocket_timer->keepalive_interval); in nxt_h1p_conn_ws_keepalive_enable()
400 nxt_h1proto_t *h1p, nxt_websocket_header_t *wsh) in nxt_h1p_conn_ws_frame_process() argument
407 r = h1p->request; in nxt_h1p_conn_ws_frame_process()
434 h1p->websocket_closed = 1; in nxt_h1p_conn_ws_frame_process()
444 nxt_h1proto_t *h1p; in nxt_h1p_conn_ws_error() local
447 h1p = data; in nxt_h1p_conn_ws_error()
451 r = h1p->request; in nxt_h1p_conn_ws_error()
453 h1p->keepalive = 0; in nxt_h1p_conn_ws_error()
456 r->state->error_handler(task, r, h1p); in nxt_h1p_conn_ws_error()
500 nxt_h1proto_t *h1p; in nxt_h1p_conn_ws_timeout() local
515 h1p = c->socket.data; in nxt_h1p_conn_ws_timeout()
516 h1p->keepalive = 0; in nxt_h1p_conn_ws_timeout()
518 r = h1p->request; in nxt_h1p_conn_ws_timeout()
545 nxt_h1proto_t *h1p; in nxt_h1p_conn_ws_frame_payload_read() local
551 h1p = data; in nxt_h1p_conn_ws_frame_payload_read()
553 nxt_h1p_conn_ws_keepalive_disable(task, h1p); in nxt_h1p_conn_ws_frame_payload_read()
558 r = h1p->request; 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()
573 nxt_h1p_conn_ws_keepalive_enable(task, h1p); in nxt_h1p_conn_ws_frame_payload_read()