summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorArne Juul <arnej@yahoo-inc.com>2019-02-19 14:35:14 +0000
committerArne Juul <arnej@yahoo-inc.com>2019-02-20 10:30:49 +0000
commit6bea4cb059566f0eb4fec2212881ece9b0a56b15 (patch)
treea065d9a88cdedeeb70cf5f6a65d4eecb72e3f89a
parent4235233d61430c7da8b55988e8744b95d91a7ed4 (diff)
transfer network ports from node Allocation to HostSpec
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java14
1 files changed, 11 insertions, 3 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java
index a0d76241533..246c56ee28b 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java
@@ -22,11 +22,13 @@ import com.yahoo.vespa.flags.Flags;
import com.yahoo.vespa.hosted.provision.Node;
import com.yahoo.vespa.hosted.provision.NodeRepository;
import com.yahoo.vespa.hosted.provision.flag.FlagId;
+import com.yahoo.vespa.hosted.provision.node.Allocation;
import com.yahoo.vespa.hosted.provision.node.filter.ApplicationFilter;
import com.yahoo.vespa.hosted.provision.node.filter.NodeHostFilter;
import java.util.ArrayList;
import java.util.Collection;
+import java.util.Collections;
import java.util.Comparator;
import java.util.List;
import java.util.Optional;
@@ -141,10 +143,16 @@ public class NodeRepositoryProvisioner implements Provisioner {
List<HostSpec> hosts = new ArrayList<>(nodes.size());
for (Node node : nodes) {
log.log(LogLevel.DEBUG, () -> "Prepared node " + node.hostname() + " - " + node.flavor());
+ Allocation nodeAllocation = node.allocation().orElseThrow(IllegalStateException::new);
hosts.add(new HostSpec(node.hostname(),
- node.allocation().orElseThrow(IllegalStateException::new).membership(),
- node.flavor(),
- node.status().vespaVersion()));
+ Collections.emptyList(),
+ Optional.of(node.flavor()),
+ Optional.of(nodeAllocation.membership()),
+ node.status().vespaVersion(),
+ nodeAllocation.networkPorts()));
+ if (nodeAllocation.networkPorts().isPresent()) {
+ log.log(LogLevel.DEBUG, () -> "Prepared node " + node.hostname() + " has port allocations");
+ }
}
return hosts;
}