Lines Matching refs:mem

294     n = c->io->recv(c, b->mem.pos, 16, MSG_PEEK);  in nxt_http_idle_io_read_handler()
324 p = b->mem.pos; in nxt_http_conn_test()
329 b->mem.free = b->mem.pos; in nxt_http_conn_test()
338 if (nxt_buf_mem_used_size(&b->mem) >= 11) { in nxt_http_conn_test()
559 ret = nxt_http_parse_request(&h1p->parser, &c->read->mem); in nxt_h1p_conn_request_header_parse()
712 if (nxt_buf_mem_free_size(&in->mem) == 0) { in nxt_h1p_header_buffer_test()
714 used = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_header_buffer_test()
725 b->mem.free = nxt_cpymem(b->mem.pos, in->mem.pos, used); in nxt_h1p_header_buffer_test()
907 tmp_name.start = nxt_pointer_to(b->mem.start, sizeof(nxt_file_t)); in nxt_h1p_request_body_read()
914 b->file = (nxt_file_t *) b->mem.start; in nxt_h1p_request_body_read()
919 b->mem.start += sizeof(nxt_file_t) + tmp_name.length + 1; in nxt_h1p_request_body_read()
920 b->mem.pos = b->mem.start; in nxt_h1p_request_body_read()
921 b->mem.free = b->mem.start; in nxt_h1p_request_body_read()
941 size = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_request_body_read()
947 res = nxt_fd_write(b->file->fd, in->mem.pos, size); in nxt_h1p_request_body_read()
957 b->mem.free = nxt_cpymem(b->mem.free, in->mem.pos, size); in nxt_h1p_request_body_read()
960 in->mem.pos += size; in nxt_h1p_request_body_read()
980 b->mem.start = NULL; in nxt_h1p_request_body_read()
981 b->mem.end = NULL; in nxt_h1p_request_body_read()
982 b->mem.pos = NULL; in nxt_h1p_request_body_read()
983 b->mem.free = NULL; in nxt_h1p_request_body_read()
1039 size = nxt_buf_mem_used_size(&b->mem); in nxt_h1p_conn_request_body_read()
1042 res = nxt_fd_write(b->file->fd, b->mem.pos, size); in nxt_h1p_conn_request_body_read()
1051 b->mem.pos += size; in nxt_h1p_conn_request_body_read()
1053 if (b->mem.pos == b->mem.free) { in nxt_h1p_conn_request_body_read()
1054 if (body_rest >= (size_t) nxt_buf_mem_size(&b->mem)) { in nxt_h1p_conn_request_body_read()
1055 b->mem.free = b->mem.start; in nxt_h1p_conn_request_body_read()
1059 b->mem.free = b->mem.end - body_rest; in nxt_h1p_conn_request_body_read()
1062 b->mem.pos = b->mem.free; in nxt_h1p_conn_request_body_read()
1066 body_rest = nxt_buf_mem_free_size(&c->read->mem); in nxt_h1p_conn_request_body_read()
1076 b->mem.start = NULL; in nxt_h1p_conn_request_body_read()
1077 b->mem.end = NULL; in nxt_h1p_conn_request_body_read()
1078 b->mem.pos = NULL; in nxt_h1p_conn_request_body_read()
1079 b->mem.free = NULL; in nxt_h1p_conn_request_body_read()
1326 p = nxt_cpymem(header->mem.free, status->start, status->length); in nxt_h1p_request_header_send()
1362 header->mem.free = p; in nxt_h1p_request_header_send()
1364 h1p->header_size = nxt_buf_mem_used_size(&header->mem); in nxt_h1p_request_header_send()
1430 size = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_complete_buffers()
1517 nxt_memcpy(tail->mem.free, tail_chunk, sizeof(tail_chunk)); in nxt_h1p_chunk_create()
1518 tail->mem.free += nxt_length(tail_chunk); in nxt_h1p_chunk_create()
1537 header->mem.free = nxt_sprintf(header->mem.free, header->mem.end, in nxt_h1p_chunk_create()
1812 size = nxt_buf_mem_used_size(&in->mem); in nxt_h1p_keepalive()
1816 nxt_memmove(in->mem.start, in->mem.pos, size); in nxt_h1p_keepalive()
1818 in->mem.pos = in->mem.start; in nxt_h1p_keepalive()
1819 in->mem.free = in->mem.start + size; in nxt_h1p_keepalive()
1907 p = nxt_cpymem(out->mem.free, NXT_H1P_IDLE_TIMEOUT, in nxt_h1p_idle_response()
1912 out->mem.free = nxt_cpymem(p, "\r\n\r\n", 4); in nxt_h1p_idle_response()
2284 p = header->mem.free; in nxt_h1p_peer_header_send()
2304 header->mem.free = p; in nxt_h1p_peer_header_send()
2305 size = p - header->mem.pos; in nxt_h1p_peer_header_send()
2331 body->mem = r->body->mem; in nxt_h1p_peer_header_send()
2507 ret = nxt_h1p_peer_header_parse(peer, &b->mem); in nxt_h1p_peer_header_read_done()
2549 if (nxt_buf_mem_used_size(&b->mem) != 0) { in nxt_h1p_peer_header_read_done()
2558 if (nxt_buf_mem_free_size(&b->mem) != 0) { in nxt_h1p_peer_header_read_done()