diff options
| author | Lisandro Pin <lisandro.pin@proton.ch> | 2024-12-04 18:00:55 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-04 09:00:55 -0800 |
| commit | 351efa134d8a3158026f6560da723b7440a7c62f (patch) | |
| tree | 3d188ea26f34083bcf7a10df3e6744842ed4a062 /weed/shell/command_ec_test.go | |
| parent | b65eb2ec4569891495ae184bf6090e0e500961e3 (diff) | |
| download | seaweedfs-351efa134d8a3158026f6560da723b7440a7c62f.tar.xz seaweedfs-351efa134d8a3158026f6560da723b7440a7c62f.zip | |
Account for replication placement settings when balancing EC shards across racks. (#6316)
Diffstat (limited to 'weed/shell/command_ec_test.go')
| -rw-r--r-- | weed/shell/command_ec_test.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/shell/command_ec_test.go b/weed/shell/command_ec_test.go index ef9461ef0..50e06ba6c 100644 --- a/weed/shell/command_ec_test.go +++ b/weed/shell/command_ec_test.go @@ -28,7 +28,7 @@ func TestCommandEcBalanceSmall(t *testing.T) { } racks := collectRacks(allEcNodes) - balanceEcVolumes(nil, "c1", allEcNodes, racks, false) + balanceEcVolumes(nil, "c1", allEcNodes, racks, nil, false) } func TestCommandEcBalanceNothingToMove(t *testing.T) { @@ -43,7 +43,7 @@ func TestCommandEcBalanceNothingToMove(t *testing.T) { } racks := collectRacks(allEcNodes) - balanceEcVolumes(nil, "c1", allEcNodes, racks, false) + balanceEcVolumes(nil, "c1", allEcNodes, racks, nil, false) } func TestCommandEcBalanceAddNewServers(t *testing.T) { @@ -60,7 +60,7 @@ func TestCommandEcBalanceAddNewServers(t *testing.T) { } racks := collectRacks(allEcNodes) - balanceEcVolumes(nil, "c1", allEcNodes, racks, false) + balanceEcVolumes(nil, "c1", allEcNodes, racks, nil, false) } func TestCommandEcBalanceAddNewRacks(t *testing.T) { @@ -77,7 +77,7 @@ func TestCommandEcBalanceAddNewRacks(t *testing.T) { } racks := collectRacks(allEcNodes) - balanceEcVolumes(nil, "c1", allEcNodes, racks, false) + balanceEcVolumes(nil, "c1", allEcNodes, racks, nil, false) } func TestCommandEcBalanceVolumeEvenButRackUneven(t *testing.T) { @@ -119,7 +119,7 @@ func TestCommandEcBalanceVolumeEvenButRackUneven(t *testing.T) { } racks := collectRacks(allEcNodes) - balanceEcVolumes(nil, "c1", allEcNodes, racks, false) + balanceEcVolumes(nil, "c1", allEcNodes, racks, nil, false) balanceEcRacks(nil, racks, false) } |