luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

Add a test for changing a failed node's ID

This commit is contained in:
Kyle Havlovitz 2019-03-13 15:39:01 -07:00
parent bf09061e86
commit df4ec913f0
1 changed files with 10 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
agent/consul/leader_test.go
View File

@ -955,20 +955,15 @@ func TestLeader_ChangeServerID(t *testing.T) {
func TestLeader_ChangeNodeID(t *testing.T) { func TestLeader_ChangeNodeID(t *testing.T) {
t.Parallel() t.Parallel()
conf := func(c *Config) { dir1, s1 := testServer(t)
c.Bootstrap = false
c.BootstrapExpect = 3
c.Datacenter = "dc1"
}
dir1, s1 := testServerWithConfig(t, conf)
defer os.RemoveAll(dir1) defer os.RemoveAll(dir1)
defer s1.Shutdown() defer s1.Shutdown()
dir2, s2 := testServerWithConfig(t, conf) dir2, s2 := testServerDCBootstrap(t, "dc1", false)
defer os.RemoveAll(dir2) defer os.RemoveAll(dir2)
defer s2.Shutdown() defer s2.Shutdown()
dir3, s3 := testServerWithConfig(t, conf) dir3, s3 := testServerDCBootstrap(t, "dc1", false)
defer os.RemoveAll(dir3) defer os.RemoveAll(dir3)
defer s3.Shutdown() defer s3.Shutdown()
@ -986,18 +981,18 @@ func TestLeader_ChangeNodeID(t *testing.T) {
s3.Shutdown() s3.Shutdown()
retry.Run(t, func(r *retry.R) { retry.Run(t, func(r *retry.R) {
alive := 0 failed := 0
for _, m := range s1.LANMembers() { for _, m := range s1.LANMembers() {
if m.Status == serf.StatusAlive { if m.Status == serf.StatusFailed {
alive++ failed++
} }
} }
if got, want := alive, 2; got != want { if got, want := failed, 1; got != want {
r.Fatalf("got %d alive members want %d", got, want) r.Fatalf("got %d failed members want %d", got, want)
} }
}) })
// Bring up a new server with s3's address that will get a different ID // Bring up a new server with s3's name that will get a different ID
dir4, s4 := testServerWithConfig(t, func(c *Config) { dir4, s4 := testServerWithConfig(t, func(c *Config) {
c.Bootstrap = false c.Bootstrap = false
c.Datacenter = "dc1" c.Datacenter = "dc1"
@ -1008,7 +1003,7 @@ func TestLeader_ChangeNodeID(t *testing.T) {
joinLAN(t, s4, s1) joinLAN(t, s4, s1)
servers[2] = s4 servers[2] = s4
// Make sure the dead server is removed and we're back to 3 total peers // Make sure the dead server is gone from both Raft and Serf and we're back to 3 total peers
retry.Run(t, func(r *retry.R) { retry.Run(t, func(r *retry.R) {
r.Check(wantRaft(servers)) r.Check(wantRaft(servers))
for _, s := range servers { for _, s := range servers {