aboutsummaryrefslogtreecommitdiffstats
path: root/config-proxy
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2021-09-15 20:46:36 +0200
committerHarald Musum <musum@yahooinc.com>2021-09-15 20:46:36 +0200
commitb998d5f0db4d88db85e055e8985d70af3d3453a0 (patch)
treec8bd47dee197b69cbdb550bd6f84c6377edb85be /config-proxy
parent5069740fcfca69f9b3ff8322b1b900f25c26a27b (diff)
Remove getConfigMd5() from RawConfig, update usage
Diffstat (limited to 'config-proxy')
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServer.java4
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/MemoryCache.java12
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java11
-rw-r--r--config-proxy/src/test/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServerTest.java4
4 files changed, 14 insertions, 17 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServer.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServer.java
index 2d9f4bd7fd0..d277ec66166 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServer.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServer.java
@@ -315,7 +315,7 @@ public class ConfigProxyRpcServer implements Runnable, TargetWatcher, RpcServer
sb.append(",");
sb.append(config.getGeneration());
sb.append(",");
- sb.append(config.getConfigMd5());
+ sb.append(config.getPayloadChecksums());
if (full) {
sb.append(",");
sb.append(config.getPayload());
@@ -354,7 +354,7 @@ public class ConfigProxyRpcServer implements Runnable, TargetWatcher, RpcServer
config.getGeneration(),
config.applyOnRestart(),
config.getPayloadChecksums());
- log.log(Level.FINE, () -> "Return response: " + request.getShortDescription() + ",configMd5=" + config.getConfigMd5() +
+ log.log(Level.FINE, () -> "Return response: " + request.getShortDescription() + ",config checksums=" + config.getPayloadChecksums() +
",generation=" + config.getGeneration());
log.log(Level.FINEST, () -> "Config payload in response for " + request.getShortDescription() + ":" + config.getPayload());
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/MemoryCache.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/MemoryCache.java
index 86f2022fa82..5320a04cc84 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/MemoryCache.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/MemoryCache.java
@@ -2,7 +2,6 @@
package com.yahoo.vespa.config.proxy;
import com.yahoo.io.IOUtils;
-import java.util.logging.Level;
import com.yahoo.vespa.config.ConfigCacheKey;
import com.yahoo.vespa.config.ConfigKey;
import com.yahoo.vespa.config.RawConfig;
@@ -16,6 +15,7 @@ import java.io.Writer;
import java.nio.file.Files;
import java.util.Collection;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.logging.Level;
import java.util.logging.Logger;
/**
@@ -112,9 +112,7 @@ public class MemoryCache {
String filename = path + File.separator + createCacheFileName(config);
Writer writer = null;
try {
- if (log.isLoggable(Level.FINE)) {
- log.log(Level.FINE, "Writing '" + config.getKey() + "' to '" + filename + "'");
- }
+ log.log(Level.FINE, () -> "Writing '" + config.getKey() + "' to '" + filename + "'");
final Payload payload = config.getPayload();
long protocolVersion = 3;
log.log(Level.FINE, () -> "Writing config '" + config + "' to file '" + filename + "' with protocol version " + protocolVersion);
@@ -122,9 +120,9 @@ public class MemoryCache {
// First three lines are meta-data about config as comment lines, fourth line is empty
writer.write("# defMd5:" + config.getDefMd5() + "\n");
- writer.write("# configMd5:" + config.getConfigMd5() + "\n");
- writer.write("# generation:" + Long.toString(config.getGeneration()) + "\n");
- writer.write("# protocolVersion:" + Long.toString(protocolVersion) + "\n");
+ writer.write("# config checksums:" + config.getPayloadChecksums() + "\n");
+ writer.write("# generation:" + config.getGeneration() + "\n");
+ writer.write("# protocolVersion:" + protocolVersion + "\n");
writer.write("\n");
writer.write(payload.withCompression(CompressionType.UNCOMPRESSED).toString());
writer.write("\n");
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java
index 3b9b101a8c6..71f1571b9c8 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java
@@ -10,11 +10,6 @@ import com.yahoo.jrt.Spec;
import com.yahoo.jrt.Supervisor;
import com.yahoo.jrt.Target;
import com.yahoo.jrt.Transport;
-
-import java.util.Map;
-import java.util.Optional;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.logging.Level;
import com.yahoo.vespa.config.ConfigCacheKey;
import com.yahoo.vespa.config.RawConfig;
import com.yahoo.vespa.config.TimingValues;
@@ -22,10 +17,14 @@ import com.yahoo.vespa.config.protocol.JRTServerConfigRequest;
import java.util.ArrayList;
import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
+import java.util.logging.Level;
import java.util.logging.Logger;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
@@ -134,7 +133,7 @@ class RpcConfigSourceClient implements ConfigSourceClient, Runnable {
RawConfig ret = null;
if (cachedConfig != null) {
log.log(Level.FINE, () -> "Found config " + configCacheKey + " in cache, generation=" + cachedConfig.getGeneration() +
- ",configmd5=" + cachedConfig.getConfigMd5());
+ ",config checksums=" + cachedConfig.getPayloadChecksums());
log.log(Level.FINEST, () -> "input config=" + input + ",cached config=" + cachedConfig);
if (ProxyServer.configOrGenerationHasChanged(cachedConfig, request)) {
log.log(Level.FINEST, () -> "Cached config is not equal to requested, will return it");
diff --git a/config-proxy/src/test/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServerTest.java b/config-proxy/src/test/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServerTest.java
index 628e1c013e6..50a02f7776b 100644
--- a/config-proxy/src/test/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServerTest.java
+++ b/config-proxy/src/test/java/com/yahoo/vespa/config/proxy/ConfigProxyRpcServerTest.java
@@ -102,7 +102,7 @@ public class ConfigProxyRpcServerTest {
assertThat(ret[0], is(config.getNamespace() + "." + config.getName() + "," +
config.getConfigId() + "," +
config.getGeneration() + "," +
- config.getConfigMd5()));
+ config.getPayloadChecksums()));
}
/**
@@ -128,7 +128,7 @@ public class ConfigProxyRpcServerTest {
assertThat(ret[0], is(config.getNamespace() + "." + config.getName() + "," +
config.getConfigId() + "," +
config.getGeneration() + "," +
- config.getConfigMd5() + "," +
+ config.getPayloadChecksums() + "," +
config.getPayload().getData()));
}