Lines Matching refs:dest

698 static void chunkqueue_steal_partial_file_chunk(chunkqueue * const restrict dest, const chunk * con…  in chunkqueue_steal_partial_file_chunk()  argument
699 chunkqueue_append_file(dest, c->mem, c->offset, len); in chunkqueue_steal_partial_file_chunk()
700 chunkqueue_dup_file_chunk_fd(dest->last, c); in chunkqueue_steal_partial_file_chunk()
703 void chunkqueue_steal(chunkqueue * const restrict dest, chunkqueue * const restrict src, off_t len)… in chunkqueue_steal() argument
719 chunkqueue_append_chunk(dest, c); in chunkqueue_steal()
720 dest->bytes_in += clen; in chunkqueue_steal()
729 chunkqueue_append_mem(dest, c->mem->ptr + c->offset, len); in chunkqueue_steal()
733 chunkqueue_steal_partial_file_chunk(dest, c, len); in chunkqueue_steal()
848 static int chunkqueue_to_tempfiles(chunkqueue * const restrict dest, log_error_st * const restrict … in chunkqueue_to_tempfiles() argument
854 const off_t cqlen = chunkqueue_length(dest); in chunkqueue_to_tempfiles()
855 chunkqueue src = *dest; /*(copy struct)*/ in chunkqueue_to_tempfiles()
856 dest->first = dest->last = NULL; in chunkqueue_to_tempfiles()
857 dest->bytes_in -= cqlen; in chunkqueue_to_tempfiles()
858 if (0 == chunkqueue_steal_with_tempfiles(dest, &src, cqlen, errh)) 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() argument
868 chunk *dst_c = dest->first; in chunkqueue_append_mem_to_tempfile()
874 && 0 != chunkqueue_to_tempfiles(dest, errh)) { in chunkqueue_append_mem_to_tempfile()
884 dst_c = chunkqueue_get_append_tempfile(dest, errh); in chunkqueue_append_mem_to_tempfile()
900 dest->bytes_in += len; in chunkqueue_append_mem_to_tempfile()
905 dest->bytes_in += written; in chunkqueue_append_mem_to_tempfile()
910 } else if (!chunkqueue_append_tempfile_err(dest, errh, dst_c)) { 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() argument
928 chunk *ckpt = dest->first; in chunkqueue_append_cqmem_to_tempfile_partial()
931 dest->last = ckpt; in chunkqueue_append_cqmem_to_tempfile_partial()
932 dest->bytes_in -= wr; /*(avoid double count in dest cq)*/ in chunkqueue_append_cqmem_to_tempfile_partial()
933 dest->bytes_out -= wr; in chunkqueue_append_cqmem_to_tempfile_partial()
934 chunkqueue_mark_written(dest, wr);/*(remove MEM_CHUNK written to tempfile)*/ in chunkqueue_append_cqmem_to_tempfile_partial()
936 c->next = dest->first; /*(place tempfile at beginning of dest cq)*/ in chunkqueue_append_cqmem_to_tempfile_partial()
937 dest->first = c; in chunkqueue_append_cqmem_to_tempfile_partial()
938 return (0 == chunkqueue_to_tempfiles(dest, errh)) ? 0 : -1; 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() argument
951 for (c = dest->first; c && c->type == MEM_CHUNK; c = c->next) { in chunkqueue_append_cqmem_to_tempfile()
960 if (__builtin_expect( (c != NULL), 0) && dest->first->type == MEM_CHUNK) { in chunkqueue_append_cqmem_to_tempfile()
963 if (0 != chunkqueue_to_tempfiles(dest, errh)) in chunkqueue_append_cqmem_to_tempfile()
985 c = chunkqueue_get_append_tempfile(dest, errh); in chunkqueue_append_cqmem_to_tempfile()
1001 dest->bytes_in += wr; in chunkqueue_append_cqmem_to_tempfile()
1005 chunkqueue_append_cqmem_to_tempfile_partial(dest,c,wr,errh); in chunkqueue_append_cqmem_to_tempfile()
1007 dest->bytes_in -= dlen; /*(avoid double count in dest cq)*/ in chunkqueue_append_cqmem_to_tempfile()
1008 dest->bytes_out -= dlen; in chunkqueue_append_cqmem_to_tempfile()
1009 chunkqueue_mark_written(dest, dlen); in chunkqueue_append_cqmem_to_tempfile()
1012 else if (chunkqueue_append_tempfile_err(dest, errh, c)) in chunkqueue_append_cqmem_to_tempfile()
1168 int chunkqueue_steal_with_tempfiles(chunkqueue * const restrict dest, chunkqueue * const restrict s… in chunkqueue_steal_with_tempfiles() argument
1179 clen = chunkqueue_append_cqmem_to_tempfile(dest, src, len, errh); in chunkqueue_steal_with_tempfiles()
1186 chunkqueue_steal(dest, src, clen); in chunkqueue_steal_with_tempfiles()
1196 chunkqueue_steal(dest, src, clen); in chunkqueue_steal_with_tempfiles()
1202 && 0 != chunkqueue_append_mem_to_tempfile(dest, in chunkqueue_steal_with_tempfiles()