Lines Matching refs:chunkqueue

93 chunkqueue *chunkqueue_init(chunkqueue *cq) {  in chunkqueue_init()
438 static void chunkqueue_release_chunks(chunkqueue *cq) { in chunkqueue_release_chunks()
446 void chunkqueue_free(chunkqueue *cq) { in chunkqueue_free()
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()
471 static chunk * chunkqueue_append_mem_chunk(chunkqueue *cq, size_t sz) { in chunkqueue_append_mem_chunk()
479 static chunk * chunkqueue_append_file_chunk(chunkqueue * const restrict cq, const buffer * const re… in __attribute_nonnull__()
490 void chunkqueue_reset(chunkqueue *cq) { in chunkqueue_reset()
497 void chunkqueue_append_file_fd(chunkqueue * const restrict cq, const buffer * const restrict fn, in… in chunkqueue_append_file_fd()
506 void chunkqueue_append_file(chunkqueue * const restrict cq, const buffer * const restrict fn, off_t… in chunkqueue_append_file()
513 static int chunkqueue_append_mem_extend_chunk(chunkqueue * const restrict cq, const char * const re… in chunkqueue_append_mem_extend_chunk()
526 void chunkqueue_append_buffer(chunkqueue * const restrict cq, buffer * const restrict 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()
551 void chunkqueue_append_mem_min(chunkqueue * const restrict cq, const char * const restrict mem, siz… in chunkqueue_append_mem_min()
563 void chunkqueue_append_chunkqueue(chunkqueue * const restrict cq, chunkqueue * const restrict src) { in chunkqueue_append_chunkqueue()
580 buffer * chunkqueue_prepend_buffer_open_sz(chunkqueue *cq, size_t sz) { in chunkqueue_prepend_buffer_open_sz()
586 buffer * chunkqueue_prepend_buffer_open(chunkqueue *cq) { in chunkqueue_prepend_buffer_open()
591 void chunkqueue_prepend_buffer_commit(chunkqueue *cq) { in chunkqueue_prepend_buffer_commit()
596 buffer * chunkqueue_append_buffer_open_sz(chunkqueue *cq, size_t sz) { in chunkqueue_append_buffer_open_sz()
602 buffer * chunkqueue_append_buffer_open(chunkqueue *cq) { in chunkqueue_append_buffer_open()
607 void chunkqueue_append_buffer_commit(chunkqueue *cq) { in chunkqueue_append_buffer_commit()
612 char * chunkqueue_get_memory(chunkqueue * const restrict cq, size_t * const restrict len) { 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()
668 void chunkqueue_set_tempdirs(chunkqueue * const restrict cq, const array * const restrict tempdirs,… in chunkqueue_set_tempdirs()
698 static void chunkqueue_steal_partial_file_chunk(chunkqueue * const restrict dest, const chunk * con… in chunkqueue_steal_partial_file_chunk()
703 void chunkqueue_steal(chunkqueue * const restrict dest, chunkqueue * const restrict src, off_t len)… in chunkqueue_steal()
755 static chunk *chunkqueue_get_append_newtempfile(chunkqueue * const restrict cq, log_error_st * cons… 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()
819 static int chunkqueue_append_tempfile_err(chunkqueue * const cq, log_error_st * const restrict errh… in chunkqueue_append_tempfile_err()
848 static int chunkqueue_to_tempfiles(chunkqueue * const restrict dest, log_error_st * const restrict … in chunkqueue_to_tempfiles()
855 chunkqueue src = *dest; /*(copy struct)*/ in chunkqueue_to_tempfiles()
867 int chunkqueue_append_mem_to_tempfile(chunkqueue * const restrict dest, const char * restrict mem, … 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()
941 static ssize_t chunkqueue_append_cqmem_to_tempfile(chunkqueue * const restrict dest, chunkqueue * c… in chunkqueue_append_cqmem_to_tempfile()
1024 static ssize_t chunkqueue_append_drain_pipe_tempfile(chunkqueue * const restrict cq, const int fd, … in chunkqueue_append_drain_pipe_tempfile()
1053 ssize_t chunkqueue_append_splice_pipe_tempfile(chunkqueue * const restrict cq, const int fd, unsign… in chunkqueue_append_splice_pipe_tempfile()
1146 ssize_t chunkqueue_append_splice_sock_tempfile(chunkqueue * const restrict cq, const int fd, unsign… in chunkqueue_append_splice_sock_tempfile()
1168 int chunkqueue_steal_with_tempfiles(chunkqueue * const restrict dest, chunkqueue * const restrict s… in chunkqueue_steal_with_tempfiles()
1216 void chunkqueue_append_cq_range (chunkqueue * const dst, const chunkqueue * const src, off_t offset… in chunkqueue_append_cq_range()
1245 void chunkqueue_mark_written(chunkqueue *cq, off_t len) { in chunkqueue_mark_written()
1265 void chunkqueue_remove_finished_chunks(chunkqueue *cq) { in chunkqueue_remove_finished_chunks()
1272 void chunkqueue_remove_empty_chunks(chunkqueue *cq) { in chunkqueue_remove_empty_chunks()
1286 void chunkqueue_compact_mem_offset(chunkqueue * const cq) { in chunkqueue_compact_mem_offset()
1298 void chunkqueue_compact_mem(chunkqueue *cq, size_t clen) { in chunkqueue_compact_mem()
1361 int chunkqueue_open_file_chunk(chunkqueue * const restrict cq, log_error_st * const restrict errh) { in chunkqueue_open_file_chunk()
1387 chunkqueue cq = {c,c,0,0,0,0,0}; /*(fake cq for chunkqueue_peek_data())*/ in chunkqueue_write_chunk_file_intermed()
1447 chunkqueue_write_chunk (const int fd, chunkqueue * const restrict cq, log_error_st * const restrict… in chunkqueue_write_chunk()
1464 chunkqueue_write_chunk_to_pipe (const int fd, chunkqueue * const restrict cq, log_error_st * const … in chunkqueue_write_chunk_to_pipe()
1482 chunkqueue_small_resp_optim (chunkqueue * const restrict cq) in chunkqueue_small_resp_optim()
1552 chunkqueue_peek_data (chunkqueue * const cq, in chunkqueue_peek_data()
1660 chunkqueue_read_data (chunkqueue * const cq, in chunkqueue_read_data()
1675 chunkqueue_read_squash (chunkqueue * const restrict cq, log_error_st * const restrict errh) in chunkqueue_read_squash()