(t *testing.T)
| 85 | } |
| 86 | |
| 87 | func TestJoinValid(t *testing.T) { |
| 88 | // Create two Nodes |
| 89 | config := buildTestConfig(2, 0, 0) |
| 90 | n, err := Create(config) |
| 91 | if err != nil { |
| 92 | t.Fatalf("Create(%+v) failed: %v", config, err) |
| 93 | } |
| 94 | |
| 95 | config2 := buildTestConfig(2, 0, 0) |
| 96 | n2, err := Create(config2) |
| 97 | if err != nil { |
| 98 | t.Fatalf("Create(%+v) failed: %v", config, err) |
| 99 | } |
| 100 | |
| 101 | time.Sleep(10 * time.Millisecond) |
| 102 | |
| 103 | if len(n.serf.Members()) != 1 { |
| 104 | t.Fatalf("s1 members: %d", len(n.serf.Members())) |
| 105 | } |
| 106 | |
| 107 | if len(n2.serf.Members()) != 1 { |
| 108 | t.Fatalf("s2 members: %d", len(n2.serf.Members())) |
| 109 | } |
| 110 | |
| 111 | others := []string{fmt.Sprintf("127.0.0.1:%d", n2.serf.LocalMember().Port)} |
| 112 | if err := n.Join(others); err != nil { |
| 113 | t.Errorf("Join(%v) failed: %v", others, err) |
| 114 | } |
| 115 | |
| 116 | time.Sleep(10 * time.Millisecond) |
| 117 | |
| 118 | if len(n.serf.Members()) != 2 { |
| 119 | t.Errorf("s1 members: %d", len(n.serf.Members())) |
| 120 | } |
| 121 | |
| 122 | if len(n2.serf.Members()) != 2 { |
| 123 | t.Errorf("s2 members: %d", len(n2.serf.Members())) |
| 124 | } |
| 125 | } |
| 126 | |
| 127 | func TestBuildPeerNameValid(t *testing.T) { |
| 128 | n, err := defaultTestNode() |
nothing calls this directly
no test coverage detected