Lines Matching refs:chunkqueue

46 typedef struct chunkqueue {  struct
55 } chunkqueue;  typedef
73 chunkqueue *chunkqueue_init(chunkqueue *cq);
84 void chunkqueue_set_tempdirs(chunkqueue * restrict cq, const array * restrict tempdirs, off_t uploa…
86 void chunkqueue_append_file(chunkqueue * restrict cq, const buffer * restrict fn, off_t offset, off…
87 void chunkqueue_append_file_fd(chunkqueue * restrict cq, const buffer * restrict fn, int fd, off_t …
88 void chunkqueue_append_mem(chunkqueue * restrict cq, const char * restrict mem, size_t len); /* cop…
89 void chunkqueue_append_mem_min(chunkqueue * restrict cq, const char * restrict mem, size_t len); /*…
92 void chunkqueue_append_buffer(chunkqueue * restrict cq, buffer * restrict mem); /* may reset "mem" …
95 void chunkqueue_append_chunkqueue(chunkqueue * restrict cq, chunkqueue * restrict src);
98 buffer * chunkqueue_prepend_buffer_open_sz(chunkqueue *cq, size_t sz);
101 buffer * chunkqueue_prepend_buffer_open(chunkqueue *cq);
103 void chunkqueue_prepend_buffer_commit(chunkqueue *cq);
106 buffer * chunkqueue_append_buffer_open_sz(chunkqueue *cq, size_t sz);
109 buffer * chunkqueue_append_buffer_open(chunkqueue *cq);
111 void chunkqueue_append_buffer_commit(chunkqueue *cq);
113 int chunkqueue_append_mem_to_tempfile(chunkqueue * restrict cq, const char * restrict mem, size_t l…
116 ssize_t chunkqueue_append_splice_pipe_tempfile(chunkqueue * restrict cq, int fd, unsigned int len, …
117 ssize_t chunkqueue_append_splice_sock_tempfile(chunkqueue * restrict cq, int fd, unsigned int len, …
133 char * chunkqueue_get_memory(chunkqueue * restrict cq, size_t * restrict len);
135 void chunkqueue_use_memory(chunkqueue * restrict cq, chunk *ckpt, size_t len);
136 void chunkqueue_update_file(chunkqueue * restrict cq, chunk *c, off_t len);
141 void chunkqueue_mark_written(chunkqueue *cq, off_t len);
143 void chunkqueue_remove_finished_chunks(chunkqueue *cq);
146 void chunkqueue_remove_empty_chunks(chunkqueue *cq);
148 void chunkqueue_steal(chunkqueue * restrict dest, chunkqueue * restrict src, off_t len);
149 int chunkqueue_steal_with_tempfiles(chunkqueue * restrict dest, chunkqueue * restrict src, off_t le…
150 void chunkqueue_append_cq_range (chunkqueue *dst, const chunkqueue *src, off_t offset, off_t len);
152 int chunkqueue_open_file_chunk(chunkqueue * restrict cq, log_error_st * const restrict errh);
154 void chunkqueue_compact_mem_offset(chunkqueue *cq);
155 void chunkqueue_compact_mem(chunkqueue *cq, size_t clen);
157 void chunkqueue_small_resp_optim (chunkqueue * restrict cq);
159 ssize_t chunkqueue_write_chunk (int fd, chunkqueue * restrict cq, log_error_st * restrict errh);
160 ssize_t chunkqueue_write_chunk_to_pipe (int fd, chunkqueue * restrict cq, log_error_st * restrict e…
162 int chunkqueue_peek_data (chunkqueue *cq, char **data, uint32_t *dlen, log_error_st * restrict errh…
163 int chunkqueue_read_data (chunkqueue *cq, char *data, uint32_t dlen, log_error_st * restrict errh);
165 buffer * chunkqueue_read_squash (chunkqueue * restrict cq, log_error_st * restrict errh);
169 static inline off_t chunkqueue_length(const chunkqueue *cq);
170 static inline off_t chunkqueue_length(const chunkqueue *cq) {  in chunkqueue_length()
175 void chunkqueue_free(chunkqueue *cq);
177 void chunkqueue_reset(chunkqueue *cq);
181 static inline int chunkqueue_is_empty(const chunkqueue *cq);
182 static inline int chunkqueue_is_empty(const chunkqueue *cq) {  in chunkqueue_is_empty()