Lines Matching refs:mem

123 	c->mem = buffer_init();  in chunk_init()
131 buffer_string_prepare_copy(c->mem, sz-1); in chunk_init_sz()
196 if (!buffer_is_blank(c->mem)) in chunk_reset_file_chunk()
197 unlink(c->mem->ptr); in chunk_reset_file_chunk()
219 buffer_clear(c->mem); in chunk_reset()
225 buffer_free(c->mem); in chunk_free()
231 if (chunks_oversized && chunks_oversized->mem->size >= sz) { in chunk_pop_oversized()
245 while (*co && sz < (*co)->mem->size) co = &(*co)->next; in chunk_push_oversized()
250 buffer * const tb = chunks_oversized ? chunks_oversized->mem : NULL; in chunk_push_oversized()
253 chunks_oversized->mem = c->mem; in chunk_push_oversized()
254 c->mem = tb; in chunk_push_oversized()
286 b = c->mem; in chunk_buffer_acquire_sz()
287 c->mem = NULL; in chunk_buffer_acquire_sz()
300 c->mem = b; in chunk_buffer_release()
364 const size_t sz = c->mem->size; in chunk_release()
422 c->mem = buffer_init(); /*(chunk_reset() expects c->mem != NULL)*/ in chunkqueue_chunk_pool_free()
433 ? (off_t)buffer_clen(c->mem) in chunk_remaining_length()
486 buffer_copy_buffer(c->mem, fn); in __attribute_nonnull__()
513 …end_mem_extend_chunk(chunkqueue * const restrict cq, const char * const restrict mem, size_t len) { in chunkqueue_append_mem_extend_chunk() argument
517 && buffer_string_space(c->mem) >= len) { in chunkqueue_append_mem_extend_chunk()
518 buffer_append_string_len(c->mem, mem, len); in chunkqueue_append_mem_extend_chunk()
526 void chunkqueue_append_buffer(chunkqueue * const restrict cq, buffer * const restrict mem) { in chunkqueue_append_buffer() argument
528 const size_t len = buffer_clen(mem); in chunkqueue_append_buffer()
529 if (len < 1024 && chunkqueue_append_mem_extend_chunk(cq, mem->ptr, len)) { in chunkqueue_append_buffer()
530 buffer_clear(mem); in chunkqueue_append_buffer()
536 buffer_move(c->mem, mem); in chunkqueue_append_buffer()
540 void chunkqueue_append_mem(chunkqueue * const restrict cq, const char * const restrict mem, size_t … in chunkqueue_append_mem() argument
542 if (len < chunk_buf_sz && chunkqueue_append_mem_extend_chunk(cq, mem, len)) in chunkqueue_append_mem()
547 buffer_copy_string_len(c->mem, mem, len); in chunkqueue_append_mem()
551 void chunkqueue_append_mem_min(chunkqueue * const restrict cq, const char * const restrict mem, siz… in chunkqueue_append_mem_min() argument
553 if (len < chunk_buf_sz && chunkqueue_append_mem_extend_chunk(cq, mem, len)) in chunkqueue_append_mem_min()
559 buffer_copy_string_len(c->mem, mem, len); in chunkqueue_append_mem_min()
582 return c->mem; in chunkqueue_prepend_buffer_open_sz()
592 cq->bytes_in += buffer_clen(cq->first->mem); in chunkqueue_prepend_buffer_commit()
598 return c->mem; in chunkqueue_append_buffer_open_sz()
608 cq->bytes_in += buffer_clen(cq->last->mem); in chunkqueue_append_buffer_commit()
618 size_t avail = buffer_string_space(c->mem); in chunkqueue_get_memory()
621 b = c->mem; in chunkqueue_get_memory()
633 buffer *b = cq->last->mem; in chunkqueue_use_memory()
639 || len > buffer_string_space(ckpt->mem)) return; in chunkqueue_use_memory()
641 buffer_append_string_buffer(ckpt->mem, b); in chunkqueue_use_memory()
699 chunkqueue_append_file(dest, c->mem, c->offset, len); in chunkqueue_steal_partial_file_chunk()
729 chunkqueue_append_mem(dest, c->mem->ptr + c->offset, len); in chunkqueue_steal()
759 buffer * const restrict template = c->mem; in chunkqueue_get_append_newtempfile()
811 "close() temp-file %s failed", c->mem->ptr); in chunkqueue_get_append_tempfile()
827 "write() temp-file %s failed", c->mem->ptr); in chunkqueue_append_tempfile_err()
839 "close() temp-file %s failed", c->mem->ptr); in chunkqueue_append_tempfile_err()
867 int chunkqueue_append_mem_to_tempfile(chunkqueue * const restrict dest, const char * restrict mem, … in chunkqueue_append_mem_to_tempfile() argument
892 const ssize_t written =pwrite(dst_c->file.fd, mem, len, dst_c->file.length); in chunkqueue_append_mem_to_tempfile()
895 const ssize_t written = write(dst_c->file.fd, mem, len); in chunkqueue_append_mem_to_tempfile()
906 mem += written; in chunkqueue_append_mem_to_tempfile()
953 iov[iovcnt].iov_base = c->mem->ptr + c->offset; in chunkqueue_append_cqmem_to_tempfile()
973 iov[iovcnt].iov_base = c->mem->ptr + c->offset; in chunkqueue_append_cqmem_to_tempfile()
1203 c->mem->ptr+c->offset, in chunkqueue_steal_with_tempfiles()
1233 chunkqueue_append_file(dst, c->mem, c->offset + offset, clen); in chunkqueue_append_cq_range()
1239 chunkqueue_append_mem(dst, c->mem->ptr + c->offset + offset, clen); in chunkqueue_append_cq_range()
1291 buffer * const restrict b = c->mem; in chunkqueue_compact_mem_offset()
1302 buffer *b = c->mem; in chunkqueue_compact_mem()
1311 buffer_append_string_len(b, c->mem->ptr + c->offset, len); in chunkqueue_compact_mem()
1319 len = buffer_clen(c->mem) - c->offset; in chunkqueue_compact_mem()
1321 buffer_append_string_len(b, c->mem->ptr + c->offset, clen); in chunkqueue_compact_mem()
1325 buffer_append_string_len(b, c->mem->ptr + c->offset, len); in chunkqueue_compact_mem()
1337 if (-1 == (c->file.fd = fdevent_open_cloexec(c->mem->ptr, 1, O_RDONLY, 0))) { in chunk_open_file_chunk()
1338 log_perror(errh, __FILE__, __LINE__, "open failed: %s",c->mem->ptr); in chunk_open_file_chunk()
1354 log_error(errh, __FILE__, __LINE__, "file shrunk: %s", c->mem->ptr); in chunk_open_file_chunk()
1440 const void * const buf = c->mem->ptr + c->offset; in chunkqueue_write_chunk_mem()
1441 const size_t len = buffer_clen(c->mem) - (size_t)c->offset; in chunkqueue_write_chunk_mem()
1505 if ((size_t)len > buffer_string_space(c->mem)) { in chunkqueue_small_resp_optim()
1516 char * const ptr = buffer_extend(c->mem, len); in chunkqueue_small_resp_optim()
1525 buffer_truncate(c->mem, (uint32_t)(ptr + offset - c->mem->ptr)); in chunkqueue_small_resp_optim()
1565 uint32_t have = buffer_clen(c->mem) - (uint32_t)c->offset; in chunkqueue_peek_data()
1571 memcpy(data_in + *dlen, c->mem->ptr + c->offset, have); in chunkqueue_peek_data()
1573 *data = c->mem->ptr + c->offset; /*(reference; defer copy)*/ in chunkqueue_peek_data()
1611 "SIGBUS in mmap: %s %d", c->mem->ptr, c->file.fd); in chunkqueue_peek_data()
1629 c->mem->ptr); in chunkqueue_peek_data()
1684 return cq->first->mem; in chunkqueue_read_squash()
1687 char *data = c->mem->ptr; in chunkqueue_read_squash()
1694 buffer_truncate(c->mem, dlen); in chunkqueue_read_squash()
1698 return c->mem; in chunkqueue_read_squash()