summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-09-01 11:30:33 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2021-09-01 11:30:33 +0200
commit6cebfce1c3c817719ef6d5b06f8988b833c14b0d (patch)
tree676de2d14645dddebe1316039219bf6616bfa9e1 /configserver
parent670aec6981523424d8539b0d0e5222c8b051d130 (diff)
Refactor to prepare for computeIfAbsent.
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/application/Application.java26
1 files changed, 13 insertions, 13 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/application/Application.java b/configserver/src/main/java/com/yahoo/vespa/config/server/application/Application.java
index db3761a97f7..97acfd9b549 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/application/Application.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/application/Application.java
@@ -8,8 +8,6 @@ import com.yahoo.config.ConfigurationRuntimeException;
import com.yahoo.config.model.api.ApplicationInfo;
import com.yahoo.config.model.api.Model;
import com.yahoo.config.provision.ApplicationId;
-import java.util.logging.Level;
-
import com.yahoo.text.AbstractUtf8Array;
import com.yahoo.vespa.config.ConfigCacheKey;
import com.yahoo.vespa.config.ConfigDefinitionKey;
@@ -31,6 +29,7 @@ import com.yahoo.vespa.config.server.tenant.TenantRepository;
import com.yahoo.vespa.config.util.ConfigUtils;
import com.yahoo.yolean.Exceptions;
+import java.util.logging.Level;
import java.util.Objects;
import java.util.Set;
@@ -117,8 +116,18 @@ public class Application implements ModelResult {
metricUpdater.incrementProcTime(System.currentTimeMillis() - start);
return config;
}
+ config = createConfigResponse(configKey, req, responseFactory);
+ cache.put(cacheKey, config, config.getConfigMd5());
+ metricUpdater.setCacheConfigElems(cache.configElems());
+ metricUpdater.setCacheChecksumElems(cache.checkSumElems());
+ return config;
+ } else {
+ return createConfigResponse(configKey, req, responseFactory);
}
+ }
+ private ConfigResponse createConfigResponse(ConfigKey<?> configKey, GetConfigRequest req, ConfigResponseFactory responseFactory) {
+ long start = System.currentTimeMillis();
ConfigDefinition def = getTargetDef(req);
if (def == null) {
metricUpdater.incrementFailedRequests();
@@ -126,19 +135,10 @@ public class Application implements ModelResult {
}
log.log(Level.FINE, () -> TenantRepository.logPre(getId()) + ("Resolving " + configKey + " with config definition " + def));
-
-
var payload = createPayload(configKey, def);
- ConfigResponse configResponse = responseFactory.createResponse(payload.getFirst(),
- applicationGeneration,
- payload.getSecond());
+ var response = responseFactory.createResponse(payload.getFirst(), applicationGeneration, payload.getSecond());
metricUpdater.incrementProcTime(System.currentTimeMillis() - start);
- if (useCache(req)) {
- cache.put(cacheKey, configResponse, configResponse.getConfigMd5());
- metricUpdater.setCacheConfigElems(cache.configElems());
- metricUpdater.setCacheChecksumElems(cache.checkSumElems());
- }
- return configResponse;
+ return response;
}
private Pair<AbstractUtf8Array, Boolean> createPayload(ConfigKey<?> configKey, ConfigDefinition def) {