Lines Matching refs:chunk
67 static chunk *chunks, *chunks_oversized, *chunks_filechunk;
68 static chunk *chunk_buffers;
110 static chunk *chunk_init(void) { in chunk_init()
111 chunk * const restrict c = ck_calloc(1, sizeof(*c)); in chunk_init()
129 static chunk *chunk_init_sz(size_t sz) { in chunk_init_sz()
130 chunk * const restrict c = chunk_init(); in chunk_init_sz()
193 static void chunk_reset_file_chunk(chunk *c) { in chunk_reset_file_chunk()
216 static void chunk_reset(chunk *c) { in chunk_reset()
223 static void chunk_free(chunk *c) { in chunk_free()
229 static chunk * chunk_pop_oversized(size_t sz) { in chunk_pop_oversized()
233 chunk *c = chunks_oversized; in chunk_pop_oversized()
240 static void chunk_push_oversized(chunk * const c, const size_t sz) { in chunk_push_oversized()
244 chunk **co = &chunks_oversized; in chunk_push_oversized()
263 chunk *c; in chunk_buffer_acquire_sz()
298 chunk *c = chunk_buffers; in chunk_buffer_release()
344 static chunk * chunk_acquire(size_t sz) { in chunk_acquire()
347 chunk *c = chunks; in chunk_acquire()
356 chunk *c = chunk_pop_oversized(sz); in chunk_acquire()
363 static void chunk_release(chunk *c) { in chunk_release()
385 static chunk * chunk_acquire_filechunk(void) { in chunk_acquire_filechunk()
387 chunk *c = chunks_filechunk; in chunk_acquire_filechunk()
396 for (chunk *next, *c = chunks; c; c = next) { in chunkqueue_chunk_pool_clear()
401 for (chunk *next, *c = chunks_oversized; c; c = next) { in chunkqueue_chunk_pool_clear()
407 for (chunk *next, *c = chunks_filechunk; c; c = next) { in chunkqueue_chunk_pool_clear()
417 for (chunk *next, *c = chunk_buffers; c; c = next) { in chunkqueue_chunk_pool_free()
430 static off_t chunk_remaining_length(const chunk *c) { in chunk_remaining_length()
440 for (chunk *c; (c = cq->first); ) { in chunkqueue_release_chunks()
452 static void chunkqueue_prepend_chunk(chunkqueue * const restrict cq, chunk * const restrict c) { in chunkqueue_prepend_chunk()
457 static void chunkqueue_append_chunk(chunkqueue * const restrict cq, chunk * const restrict c) { in chunkqueue_append_chunk()
464 static chunk * chunkqueue_prepend_mem_chunk(chunkqueue *cq, size_t sz) { in chunkqueue_prepend_mem_chunk()
465 chunk *c = chunk_acquire(sz); in chunkqueue_prepend_mem_chunk()
471 static chunk * chunkqueue_append_mem_chunk(chunkqueue *cq, size_t sz) { in chunkqueue_append_mem_chunk()
472 chunk *c = chunk_acquire(sz); in chunkqueue_append_mem_chunk()
479 static chunk * chunkqueue_append_file_chunk(chunkqueue * const restrict cq, const buffer * const re… in __attribute_nonnull__()
480 chunk * const c = chunk_acquire_filechunk(); in __attribute_nonnull__()
514 chunk *c = cq->last; in chunkqueue_append_mem_extend_chunk()
527 chunk *c; in chunkqueue_append_buffer()
541 chunk *c; in chunkqueue_append_mem()
552 chunk *c; in chunkqueue_append_mem_min()
581 chunk * const c = chunkqueue_prepend_mem_chunk(cq, sz); in chunkqueue_prepend_buffer_open_sz()
597 chunk * const c = chunkqueue_append_mem_chunk(cq, sz); in chunkqueue_append_buffer_open_sz()
615 chunk *c = cq->last; in chunkqueue_get_memory()
632 void chunkqueue_use_memory(chunkqueue * const restrict cq, chunk *ckpt, size_t len) { in chunkqueue_use_memory()
653 void chunkqueue_update_file(chunkqueue * const restrict cq, chunk *c, off_t len) { in chunkqueue_update_file()
677 static void chunkqueue_dup_file_chunk_fd (chunk * const restrict d, const chunk * const restrict c)… in chunkqueue_dup_file_chunk_fd()
698 static void chunkqueue_steal_partial_file_chunk(chunkqueue * const restrict dest, const chunk * con… in chunkqueue_steal_partial_file_chunk()
708 chunk * const c = src->first; in chunkqueue_steal()
755 static chunk *chunkqueue_get_append_newtempfile(chunkqueue * const restrict cq, log_error_st * cons… in chunkqueue_get_append_newtempfile()
757 chunk * const restrict last = cq->last; in chunkqueue_get_append_newtempfile()
758 chunk * const restrict c = chunkqueue_append_file_chunk(cq, &emptyb, 0, 0); in chunkqueue_get_append_newtempfile()
790 static chunk *chunkqueue_get_append_tempfile(chunkqueue * const restrict cq, log_error_st * const r… in chunkqueue_get_append_tempfile()
799 chunk * const c = cq->last; in chunkqueue_get_append_tempfile()
819 …e_append_tempfile_err(chunkqueue * const cq, log_error_st * const restrict errh, chunk * const c) { in chunkqueue_append_tempfile_err()
868 chunk *dst_c = dest->first; in chunkqueue_append_mem_to_tempfile()
926 static ssize_t chunkqueue_append_cqmem_to_tempfile_partial(chunkqueue * const dest, chunk * const c… in chunkqueue_append_cqmem_to_tempfile_partial()
928 chunk *ckpt = dest->first; in chunkqueue_append_cqmem_to_tempfile_partial()
950 chunk *c; in chunkqueue_append_cqmem_to_tempfile()
1065 chunk * const c = chunkqueue_get_append_tempfile(cq, errh); in chunkqueue_append_splice_pipe_tempfile()
1173 chunk * const c = src->first; in chunkqueue_steal_with_tempfiles()
1221 for (const chunk *c = src->first; len > 0 && c != NULL; c = c->next) { in chunkqueue_append_cq_range()
1248 for (chunk *c = cq->first; c; ) { in chunkqueue_mark_written()
1251 chunk * const x = c; in chunkqueue_mark_written()
1266 for (chunk *c; (c = cq->first) && 0 == chunk_remaining_length(c); ){ in chunkqueue_remove_finished_chunks()
1273 chunk *c; in chunkqueue_remove_empty_chunks()
1278 chunk *empty = c->next; in chunkqueue_remove_empty_chunks()
1287 chunk * const restrict c = cq->first; in chunkqueue_compact_mem_offset()
1301 chunk *c = cq->first; in chunkqueue_compact_mem()
1318 for (chunk *fc = c; ((clen -= len) && (c = fc->next)); ) { in chunkqueue_compact_mem()
1334 static int chunk_open_file_chunk(chunk * const restrict c, log_error_st * const restrict errh) { in chunk_open_file_chunk()
1381 chunkqueue_write_chunk_file_intermed (const int fd, chunk * const restrict c, log_error_st * const … in chunkqueue_write_chunk_file_intermed()
1401 chunkqueue_write_chunk_file (const int fd, chunk * const restrict c, log_error_st * const errh) in chunkqueue_write_chunk_file()
1438 chunkqueue_write_chunk_mem (const int fd, const chunk * const restrict c) in chunkqueue_write_chunk_mem()
1450 chunk * const c = cq->first; in chunkqueue_write_chunk()
1467 chunk * const c = cq->first; in chunkqueue_write_chunk_to_pipe()
1496 chunk * restrict c = cq->first; in chunkqueue_small_resp_optim()
1497 chunk * const restrict filec = c->next; /*(require file already be open)*/ in chunkqueue_small_resp_optim()
1560 for (chunk *c = cq->first; c; ) { in chunkqueue_peek_data()
1686 chunk * const c = chunk_acquire((uint32_t)cqlen+1); in chunkqueue_read_squash()
1705 chunkqueue_chunk_file_viewadj (chunk * const c, off_t n, log_error_st * restrict errh) in chunkqueue_chunk_file_viewadj()