diff options
author | Harald Musum <musum@yahooinc.com> | 2023-06-08 11:06:27 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-06-08 11:06:27 +0200 |
commit | 7d9f7b3aeba5b7c739baa9eeeba944bf37b5d831 (patch) | |
tree | a353c78aac616238d75230a1a4424674d8988ed4 /node-admin | |
parent | d7568f0d450df2287657ac18c37955a1867496f5 (diff) |
Always use feature flag for container cpu capping
Diffstat (limited to 'node-admin')
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java | 24 |
1 files changed, 10 insertions, 14 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java index 460ef2efb58..4c17bfbe039 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java @@ -4,12 +4,10 @@ package com.yahoo.vespa.hosted.node.admin.nodeagent; import com.yahoo.component.Version; import com.yahoo.config.provision.ApplicationId; import com.yahoo.config.provision.DockerImage; -import com.yahoo.config.provision.Environment; import com.yahoo.config.provision.NodeType; import com.yahoo.config.provision.zone.ZoneApi; import com.yahoo.jdisc.Timer; import com.yahoo.vespa.flags.DoubleFlag; -import com.yahoo.vespa.flags.FetchVector; import com.yahoo.vespa.flags.FlagSource; import com.yahoo.vespa.flags.PermanentFlags; import com.yahoo.vespa.hosted.node.admin.configserver.noderepository.NodeAttributes; @@ -44,6 +42,10 @@ import java.util.function.Function; import java.util.logging.Level; import java.util.logging.Logger; +import static com.yahoo.vespa.flags.FetchVector.Dimension.APPLICATION_ID; +import static com.yahoo.vespa.flags.FetchVector.Dimension.CLUSTER_ID; +import static com.yahoo.vespa.flags.FetchVector.Dimension.CLUSTER_TYPE; +import static com.yahoo.vespa.flags.FetchVector.Dimension.HOSTNAME; import static com.yahoo.vespa.hosted.node.admin.nodeagent.NodeAgentContextSupplier.ContextSupplierInterruptedException; import static com.yahoo.vespa.hosted.node.admin.nodeagent.NodeAgentImpl.ContainerState.ABSENT; import static com.yahoo.vespa.hosted.node.admin.nodeagent.NodeAgentImpl.ContainerState.STARTING; @@ -415,22 +417,16 @@ public class NodeAgentImpl implements NodeAgent { } private ContainerResources getContainerResources(NodeAgentContext context) { - double cpuCap = noCpuCap(context.zone()) ? - 0 : - context.vcpuOnThisHost() * containerCpuCap - .with(FetchVector.Dimension.APPLICATION_ID, context.node().owner().map(ApplicationId::serializedForm)) - .with(FetchVector.Dimension.CLUSTER_ID, context.node().membership().map(NodeMembership::clusterId)) - .with(FetchVector.Dimension.CLUSTER_TYPE, context.node().membership().map(membership -> membership.type().value())) - .with(FetchVector.Dimension.HOSTNAME, context.node().hostname()) - .value(); + double cpuCap = context.vcpuOnThisHost() * containerCpuCap + .with(APPLICATION_ID, context.node().owner().map(ApplicationId::serializedForm)) + .with(CLUSTER_ID, context.node().membership().map(NodeMembership::clusterId)) + .with(CLUSTER_TYPE, context.node().membership().map(membership -> membership.type().value())) + .with(HOSTNAME, context.node().hostname()) + .value(); return ContainerResources.from(cpuCap, context.vcpuOnThisHost(), context.node().memoryGb()); } - private boolean noCpuCap(ZoneApi zone) { - return zone.getEnvironment() == Environment.dev || zone.getEnvironment().isTest(); - } - private boolean downloadImageIfNeeded(NodeAgentContext context, Optional<Container> container) { NodeSpec node = context.node(); if (node.wantedDockerImage().equals(container.map(c -> c.image()))) return false; |