diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-10-19 13:08:28 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-10-19 13:11:45 +0200 |
commit | 96e57d962282f90b29a01dd188ae9ba1e26746d8 (patch) | |
tree | 7c5e9575ea8b02ef0e97c6ad703b41f20e308f66 /config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java | |
parent | bd1cdc00cdf97a01cdf82e082728f519f3f53572 (diff) |
Move vcpu() method to ContainerCluster
Diffstat (limited to 'config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java')
-rw-r--r-- | config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java b/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java index 93a02833d26..5074f1ecbbe 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerThreadpool.java @@ -11,7 +11,6 @@ import com.yahoo.vespa.model.container.component.SimpleComponent; import org.w3c.dom.Element; import java.util.Optional; -import java.util.OptionalDouble; /** * Component definition for a {@link java.util.concurrent.Executor} using {@link ContainerThreadPool}. @@ -48,13 +47,6 @@ public class ContainerThreadpool extends SimpleComponent implements ContainerThr protected Optional<UserOptions> userOptions() { return Optional.ofNullable(userOptions); } protected boolean hasUserOptions() { return userOptions().isPresent(); } - protected static OptionalDouble vcpu(ContainerCluster<?> cluster) { - return cluster.getContainers().stream() - .filter(c -> c.getHostResource() != null && c.getHostResource().realResources() != null) - .mapToDouble(c -> c.getHostResource().realResources().vcpu()) - .max(); // Use highest vcpu as scale factor - } - public static class UserOptions { private final int maxThreads; private final int minThreads; |