Lines Matching refs:chunkqueue

21 chunkqueue *chunkqueue_init(void) {  in chunkqueue_init()
22 chunkqueue *cq; in chunkqueue_init()
79 void chunkqueue_free(chunkqueue *cq) { in chunkqueue_free()
99 static chunk *chunkqueue_get_unused_chunk(chunkqueue *cq) { in chunkqueue_get_unused_chunk()
116 static int chunkqueue_prepend_chunk(chunkqueue *cq, chunk *c) { in chunkqueue_prepend_chunk()
127 static int chunkqueue_append_chunk(chunkqueue *cq, chunk *c) { in chunkqueue_append_chunk()
140 void chunkqueue_reset(chunkqueue *cq) { in chunkqueue_reset()
163 int chunkqueue_append_file(chunkqueue *cq, buffer *fn, off_t offset, off_t len) { in chunkqueue_append_file()
182 int chunkqueue_append_buffer(chunkqueue *cq, buffer *mem) { in chunkqueue_append_buffer()
197 int chunkqueue_append_buffer_weak(chunkqueue *cq, buffer *mem) { in chunkqueue_append_buffer_weak()
211 int chunkqueue_prepend_buffer(chunkqueue *cq, buffer *mem) { in chunkqueue_prepend_buffer()
227 int chunkqueue_append_mem(chunkqueue *cq, const char * mem, size_t len) { in chunkqueue_append_mem()
242 buffer * chunkqueue_get_prepend_buffer(chunkqueue *cq) { in chunkqueue_get_prepend_buffer()
256 buffer *chunkqueue_get_append_buffer(chunkqueue *cq) { in chunkqueue_get_append_buffer()
270 int chunkqueue_set_tempdirs(chunkqueue *cq, array *tempdirs) { in chunkqueue_set_tempdirs()
278 chunk *chunkqueue_get_append_tempfile(chunkqueue *cq) { in chunkqueue_get_append_tempfile()
323 off_t chunkqueue_length(chunkqueue *cq) { in chunkqueue_length()
343 off_t chunkqueue_written(chunkqueue *cq) { in chunkqueue_written()
361 int chunkqueue_is_empty(chunkqueue *cq) { in chunkqueue_is_empty()
365 int chunkqueue_remove_finished_chunks(chunkqueue *cq) { in chunkqueue_remove_finished_chunks()