Method startFullValidation

pkg/server/sync.go:722–748

()

}

func (sh *SyncHandler) startFullValidation() {
	sh.mu.Lock()
	if sh.vshardDone == len(sh.vshards) {
		sh.vshards, sh.vshardErrs = nil, nil
		sh.vshardDone, sh.vmissing = 0, 0
		sh.vdestCount, sh.vdestBytes = 0, 0
		sh.vsrcCount, sh.vsrcBytes = 0, 0
	}
	if len(sh.vshards) != 0 {
		sh.mu.Unlock()
		return
	}
	sh.mu.Unlock()

	sh.logf("running full validation; determining validation shards...")
	shards := sh.shardPrefixes()

	sh.mu.Lock()
	if len(sh.vshards) != 0 {
		sh.mu.Unlock()
		return
	}
	sh.vshards = shards
	sh.mu.Unlock()

	go sh.runFullValidation()
}

func (sh *SyncHandler) runFullValidation() {
	var wg sync.WaitGroup