Lines Matching refs:dlen
949 off_t dlen = 0; in chunkqueue_append_cqmem_to_tempfile() local
955 dlen += clen; in chunkqueue_append_cqmem_to_tempfile()
965 dlen = 0; in chunkqueue_append_cqmem_to_tempfile()
1002 if (dlen) { in chunkqueue_append_cqmem_to_tempfile()
1003 if (__builtin_expect( (wr < dlen), 0)) in chunkqueue_append_cqmem_to_tempfile()
1006 wr -= (ssize_t)dlen; 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()
1386 uint32_t dlen = len < (off_t)sizeof(buf) ? (uint32_t)len : sizeof(buf); in chunkqueue_write_chunk_file_intermed() local
1388 if (0 != chunkqueue_peek_data(&cq, &data, &dlen, errh) && 0 == dlen) in chunkqueue_write_chunk_file_intermed()
1390 return chunkqueue_write_data(fd, data, dlen); in chunkqueue_write_chunk_file_intermed()
1553 char ** const data, uint32_t * const dlen, in chunkqueue_peek_data() argument
1557 const uint32_t data_insz = *dlen; in chunkqueue_peek_data()
1558 *dlen = 0; in chunkqueue_peek_data()
1561 uint32_t space = data_insz - *dlen; in chunkqueue_peek_data()
1570 if (*dlen) in chunkqueue_peek_data()
1571 memcpy(data_in + *dlen, c->mem->ptr + c->offset, have); in chunkqueue_peek_data()
1574 *dlen += have; in chunkqueue_peek_data()
1609 data_in+*dlen, mdata, len) < 0) { in chunkqueue_peek_data()
1615 else if (*dlen) in chunkqueue_peek_data()
1616 memcpy(data_in+*dlen, mdata, (size_t)len); in chunkqueue_peek_data()
1619 *dlen += (uint32_t)len; in chunkqueue_peek_data()
1625 ssize_t rd = chunk_file_pread(c->file.fd, data_in+*dlen, in chunkqueue_peek_data()
1633 *dlen += (uint32_t)rd; in chunkqueue_peek_data()
1642 if (*dlen == data_insz) in chunkqueue_peek_data()
1649 if (*dlen && *data != data_in) { in chunkqueue_peek_data()
1650 memcpy(data_in, *data, *dlen); in chunkqueue_peek_data()
1661 char * const data, const uint32_t dlen, in chunkqueue_read_data() argument
1665 uint32_t len = dlen; in chunkqueue_read_data()
1666 if (chunkqueue_peek_data(cq, &ptr, &len, errh) < 0 || len != dlen) in chunkqueue_read_data()
1688 uint32_t dlen = (uint32_t)cqlen; in chunkqueue_read_squash() local
1689 int rc = chunkqueue_peek_data(cq, &data, &dlen, errh); in chunkqueue_read_squash()
1694 buffer_truncate(c->mem, dlen); in chunkqueue_read_squash()