diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-12-08 20:01:44 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-12-08 20:01:44 +0100 |
commit | 16007bba76addf4a077cb5409b3ac8adaa99de71 (patch) | |
tree | 35086eafb7abbc7ca98a5de175554d3fb403b57b /configserver/src | |
parent | f17e602d96701f81e405e3b740c65df95365e9ca (diff) |
Let transfer method be config until it works fine.
Diffstat (limited to 'configserver/src')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java | 7 |
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); } } |