Method Start

xs/multiobj.go:298–312

()

}

func (p *prfFactory) Start() error {
	b := p.Bck
	if err := b.Init(p.Args.T.Bowner()); err != nil {
		if cmn.IsErrRemoteBckNotFound(err) {
			glog.Warning(err) // may show up later via ais/prxtrybck.go logic
		} else {
			return err
		}
	} else if b.IsAIS() {
		glog.Errorf("bucket %q: can only prefetch remote buckets", b)
		return fmt.Errorf("bucket %q: can only prefetch remote buckets", b)
	}
	p.xctn = newPrefetch(&p.Args, p.Kind(), p.Bck, p.msg)
	return nil
}

func (*prfFactory) Kind() string        { return apc.ActPrefetchObjects }
func (p *prfFactory) Get() cluster.Xact { return p.xctn }