adds a test

This commit is contained in:
Chris Lu 2021-08-01 22:53:50 -07:00
parent 6de786185d
commit f690643b47
2 changed files with 2262 additions and 805 deletions

View file

@ -120,7 +120,7 @@ func balanceVolumeServers(commandEnv *CommandEnv, diskTypes []types.DiskType, vo
func balanceVolumeServersByDiskType(commandEnv *CommandEnv, diskType types.DiskType, volumeReplicas map[uint32][]*VolumeReplica, nodes []*Node, volumeSizeLimit uint64, collection string, applyBalancing bool) error {
// balance readable volumes
// balance read only volumes
for _, n := range nodes {
n.selectVolumes(func(v *master_pb.VolumeInformationMessage) bool {
if collection != "ALL_COLLECTIONS" {

File diff suppressed because it is too large Load diff