kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-07 10:55:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix bootstrap tests

Browse Source
This commit is contained in:
Alex Dadgar
2017-02-03 13:00:28 -08:00
parent 7a1bdf9696
commit b03e73d4a2
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
nomad/serf_test.go
View File

@@ -94,12 +94,14 @@ func TestNomad_BootstrapExpect(t *testing.T) {
s1 := testServer(t, func(c *Config) {
c.BootstrapExpect = 2
c.DevMode = false
c.DevDisableBootstrap = true
c.DataDir = path.Join(dir, "node1")
})
defer s1.Shutdown()
s2 := testServer(t, func(c *Config) {
c.BootstrapExpect = 2
c.DevMode = false
c.DevDisableBootstrap = true
c.DataDir = path.Join(dir, "node2")
})
defer s2.Shutdown()
@@ -110,14 +112,14 @@ func TestNomad_BootstrapExpect(t *testing.T) {
if err != nil {
return false, err
}
if peers != 1 {
if peers != 2 {
return false, fmt.Errorf("bad: %#v", peers)
}
peers, err = s2.numPeers()
if err != nil {
return false, err
}
if peers != 1 {
if peers != 2 {
return false, fmt.Errorf("bad: %#v", peers)
}
if len(s1.localPeers) != 2 {
@@ -163,7 +165,7 @@ func TestNomad_BadExpect(t *testing.T) {
testutil.WaitForResult(func() (bool, error) {
for _, s := range servers {
p, _ := s.numPeers()
if p != 0 {
if p != 1 {
return false, fmt.Errorf("%d", p)
}
}