"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "tests/functional/tester/cluster_run.go" between
etcd-3.5.5.tar.gz and etcd-3.5.6.tar.gz

About: etcd is a distributed reliable key-value store for the most critical data of a distributed system (written in "Go").

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

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)