diff options
author | Harald Musum <musum@yahooinc.com> | 2022-07-05 09:58:47 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-07-05 09:58:47 +0200 |
commit | 639dc28266e8b2cf08c7f93f19ccc9275888896c (patch) | |
tree | a860fa9f5b4cc26e17ab10ebc0fe30443db40e1c /configserver/src/test/java | |
parent | f2802027f402d5b16f5fffb9cfc5a3d7f7401ab4 (diff) |
Support specifying compression type for file distribution requests
Add accepted compression types in file distribution requests.
Older clients (e.g. Vespa 7.x) will not have that in requests,
so fallback to gzip in that case.
Diffstat (limited to 'configserver/src/test/java')
-rw-r--r-- | configserver/src/test/java/com/yahoo/vespa/config/server/filedistribution/FileServerTest.java | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/configserver/src/test/java/com/yahoo/vespa/config/server/filedistribution/FileServerTest.java b/configserver/src/test/java/com/yahoo/vespa/config/server/filedistribution/FileServerTest.java index 861e6967620..9498db1d1e0 100644 --- a/configserver/src/test/java/com/yahoo/vespa/config/server/filedistribution/FileServerTest.java +++ b/configserver/src/test/java/com/yahoo/vespa/config/server/filedistribution/FileServerTest.java @@ -14,15 +14,17 @@ import org.junit.Before; import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; - import java.io.File; import java.io.IOException; import java.time.Duration; import java.util.ArrayList; import java.util.List; +import java.util.Set; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; +import static com.yahoo.vespa.filedistribution.FileReferenceData.CompressionType.gzip; +import static com.yahoo.vespa.filedistribution.FileReferenceData.CompressionType.lz4; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; @@ -75,8 +77,13 @@ public class FileServerTest { File dir = getFileServerRootDir(); IOUtils.writeFile(dir + "/12y/f1", "dummy-data", true); CompletableFuture<byte []> content = new CompletableFuture<>(); - fileServer.startFileServing(new FileReference("12y"), new FileReceiver(content)); + fileServer.startFileServing(new FileReference("12y"), new FileReceiver(content), Set.of(gzip)); assertEquals(new String(content.get()), "dummy-data"); + + IOUtils.writeFile(dir + "/12z/f1", "dummy-data-2", true); + content = new CompletableFuture<>(); + fileServer.startFileServing(new FileReference("12z"), new FileReceiver(content), Set.of(gzip, lz4)); + assertEquals(new String(content.get()), "dummy-data-2"); } @Test |