Function waitForMirrorComplete

sqlchain/mirror/mirror_test.go:184–211

(ctx context.Context, dbID string, tick time.Duration, stableDuration time.Duration)

}

func waitForMirrorComplete(ctx context.Context, dbID string, tick time.Duration, stableDuration time.Duration) (err error) {
	progressFile := FJ(testWorkingDir, "./mirror/node_mirror/"+dbID+progressFileSuffix)
	lastProgress := 0
	lastUpdate := time.Now()

	for {
		select {
		case <-ctx.Done():
			return ctx.Err()
		case <-time.After(tick):
			progressData, _ := ioutil.ReadFile(progressFile)
			progressCount, _ := strconv.Atoi(string(progressData))
			log.WithFields(log.Fields{
				"lastUpdate":     lastUpdate.String(),
				"stableDuration": stableDuration,
				"progressCount":  progressCount,
			}).Infof("current mirror count progress")
			if progressCount > lastProgress {
				lastProgress = progressCount
				lastUpdate = time.Now()
			}
			if progressCount > 5 || (progressCount > 0 && time.Now().Sub(lastUpdate) > stableDuration) {
				// mirror synced
				return
			}
		}
	}
}

func TestFullProcess(t *testing.T) {
	log.SetLevel(log.DebugLevel)