diff options
author | Harald Musum <musum@yahooinc.com> | 2021-09-09 09:29:53 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2021-09-09 09:29:53 +0200 |
commit | c8d830e1600da93112ae36e4f464ac9a9a9c8fc5 (patch) | |
tree | 8719d0e7231b75de0528e71d4d2406739cab8a2a /configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java | |
parent | ee747ac8a83f1a7be8862635d4b451d913f51fff (diff) |
Use both xxhash64 and md5 for config payload in requests and responses
Chacking of equal config with hasEqualConfig() still uses only md5
Diffstat (limited to 'configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java')
-rw-r--r-- | configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java b/configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java index 738e8c9827d..21e1c1f3448 100644 --- a/configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java +++ b/configserver/src/test/java/com/yahoo/vespa/config/server/rpc/DelayedConfigResponseTest.java @@ -2,12 +2,11 @@ package com.yahoo.vespa.config.server.rpc; import com.yahoo.config.provision.ApplicationId; - +import com.yahoo.vespa.config.PayloadChecksums; import com.yahoo.jrt.Request; import com.yahoo.vespa.config.ConfigKey; import com.yahoo.vespa.config.protocol.CompressionType; import com.yahoo.vespa.config.protocol.DefContent; -import com.yahoo.vespa.config.protocol.JRTClientConfigRequestV3; import com.yahoo.vespa.config.protocol.JRTServerConfigRequest; import com.yahoo.vespa.config.protocol.JRTServerConfigRequestV3; import com.yahoo.vespa.config.protocol.Trace; @@ -22,6 +21,7 @@ import java.util.Collections; import java.util.List; import java.util.Optional; +import static com.yahoo.vespa.config.protocol.JRTClientConfigRequestV3.createWithParams; import static org.hamcrest.CoreMatchers.is; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertThat; @@ -41,7 +41,7 @@ public class DelayedConfigResponseTest { MockRpcServer rpc = new MockRpcServer(13337, temporaryFolder.newFolder()); DelayedConfigResponses responses = new DelayedConfigResponses(rpc, 1, false); assertThat(responses.size(), is(0)); - JRTServerConfigRequest req = createRequest("foo", "myid", "mymd5", 3, 1000000, "bar"); + JRTServerConfigRequest req = createRequest("foo", "myid", 3, 1000000, "bar"); req.setDelayedResponse(true); GetConfigContext context = GetConfigContext.testContext(ApplicationId.defaultId()); responses.delayResponse(req, context); @@ -49,7 +49,7 @@ public class DelayedConfigResponseTest { req.setDelayedResponse(false); responses.delayResponse(req, context); - responses.delayResponse(createRequest("foolio", "myid", "mymd5", 3, 100000, "bar"), context); + responses.delayResponse(createRequest("foolio", "myid", 3, 100000, "bar"), context); assertThat(responses.size(), is(2)); assertTrue(req.isDelayedResponse()); List<DelayedConfigResponses.DelayedConfigResponse> it = responses.allDelayedResponses(); @@ -61,7 +61,7 @@ public class DelayedConfigResponseTest { GetConfigContext context = GetConfigContext.testContext(ApplicationId.defaultId()); MockRpcServer rpc = new MockRpcServer(13337, temporaryFolder.newFolder()); DelayedConfigResponses responses = new DelayedConfigResponses(rpc, 1, false); - responses.delayResponse(createRequest("foolio", "myid", "mymd5", 3, 100000, "bar"), context); + responses.delayResponse(createRequest("foolio", "myid", 3, 100000, "bar"), context); assertThat(responses.size(), is(1)); responses.allDelayedResponses().get(0).cancelAndRemove(); assertThat(responses.size(), is(0)); @@ -73,17 +73,18 @@ public class DelayedConfigResponseTest { DelayedConfigResponses responses = new DelayedConfigResponses(rpc, 1, false); assertThat(responses.size(), is(0)); assertThat(responses.toString(), is("DelayedConfigResponses. Average Size=0")); - JRTServerConfigRequest req = createRequest("foo", "myid", "mymd5", 3, 100, "bar"); + JRTServerConfigRequest req = createRequest("foo", "myid", 3, 100, "bar"); responses.delayResponse(req, GetConfigContext.testContext(ApplicationId.defaultId())); rpc.waitUntilSet(Duration.ofSeconds(5)); assertThat(rpc.latestRequest, is(req)); } - private JRTServerConfigRequest createRequest(String configName, String configId, String md5, long generation, long timeout, String namespace) { - Request request = JRTClientConfigRequestV3. - createWithParams(new ConfigKey<>(configName, configId, namespace, null), DefContent.fromList(Collections.emptyList()), - "fromHost", md5, generation, timeout, Trace.createDummy(), CompressionType.UNCOMPRESSED, - Optional.empty()).getRequest(); + private JRTServerConfigRequest createRequest(String configName, String configId, long generation, long timeout, String namespace) { + Request request = createWithParams(new ConfigKey<>(configName, configId, namespace, null), + DefContent.fromList(Collections.emptyList()), "fromHost", + PayloadChecksums.empty(), generation, timeout, Trace.createDummy(), + CompressionType.UNCOMPRESSED, Optional.empty()) + .getRequest(); return JRTServerConfigRequestV3.createFromRequest(request); } |