aboutsummaryrefslogtreecommitdiffstats
path: root/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java
diff options
context:
space:
mode:
Diffstat (limited to 'configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java
index 59c3a54897d..38fa3087f88 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionProvider.java
@@ -12,8 +12,7 @@ import java.util.concurrent.locks.Lock;
/**
* Provides file distribution registry and invoker.
*
- * @author lulf
- * @since 5.1.14
+ * @author Ulf Lilleengen
*/
public class FileDistributionProvider {
@@ -37,18 +36,19 @@ public class FileDistributionProvider {
}
public FileDistributionProvider(File applicationDir, String zooKeepersSpec,
- String applicationId, Lock fileDistributionLock)
- {
+ String applicationId, Lock fileDistributionLock,
+ boolean disableFileDistributor) {
ensureDirExists(FileDistribution.getDefaultFileDBPath());
final FileDistributionManager manager = new FileDistributionManager(
FileDistribution.getDefaultFileDBPath(), applicationDir,
zooKeepersSpec, applicationId, fileDistributionLock);
- this.fileDistribution = new CombinedLegacyDistribution(new FileDBHandler(manager));
+ this.fileDistribution = new CombinedLegacyDistribution(new FileDBHandler(manager), disableFileDistributor);
this.fileRegistry = new CombinedLegacyRegistry(new FileDBRegistry(new ManagerWrapper(manager)),
new FileDBRegistry(new ApplicationFileManager(applicationDir, new FileDirectory())));
}
- public FileDistributionProvider(FileRegistry fileRegistry, FileDistribution fileDistribution) {
+ // For testing only
+ FileDistributionProvider(FileRegistry fileRegistry, FileDistribution fileDistribution) {
this.fileRegistry = fileRegistry;
this.fileDistribution = fileDistribution;
}