aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2022-08-11 13:42:16 +0200
committerJon Bratseth <bratseth@gmail.com>2022-08-11 13:42:16 +0200
commit9e7ddc418064718deaf4b7d9d3b55492664a6372 (patch)
tree932ec26eeb83609b239a0a96037747aaf965f1c4 /node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java
parent202854aaeadb77f3880892b9b327166ab537c637 (diff)
Use actual ideal load in test load
Diffstat (limited to 'node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java15
1 files changed, 7 insertions, 8 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java
index b7041553c25..e668863bb9b 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/Loader.java
@@ -34,16 +34,14 @@ public class Loader {
* @param count the number of measurements
*/
public Duration addCpuMeasurements(double value, int count) {
- var idealLoad = fixture.clusterModel().idealLoad(); // TODO: Use this
+ var idealLoad = fixture.clusterModel().idealLoad();
NodeList nodes = fixture.nodes();
float oneExtraNodeFactor = (float)(nodes.size() - 1.0) / (nodes.size());
+ Load load = new Load(value, idealLoad.memory(), idealLoad.disk()).multiply(oneExtraNodeFactor);
Instant initialTime = fixture.tester().clock().instant();
for (int i = 0; i < count; i++) {
fixture.tester().clock().advance(samplingInterval);
for (Node node : nodes) {
- Load load = new Load(value,
- ClusterModel.idealMemoryLoad,
- ClusterModel.idealContentDiskLoad).multiply(oneExtraNodeFactor);
fixture.tester().nodeMetricsDb().addNodeMetrics(List.of(new Pair<>(node.hostname(),
new NodeMetricSnapshot(fixture.tester().clock().instant(),
load,
@@ -88,15 +86,16 @@ public class Loader {
* wanting to see the ideal load with one node missing.)
*/
public void addMemMeasurements(double value, int count) {
- var idealLoad = fixture.clusterModel().idealLoad(); // TODO: Use this
+ var idealLoad = fixture.clusterModel().idealLoad();
NodeList nodes = fixture.nodes();
float oneExtraNodeFactor = (float)(nodes.size() - 1.0) / (nodes.size());
+ Load load = new Load(idealLoad.cpu(), value, idealLoad.disk()).multiply(oneExtraNodeFactor);
+ System.out.println("Applying " + load);
+ System.out.println(" ideal " + idealLoad);
+ System.out.println("");
for (int i = 0; i < count; i++) {
fixture.tester().clock().advance(samplingInterval);
for (Node node : nodes) {
- Load load = new Load(0.2,
- value,
- ClusterModel.idealContentDiskLoad).multiply(oneExtraNodeFactor);
fixture.tester().nodeMetricsDb().addNodeMetrics(List.of(new Pair<>(node.hostname(),
new NodeMetricSnapshot(fixture.tester().clock().instant(),
load,