From aebd8e095c9ff9c2889bfed05ef4d5e30c767e29 Mon Sep 17 00:00:00 2001 From: Jon Bratseth Date: Sun, 2 Jun 2019 13:33:57 +0200 Subject: Add resources across disk speeds --- .../vespa/hosted/provision/provisioning/DockerHostCapacity.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'node-repository') diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/DockerHostCapacity.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/DockerHostCapacity.java index 9d8bc047862..feccfb430e6 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/DockerHostCapacity.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/DockerHostCapacity.java @@ -70,8 +70,8 @@ public class DockerHostCapacity { .filter(n -> n.type().equals(NodeType.host)) .filter(n -> speed == NodeResources.DiskSpeed.any || n.flavor().resources().diskSpeed() == speed) .map(n -> freeCapacityOf(n, false)) - .reduce(new NodeResources(0, 0, 0, speed), NodeResources::add) - .withDiskSpeed(speed); // Set speed to 'any' if necessary + .map(resources -> resources.withDiskSpeed(speed)) // Set speed to 'any' if necessary + .reduce(new NodeResources(0, 0, 0, speed), NodeResources::add); } /** Return total capacity for a given disk speed (or for any disk speed) */ @@ -80,8 +80,8 @@ public class DockerHostCapacity { .filter(n -> n.type().equals(NodeType.host)) .filter(n -> speed == NodeResources.DiskSpeed.any || n.flavor().resources().diskSpeed() == speed) .map(host -> host.flavor().resources()) - .reduce(new NodeResources(0, 0, 0, speed), NodeResources::add) - .withDiskSpeed(speed); // Set speed to 'any' if necessary + .map(resources -> resources.withDiskSpeed(speed)) // Set speed to 'any' if necessary + .reduce(new NodeResources(0, 0, 0, speed), NodeResources::add); } public int freeCapacityInFlavorEquivalence(Flavor flavor) { -- cgit v1.2.3