cluster_run.go (etcd-3.5.5) | : | cluster_run.go (etcd-3.5.6) | ||
---|---|---|---|---|
skipping to change at line 40 | skipping to change at line 40 | |||
const compactQPS = 50000 | const compactQPS = 50000 | |||
// Run starts tester. | // Run starts tester. | |||
func (clus *Cluster) Run() { | func (clus *Cluster) Run() { | |||
defer printReport() | defer printReport() | |||
// updateCases must be executed after etcd is started, because the FAILPO INTS case | // updateCases must be executed after etcd is started, because the FAILPO INTS case | |||
// needs to obtain all the failpoints from the etcd member. | // needs to obtain all the failpoints from the etcd member. | |||
clus.updateCases() | clus.updateCases() | |||
if err := fileutil.TouchDirAll(clus.Tester.DataDir); err != nil { | if err := fileutil.TouchDirAll(clus.lg, clus.Tester.DataDir); err != nil { | |||
clus.lg.Panic( | clus.lg.Panic( | |||
"failed to create test data directory", | "failed to create test data directory", | |||
zap.String("dir", clus.Tester.DataDir), | zap.String("dir", clus.Tester.DataDir), | |||
zap.Error(err), | zap.Error(err), | |||
) | ) | |||
} | } | |||
var preModifiedKey int64 | var preModifiedKey int64 | |||
for round := 0; round < int(clus.Tester.RoundLimit) || clus.Tester.RoundL imit == -1; round++ { | for round := 0; round < int(clus.Tester.RoundLimit) || clus.Tester.RoundL imit == -1; round++ { | |||
roundTotalCounter.Inc() | roundTotalCounter.Inc() | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 1 lines changed or added |