Searched refs:read_end (Results 1 – 3 of 3) sorted by relevance
41 unsigned char *read_end; member59 ret->read_end = ret->buffer; in record_stream_new()100 record_end = getEndOfRecord (p_rs->unconsumed, p_rs->read_end); in getNextRecord()145 && p_rs->read_end == p_rs->buffer_end in record_stream_get_next()158 toMove = p_rs->read_end - p_rs->unconsumed; in record_stream_get_next()163 p_rs->read_end = p_rs->buffer + toMove; in record_stream_get_next()167 countRead = read (p_rs->fd, p_rs->read_end, p_rs->buffer_end - p_rs->read_end); in record_stream_get_next()175 p_rs->read_end += countRead; in record_stream_get_next()
179 uint64_t read_end = partition_size_; in ScheduleRead() local182 read_end = std::min(read_end, partition.hash_tree_offset); in ScheduleRead()185 read_end = std::min(read_end, partition.fec_offset); in ScheduleRead()187 std::min(static_cast<uint64_t>(buffer_.size()), read_end - offset_); in ScheduleRead()
1505 off64_t read_end; in ReadAtOffset() local1507 __builtin_add_overflow(off, static_cast<off64_t>(len), &read_end)) { in ReadAtOffset()1513 if (read_end > data_length_) { in ReadAtOffset()