summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@verizonmedia.com>2019-05-20 10:50:19 +0200
committerJon Bratseth <bratseth@verizonmedia.com>2019-05-20 10:50:19 +0200
commit78edcbee16aefcbe37dd71841dc0e22df9854f19 (patch)
treecf710d07715a9b66f6d10dbbebdbd45fb9e1e0ba /node-repository
parentf89e5f828617a2cdcb28631d7db98387c698fded (diff)
Minor fixes
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/DockerHostCapacity.java12
1 files changed, 3 insertions, 9 deletions
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 a38d6cc1040..bec4af3e426 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
@@ -33,9 +33,6 @@ public class DockerHostCapacity {
int result = compare(freeCapacityOf(hostB, false), freeCapacityOf(hostA, false));
if (result != 0) return result;
- result = compare(freeCapacityOf(hostB, false), freeCapacityOf(hostA, false));
- if (result != 0) return result;
-
// If resources are equal we want to assign to the one with the most IPaddresses free
return freeIPs(hostB) - freeIPs(hostA);
}
@@ -44,9 +41,6 @@ public class DockerHostCapacity {
int result = compare(freeCapacityOf(hostB, true), freeCapacityOf(hostA, true));
if (result != 0) return result;
- result = compare(freeCapacityOf(hostB, true), freeCapacityOf(hostA, true));
- if (result != 0) return result;
-
// If resources are equal we want to assign to the one with the most IPaddresses free
return freeIPs(hostB) - freeIPs(hostA);
}
@@ -76,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), NodeResources::add)
- .withDiskSpeed(speed); // Set speed to 'any' if necvessary
+ .reduce(new NodeResources(0, 0, 0, speed), NodeResources::add)
+ .withDiskSpeed(speed); // Set speed to 'any' if necessary
}
/** Return total capacity for a given disk speed (or for any disk speed) */
@@ -86,7 +80,7 @@ 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), NodeResources::add)
+ .reduce(new NodeResources(0, 0, 0, speed), NodeResources::add)
.withDiskSpeed(speed); // Set speed to 'any' if necessary
}