aboutsummaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-07-05 17:09:39 +0200
committerGitHub <noreply@github.com>2022-07-05 17:09:39 +0200
commit75492160196a8bf295796231f4cf0aa3f291cea1 (patch)
tree822268be1cbd89b3949d4f883c30ee7b74524614 /config-model/src/main/java/com/yahoo
parent76019c70d1c41a16ee2fb6af56bc35f4cd52b667 (diff)
Revert "Revert "GC long gone config""
Diffstat (limited to 'config-model/src/main/java/com/yahoo')
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/container/Container.java16
-rwxr-xr-xconfig-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java8
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/container/docproc/ContainerDocproc.java13
-rw-r--r--config-model/src/main/java/com/yahoo/vespa/model/container/xml/DocprocOptionsBuilder.java5
4 files changed, 4 insertions, 38 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/Container.java b/config-model/src/main/java/com/yahoo/vespa/model/container/Container.java
index 4b1c03a170c..cbfe2826a76 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/container/Container.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/container/Container.java
@@ -1,7 +1,6 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.model.container;
-import com.yahoo.config.application.api.DeployLogger;
import com.yahoo.config.model.api.ModelContext;
import com.yahoo.config.model.api.container.ContainerServiceType;
import com.yahoo.config.model.deploy.DeployState;
@@ -148,19 +147,6 @@ public abstract class Container extends AbstractService implements
return (parent instanceof ContainerCluster) ? ((ContainerCluster<?>) parent).getHttp() : null;
}
- public JettyHttpServer getDefaultHttpServer() {
- return defaultHttpServer;
- }
-
- public JettyHttpServer getHttpServer() {
- Http http = getHttp();
- if (http == null) {
- return defaultHttpServer;
- } else {
- return http.getHttpServer().orElse(null);
- }
- }
-
/** Returns the index of this node. The index of a given node is stable through changes with best effort. */
public final int index() { return index; }
@@ -381,7 +367,7 @@ public abstract class Container extends AbstractService implements
@Override
public void getConfig(ContainerMbusConfig.Builder builder) {
- builder.enabled(messageBusEnabled()).port(getMessagingPort());
+ builder.port(getMessagingPort());
}
@Override
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java
index 5adea6d50e8..6b6192a04ef 100755
--- a/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java
@@ -412,8 +412,6 @@ public abstract class ContainerCluster<CONTAINER extends Container>
@Override
public void getConfig(DocumentmanagerConfig.Builder builder) {
- if (containerDocproc != null && containerDocproc.isCompressDocuments())
- builder.enablecompression(true);
if (containerDocumentApi != null)
builder.ignoreundefinedfields(containerDocumentApi.ignoreUndefinedFields());
}
@@ -539,9 +537,7 @@ public abstract class ContainerCluster<CONTAINER extends Container>
@Override
public void getConfig(IlscriptsConfig.Builder builder) {
- List<SearchCluster> searchClusters = new ArrayList<>();
- searchClusters.addAll(Content.getSearchClusters(getRoot().configModelRepo()));
- for (SearchCluster searchCluster : searchClusters) {
+ for (SearchCluster searchCluster : Content.getSearchClusters(getRoot().configModelRepo())) {
searchCluster.getConfig(builder);
}
}
@@ -613,8 +609,6 @@ public abstract class ContainerCluster<CONTAINER extends Container>
public void setEnvironmentVars(String environmentVars) { this.environmentVars = environmentVars; }
- public String getEnvironmentVars() { return environmentVars; }
-
public Optional<String> getJvmGCOptions() { return Optional.ofNullable(jvmGCOptions); }
public final void setRpcServerEnabled(boolean rpcServerEnabled) { this.rpcServerEnabled = rpcServerEnabled; }
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/docproc/ContainerDocproc.java b/config-model/src/main/java/com/yahoo/vespa/model/container/docproc/ContainerDocproc.java
index 8be02f77ab3..f2233680e9b 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/container/docproc/ContainerDocproc.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/container/docproc/ContainerDocproc.java
@@ -35,7 +35,7 @@ public class ContainerDocproc extends ContainerSubsystem<DocprocChains>
private Map<Pair<String, String>, String> fieldNameSchemaMap = new HashMap<>();
public ContainerDocproc(ContainerCluster cluster, DocprocChains chains) {
- this(cluster, chains, new Options(false, null, null, null, null, null, null));
+ this(cluster, chains, new Options( null, null, null, null, null, null));
}
public ContainerDocproc(ContainerCluster cluster, DocprocChains chains, Options options) {
@@ -60,10 +60,6 @@ public class ContainerDocproc extends ContainerSubsystem<DocprocChains>
}
}
- public boolean isCompressDocuments() {
- return options.compressDocuments;
- }
-
public boolean isPreferLocalNode() {
return preferLocalNode;
}
@@ -75,8 +71,6 @@ public class ContainerDocproc extends ContainerSubsystem<DocprocChains>
@Override
public void getConfig(ContainerMbusConfig.Builder builder) {
builder.maxpendingcount(getMaxMessagesInQueue());
- if (getMaxQueueMbSize() != null)
- builder.maxpendingsize(getMaxQueueMbSize()); //yes, this shall be set in megabytes.
}
private int getMaxMessagesInQueue() {
@@ -137,8 +131,6 @@ public class ContainerDocproc extends ContainerSubsystem<DocprocChains>
}
public static class Options {
- // Whether or not to compress documents after processing them.
- public final boolean compressDocuments;
public final Integer maxMessagesInQueue;
public final Integer maxQueueMbSize;
@@ -148,8 +140,7 @@ public class ContainerDocproc extends ContainerSubsystem<DocprocChains>
public final Double documentExpansionFactor;
public final Integer containerCoreMemory;
- public Options(boolean compressDocuments, Integer maxMessagesInQueue, Integer maxQueueMbSize, Integer maxQueueTimeMs, Double maxConcurrentFactor, Double documentExpansionFactor, Integer containerCoreMemory) {
- this.compressDocuments = compressDocuments;
+ public Options(Integer maxMessagesInQueue, Integer maxQueueMbSize, Integer maxQueueTimeMs, Double maxConcurrentFactor, Double documentExpansionFactor, Integer containerCoreMemory) {
this.maxMessagesInQueue = maxMessagesInQueue;
this.maxQueueMbSize = maxQueueMbSize;
this.maxQueueTimeMs = maxQueueTimeMs;
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/xml/DocprocOptionsBuilder.java b/config-model/src/main/java/com/yahoo/vespa/model/container/xml/DocprocOptionsBuilder.java
index 1239cbf9bdc..e0dffca2bc5 100644
--- a/config-model/src/main/java/com/yahoo/vespa/model/container/xml/DocprocOptionsBuilder.java
+++ b/config-model/src/main/java/com/yahoo/vespa/model/container/xml/DocprocOptionsBuilder.java
@@ -10,7 +10,6 @@ import org.w3c.dom.Element;
public class DocprocOptionsBuilder {
public static ContainerDocproc.Options build(Element spec) {
return new ContainerDocproc.Options(
- getCompression(spec),
getMaxMessagesInQueue(spec),
getSizeInMegabytes(spec.getAttribute("maxqueuebytesize")),
getTime(spec.getAttribute("maxqueuewait")),
@@ -25,10 +24,6 @@ public class DocprocOptionsBuilder {
Integer.parseInt(integer);
}
- private static boolean getCompression(Element spec) {
- return (spec.hasAttribute("compressdocuments") && spec.getAttribute("compressdocuments").equals("true"));
- }
-
private static Double getFactor(String factor) {
return factor == null || factor.trim().isEmpty() ?
null :