"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "tests/integration/corrupt_test.go" between
etcd-3.5.6.tar.gz and etcd-3.5.7.tar.gz

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

corrupt_test.go  (etcd-3.5.6)	:	corrupt_test.go  (etcd-3.5.7)
skipping to change at line 99		skipping to change at line 99
err = clus.Members[0].Restart(t)		err = clus.Members[0].Restart(t)
assert.NoError(t, err)		assert.NoError(t, err)
time.Sleep(50 * time.Millisecond)		time.Sleep(50 * time.Millisecond)
leader := clus.WaitLeader(t)		leader := clus.WaitLeader(t)
err = clus.Members[leader].CorruptionChecker().PeriodicCheck()		err = clus.Members[leader].CorruptionChecker().PeriodicCheck()
assert.NoError(t, err, "error on periodic check")		assert.NoError(t, err, "error on periodic check")
time.Sleep(50 * time.Millisecond)		time.Sleep(50 * time.Millisecond)
alarmResponse, err := cc.AlarmList(ctx)		alarmResponse, err := cc.AlarmList(ctx)
assert.NoError(t, err, "error on alarm list")		assert.NoError(t, err, "error on alarm list")
assert.Equal(t, []*etcdserverpb.AlarmMember{{Alarm: etcdserverpb.AlarmTyp e_CORRUPT, MemberID: uint64(clus.Members[0].ID())}}, alarmResponse.Alarms)		assert.Equal(t, []*etcdserverpb.AlarmMember{{Alarm: etcdserverpb.AlarmTyp e_CORRUPT, MemberID: 0}}, alarmResponse.Alarms)
}		}
func TestCompactHashCheck(t *testing.T) {		func TestCompactHashCheck(t *testing.T) {
BeforeTest(t)		BeforeTest(t)
clus := NewClusterV3(t, &ClusterConfig{Size: 3})		clus := NewClusterV3(t, &ClusterConfig{Size: 3})
defer clus.Terminate(t)		defer clus.Terminate(t)
cc, err := clus.ClusterClient()		cc, err := clus.ClusterClient()
require.NoError(t, err)		require.NoError(t, err)
skipping to change at line 172		skipping to change at line 172
err = clus.Members[0].Restart(t)		err = clus.Members[0].Restart(t)
assert.NoError(t, err)		assert.NoError(t, err)
_, err = cc.Compact(ctx, 5)		_, err = cc.Compact(ctx, 5)
assert.NoError(t, err)		assert.NoError(t, err)
time.Sleep(50 * time.Millisecond)		time.Sleep(50 * time.Millisecond)
leader := clus.WaitLeader(t)		leader := clus.WaitLeader(t)
clus.Members[leader].CorruptionChecker().CompactHashCheck()		clus.Members[leader].CorruptionChecker().CompactHashCheck()
time.Sleep(50 * time.Millisecond)		time.Sleep(50 * time.Millisecond)
alarmResponse, err := cc.AlarmList(ctx)		alarmResponse, err := cc.AlarmList(ctx)
assert.NoError(t, err, "error on alarm list")		assert.NoError(t, err, "error on alarm list")
assert.Equal(t, []*etcdserverpb.AlarmMember{{Alarm: etcdserverpb.AlarmTyp e_CORRUPT, MemberID: uint64(clus.Members[0].ID())}}, alarmResponse.Alarms)		assert.Equal(t, []*etcdserverpb.AlarmMember{{Alarm: etcdserverpb.AlarmTyp e_CORRUPT, MemberID: 0}}, alarmResponse.Alarms)
}		}
End of changes. 2 change blocks.
2 lines changed or deleted		2 lines changed or added

---