Method ReadAt

pkg/io/buffered.go:100–142

(b []byte, offset int64)

}

func (r *BufferedReaderAt) ReadAt(b []byte, offset int64) (int, error) {
	r.mtx.Lock()
	defer r.mtx.Unlock()

	if len(r.buffers) == 0 {
		return r.ra.ReadAt(b, offset)
	}

	// Least-recently-used tracking
	r.count++
	var lru *readerBuffer
	var buf *readerBuffer
	for i := range r.buffers {
		if r.canRead(&r.buffers[i], offset, int64(len(b))) {
			buf = &r.buffers[i]
			break
		}

		if lru == nil || r.buffers[i].count < lru.count {
			lru = &r.buffers[i]
		}
	}

	if buf == nil {
		// No buffer satisfied read, overwrite least-recently-used
		buf = lru

		r.prep(buf, offset, int64(len(b)))
		buf.count = r.count

		var err error
		if _, err = r.populate(buf); isFatalError(err) {
			return 0, err
		}

		r.read(buf, b, offset)
		return len(b), err
	}

	buf.count = r.count
	r.read(buf, b, offset)
	return len(b), nil
}

type BufferedWriter struct {
	w   io.Writer