Lines Matching refs:out

163     nxt_buf_t                  *out;  in nxt_h1p_conn_ws_keepalive()  local
181 out = nxt_http_buf_mem(task, r, 2); in nxt_h1p_conn_ws_keepalive()
182 if (nxt_slow_path(out == NULL)) { in nxt_h1p_conn_ws_keepalive()
187 out->mem.start[0] = 0; in nxt_h1p_conn_ws_keepalive()
188 out->mem.start[1] = 0; in nxt_h1p_conn_ws_keepalive()
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()
196 nxt_http_request_send(task, r, out); in nxt_h1p_conn_ws_keepalive()
583 nxt_buf_t *out; in hxt_h1p_send_ws_error() local
603 out = nxt_http_buf_mem(task, r, 2 + sizeof(err->code) + desc.length); in hxt_h1p_send_ws_error()
604 if (nxt_slow_path(out == NULL)) { in hxt_h1p_send_ws_error()
609 out->mem.start[0] = 0; in hxt_h1p_send_ws_error()
610 out->mem.start[1] = 0; in hxt_h1p_send_ws_error()
612 wsh = (nxt_websocket_header_t *) out->mem.start; in hxt_h1p_send_ws_error()
621 out->mem.free = nxt_cpymem(p, desc.start, desc.length); in hxt_h1p_send_ws_error()
622 out->next = nxt_http_buf_last(r); in hxt_h1p_send_ws_error()
624 if (out->next != NULL) { in hxt_h1p_send_ws_error()
625 out->next->completion_handler = nxt_h1p_conn_ws_error_sent; in hxt_h1p_send_ws_error()
628 nxt_http_request_send(task, r, out); in hxt_h1p_send_ws_error()
649 nxt_buf_t *b, *out, *next; in nxt_h1p_conn_ws_pong() local
668 out = nxt_http_buf_mem(task, r, 2 + payload_len); in nxt_h1p_conn_ws_pong()
669 if (nxt_slow_path(out == NULL)) { in nxt_h1p_conn_ws_pong()
674 out->mem.start[0] = 0; in nxt_h1p_conn_ws_pong()
675 out->mem.start[1] = 0; 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()
694 *out->mem.free++ = *b->mem.pos++ ^ mask[i % 4]; in nxt_h1p_conn_ws_pong()
699 nxt_http_request_send(task, r, out); in nxt_h1p_conn_ws_pong()