Lines Matching refs:mem

146         size = nxt_buf_mem_used_size(&in->mem);  in nxt_h1p_websocket_frame_start()
150 nxt_memmove(in->mem.start, in->mem.pos, size); in nxt_h1p_websocket_frame_start()
152 in->mem.pos = in->mem.start; in nxt_h1p_websocket_frame_start()
153 in->mem.free = in->mem.start + size; in nxt_h1p_websocket_frame_start()
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()
232 size = nxt_buf_mem_used_size(&c->read->mem); in nxt_h1p_conn_ws_frame_header_read()
245 wsh = (nxt_websocket_header_t *) c->read->mem.pos; in nxt_h1p_conn_ws_frame_header_read()
342 if (frame_size < (size_t) nxt_buf_mem_size(&c->read->mem)) { in nxt_h1p_conn_ws_frame_header_read()
343 c->read->mem.end = c->read->mem.start + frame_size; in nxt_h1p_conn_ws_frame_header_read()
557 if (nxt_buf_mem_free_size(&c->read->mem) == 0) { in nxt_h1p_conn_ws_frame_payload_read()
563 wsh = (nxt_websocket_header_t *) r->ws_frame->mem.pos; in nxt_h1p_conn_ws_frame_payload_read()
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()
659 wsh = (nxt_websocket_header_t *) b->mem.pos; in nxt_h1p_conn_ws_pong()
662 b->mem.pos += 2; in nxt_h1p_conn_ws_pong()
664 nxt_memcpy(mask, b->mem.pos, 4); in nxt_h1p_conn_ws_pong()
666 b->mem.pos += 4; 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()
684 while (nxt_buf_mem_used_size(&b->mem) == 0) { in nxt_h1p_conn_ws_pong()
694 *out->mem.free++ = *b->mem.pos++ ^ mask[i % 4]; in nxt_h1p_conn_ws_pong()