aboutsummaryrefslogtreecommitdiffstats
path: root/configserver/src/test/java
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-07-05 09:58:47 +0200
committerHarald Musum <musum@yahooinc.com>2022-07-05 09:58:47 +0200
commit639dc28266e8b2cf08c7f93f19ccc9275888896c (patch)
treea860fa9f5b4cc26e17ab10ebc0fe30443db40e1c /configserver/src/test/java
parentf2802027f402d5b16f5fffb9cfc5a3d7f7401ab4 (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.java11
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