Method getReaderAtOffset

internal/stream/stream.go:444–485

(off int64)

}

func (r *RangeReadReadAtSeeker) getReaderAtOffset(off int64) (io.Reader, error) {
	for {
		var cur int64 = -1
		r.readerMap.Range(func(key, value any) bool {
			k := key.(int64)
			if off == k {
				cur = k
				return false
			}
			if off > k && off-k <= 4*utils.MB && k > cur {
				cur = k
			}
			return true
		})
		if cur < 0 {
			break
		}
		v, ok := r.readerMap.LoadAndDelete(int64(cur))
		if !ok {
			continue
		}
		rr := v.(io.Reader)
		if off == int64(cur) {
			// logrus.Debugf("getReaderAtOffset match_%d", off)
			return rr, nil
		}
		n, _ := utils.CopyWithBufferN(io.Discard, rr, off-cur)
		cur += n
		if cur == off {
			// logrus.Debugf("getReaderAtOffset old_%d", off)
			return rr, nil
		}
		break
	}

	// logrus.Debugf("getReaderAtOffset new_%d", off)
	reader, err := r.ss.RangeRead(http_range.Range{Start: off, Length: -1})
	if err != nil {
		return nil, err
	}
	return reader, nil
}

func (r *RangeReadReadAtSeeker) ReadAt(p []byte, off int64) (n int, err error) {
	if off < 0 || off >= r.ss.GetSize() {