aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-05-01 23:15:58 -0700
committerchrislu <chris.lu@gmail.com>2022-05-01 23:15:58 -0700
commitce1e8e58ae53d093b3fb97df9533b81dac236ba5 (patch)
tree78dff8132e03e8a21a144c4765c73168a3a3ded0
parent2c0fdf36931fded0b530098b47fc8ddfc663abf3 (diff)
downloadseaweedfs-ce1e8e58ae53d093b3fb97df9533b81dac236ba5.tar.xz
seaweedfs-ce1e8e58ae53d093b3fb97df9533b81dac236ba5.zip
fix test
-rw-r--r--weed/cluster/cluster_test.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/cluster/cluster_test.go b/weed/cluster/cluster_test.go
index d7c82a24d..ccaccf6f7 100644
--- a/weed/cluster/cluster_test.go
+++ b/weed/cluster/cluster_test.go
@@ -14,7 +14,7 @@ func TestClusterAddRemoveNodes(t *testing.T) {
assert.Equal(t, []pb.ServerAddress{
pb.ServerAddress("111:1"),
pb.ServerAddress("111:2"),
- }, c.filerLeaders.GetLeaders())
+ }, c.getFilers("", false).leaders.GetLeaders())
c.AddClusterNode("", "filer", pb.ServerAddress("111:3"), "23.45")
c.AddClusterNode("", "filer", pb.ServerAddress("111:4"), "23.45")
@@ -22,7 +22,7 @@ func TestClusterAddRemoveNodes(t *testing.T) {
pb.ServerAddress("111:1"),
pb.ServerAddress("111:2"),
pb.ServerAddress("111:3"),
- }, c.filerLeaders.GetLeaders())
+ }, c.getFilers("", false).leaders.GetLeaders())
c.AddClusterNode("", "filer", pb.ServerAddress("111:5"), "23.45")
c.AddClusterNode("", "filer", pb.ServerAddress("111:6"), "23.45")
@@ -31,7 +31,7 @@ func TestClusterAddRemoveNodes(t *testing.T) {
pb.ServerAddress("111:1"),
pb.ServerAddress("111:2"),
pb.ServerAddress("111:3"),
- }, c.filerLeaders.GetLeaders())
+ }, c.getFilers("", false).leaders.GetLeaders())
// remove oldest
c.RemoveClusterNode("", "filer", pb.ServerAddress("111:1"))
@@ -39,7 +39,7 @@ func TestClusterAddRemoveNodes(t *testing.T) {
pb.ServerAddress("111:6"),
pb.ServerAddress("111:2"),
pb.ServerAddress("111:3"),
- }, c.filerLeaders.GetLeaders())
+ }, c.getFilers("", false).leaders.GetLeaders())
// remove oldest
c.RemoveClusterNode("", "filer", pb.ServerAddress("111:1"))