summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-12-08 20:01:44 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2017-12-08 20:01:44 +0100
commit16007bba76addf4a077cb5409b3ac8adaa99de71 (patch)
tree35086eafb7abbc7ca98a5de175554d3fb403b57b /configserver
parentf17e602d96701f81e405e3b740c65df95365e9ca (diff)
Let transfer method be config until it works fine.
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
index d83d71966c7..15147d522f3 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
@@ -95,6 +95,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
private final FileServer fileServer;
private final ThreadPoolExecutor executorService;
+ private final boolean useChunkedFileTransfer;
private volatile boolean allTenantsLoaded = false;
/**
@@ -120,6 +121,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
this.useRequestVersion = config.useVespaVersionInRequest();
this.hostedVespa = config.hostedVespa();
this.fileServer = fileServer;
+ this.useChunkedFileTransfer = config.usechunkedtransfer();
setUpHandlers();
}
@@ -542,6 +544,9 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
@SuppressWarnings("UnusedDeclaration")
public final void serveFile(Request request) {
request.detach();
- fileServer.serveFile(request, new WholeFileReceiver(request.target()));
+ FileServer.Receiver receiver = useChunkedFileTransfer
+ ? new ChunkedFileReceiver(request.target())
+ : new WholeFileReceiver(request.target());
+ fileServer.serveFile(request, receiver);
}
}