Skip to content

Commit

Permalink
HDDS-11410. Refactoring more tests from TestContainerBalancerTask (#7156
Browse files Browse the repository at this point in the history
)
  • Loading branch information
Montura authored Dec 3, 2024
1 parent 98e070e commit 0bde3a2
Show file tree
Hide file tree
Showing 4 changed files with 247 additions and 372 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package org.apache.hadoop.hdds.scm.container.balancer;

import org.apache.hadoop.hdds.conf.OzoneConfiguration;

class ContainerBalancerConfigBuilder {
private static final int DATANODE_COUNT_LIMIT_FOR_SMALL_CLUSTER = 15;

private final ContainerBalancerConfiguration config;

ContainerBalancerConfigBuilder(int nodeCount) {
this(new OzoneConfiguration(), nodeCount);
}

ContainerBalancerConfigBuilder(OzoneConfiguration ozoneConfig, int nodeCount) {
config = ozoneConfig.getObject(ContainerBalancerConfiguration.class);
config.setIterations(1);
config.setThreshold(10);
config.setMaxSizeToMovePerIteration(50 * TestContainerBalancerTask.STORAGE_UNIT);
config.setMaxSizeEnteringTarget(50 * TestContainerBalancerTask.STORAGE_UNIT);
if (nodeCount < DATANODE_COUNT_LIMIT_FOR_SMALL_CLUSTER) {
config.setMaxDatanodesPercentageToInvolvePerIteration(100);
}
}

ContainerBalancerConfiguration build() {
return config;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -142,6 +142,10 @@ public String toString() {
return startBalancerTask(new ContainerBalancer(scm), config);
}

public int getNodeCount() {
return cluster.getNodeCount();
}

public void enableLegacyReplicationManager() {
mockedReplicaManager.conf.setEnableLegacy(true);
}
Expand Down
Loading

0 comments on commit 0bde3a2

Please sign in to comment.