Lines Matching refs:offset
56 #define mmap_align_offset(offset) ((offset) & chunk_pagemask) argument
116 c->offset = 0; in chunk_init()
170 chunk_file_pread (int fd, void *buf, size_t count, off_t offset) in chunk_file_pread() argument
178 if (-1 == lseek(fd, offset, SEEK_SET)) in chunk_file_pread()
185 rd =pread(fd, buf, count, offset); in chunk_file_pread()
220 c->offset = 0; in chunk_reset()
435 - c->offset; in chunk_remaining_length()
479 …_chunk(chunkqueue * const restrict cq, const buffer * const restrict fn, off_t offset, off_t len) { in __attribute_nonnull__()
483 c->offset = offset; in __attribute_nonnull__()
484 c->file.length = offset + len; in __attribute_nonnull__()
497 …hunkqueue * const restrict cq, const buffer * const restrict fn, int fd, off_t offset, off_t len) { in chunkqueue_append_file_fd() argument
499 (chunkqueue_append_file_chunk(cq, fn, offset, len))->file.fd = fd; in chunkqueue_append_file_fd()
506 …d_file(chunkqueue * const restrict cq, const buffer * const restrict fn, off_t offset, off_t len) { in chunkqueue_append_file() argument
508 chunkqueue_append_file_chunk(cq, fn, offset, len); in chunkqueue_append_file()
699 chunkqueue_append_file(dest, c->mem, c->offset, len); in chunkqueue_steal_partial_file_chunk()
729 chunkqueue_append_mem(dest, c->mem->ptr + c->offset, len); in chunkqueue_steal()
737 c->offset += len; in chunkqueue_steal()
953 iov[iovcnt].iov_base = c->mem->ptr + c->offset; in chunkqueue_append_cqmem_to_tempfile()
973 iov[iovcnt].iov_base = c->mem->ptr + c->offset; in chunkqueue_append_cqmem_to_tempfile()
1203 c->mem->ptr+c->offset, 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() argument
1224 if (offset >= clen) { in chunkqueue_append_cq_range()
1225 offset -= clen; in chunkqueue_append_cq_range()
1228 clen -= offset; in chunkqueue_append_cq_range()
1233 chunkqueue_append_file(dst, c->mem, c->offset + offset, clen); in chunkqueue_append_cq_range()
1239 chunkqueue_append_mem(dst, c->mem->ptr + c->offset + offset, clen); in chunkqueue_append_cq_range()
1241 offset = 0; in chunkqueue_append_cq_range()
1257 c->offset += len; in chunkqueue_mark_written()
1288 if (0 == c->offset) return; in chunkqueue_compact_mem_offset()
1292 size_t len = buffer_clen(b) - c->offset; in chunkqueue_compact_mem_offset()
1293 memmove(b->ptr, b->ptr+c->offset, len); in chunkqueue_compact_mem_offset()
1294 c->offset = 0; in chunkqueue_compact_mem_offset()
1303 size_t len = buffer_clen(b) - c->offset; in chunkqueue_compact_mem()
1311 buffer_append_string_len(b, c->mem->ptr + c->offset, len); in chunkqueue_compact_mem()
1319 len = buffer_clen(c->mem) - c->offset; in chunkqueue_compact_mem()
1321 buffer_append_string_len(b, c->mem->ptr + c->offset, clen); in chunkqueue_compact_mem()
1322 c->offset += clen; in chunkqueue_compact_mem()
1325 buffer_append_string_len(b, c->mem->ptr + c->offset, len); in chunkqueue_compact_mem()
1385 const off_t len = c->file.length - c->offset; in chunkqueue_write_chunk_file_intermed()
1409 const off_t len = c->file.length - c->offset; in chunkqueue_write_chunk_file()
1416 off_t offset = c->offset; in chunkqueue_write_chunk_file() local
1418 sendfile(fd, c->file.fd, &offset, len < INT32_MAX ? len : INT32_MAX); in chunkqueue_write_chunk_file()
1427 const off_t mmap_avail = chunk_file_view_dlen(cfv, c->offset); in chunkqueue_write_chunk_file()
1428 return chunkqueue_write_data(fd, chunk_file_view_dptr(cfv, c->offset), in chunkqueue_write_chunk_file()
1440 const void * const buf = c->mem->ptr + c->offset; in chunkqueue_write_chunk_mem()
1441 const size_t len = buffer_clen(c->mem) - (size_t)c->offset; in chunkqueue_write_chunk_mem()
1469 const size_t len = (size_t)(c->file.length - c->offset); in chunkqueue_write_chunk_to_pipe()
1470 loff_t abs_offset = c->offset; in chunkqueue_write_chunk_to_pipe()
1504 off_t len = filec->file.length - filec->offset; in chunkqueue_small_resp_optim()
1515 off_t offset = 0; in chunkqueue_small_resp_optim() local
1518 rd = chunk_file_pread(filec->file.fd, ptr+offset, (size_t)len, in chunkqueue_small_resp_optim()
1519 filec->offset+offset); in chunkqueue_small_resp_optim()
1520 } while (rd > 0 && (offset += rd, len -= rd)); in chunkqueue_small_resp_optim()
1525 buffer_truncate(c->mem, (uint32_t)(ptr + offset - c->mem->ptr)); in chunkqueue_small_resp_optim()
1527 if (offset) in chunkqueue_small_resp_optim()
1528 filec->offset += offset; in chunkqueue_small_resp_optim()
1565 uint32_t have = buffer_clen(c->mem) - (uint32_t)c->offset; in chunkqueue_peek_data()
1571 memcpy(data_in + *dlen, c->mem->ptr + c->offset, have); in chunkqueue_peek_data()
1573 *data = c->mem->ptr + c->offset; /*(reference; defer copy)*/ in chunkqueue_peek_data()
1580 off_t len = c->file.length - c->offset; in chunkqueue_peek_data()
1604 if (cfv && chunk_file_view_dlen(cfv, c->offset) >= len) { in chunkqueue_peek_data()
1606 char * const mdata = chunk_file_view_dptr(cfv, c->offset); in chunkqueue_peek_data()
1626 (size_t)len, c->offset); in chunkqueue_peek_data()
1723 cfv->foff = mmap_align_offset(c->offset); in chunkqueue_chunk_file_viewadj()
1726 cfv->mlen = c->offset - cfv->foff + n; in chunkqueue_chunk_file_viewadj()