Method Run

xs/multiobj.go:329–340

(*sync.WaitGroup)

}

func (r *prefetch) Run(*sync.WaitGroup) {
	var (
		err  error
		smap = r.t.Sowner().Get()
	)
	if r.msg.IsList() {
		err = r.iterateList(r, smap)
	} else {
		err = r.iterateRange(r, smap)
	}
	r.Finish(err)
}

func (r *prefetch) do(lom *cluster.LOM, _ *lriterator) {
	if err := lom.Load(true /*cache it*/, false /*locked*/); err != nil {