aboutsummaryrefslogtreecommitdiffstats
path: root/configserver/src
diff options
context:
space:
mode:
authorGeir Storli <geirst@verizonmedia.com>2021-11-18 08:56:39 +0000
committerGeir Storli <geirst@verizonmedia.com>2021-11-18 08:56:39 +0000
commit357eef19d892c33e3e83b4c51cf9985444633848 (patch)
treebab9c19970fc3c84ad836b473f48dab85da8ab46 /configserver/src
parent171a0b36e060cdb59c5974a4bc2c723e3b09e0f8 (diff)
Add feature flag for "feed-master-task-limit".
Diffstat (limited to 'configserver/src')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java3
1 files changed, 3 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java
index 3630215913e..ea823e5befb 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java
@@ -168,6 +168,7 @@ public class ModelContextImpl implements ModelContext {
private final boolean useThreePhaseUpdates;
private final String feedSequencer;
private final int feedTaskLimit;
+ private final int feedMasterTaskLimit;
private final String sharedFieldWriterExecutor;
private final String responseSequencer;
private final int numResponseThreads;
@@ -205,6 +206,7 @@ public class ModelContextImpl implements ModelContext {
this.useThreePhaseUpdates = flagValue(source, appId, Flags.USE_THREE_PHASE_UPDATES);
this.feedSequencer = flagValue(source, appId, Flags.FEED_SEQUENCER_TYPE);
this.feedTaskLimit = flagValue(source, appId, Flags.FEED_TASK_LIMIT);
+ this.feedMasterTaskLimit = flagValue(source, appId, Flags.FEED_MASTER_TASK_LIMIT);
this.sharedFieldWriterExecutor = flagValue(source, appId, Flags.SHARED_FIELD_WRITER_EXECUTOR);
this.responseSequencer = flagValue(source, appId, Flags.RESPONSE_SEQUENCER_TYPE);
this.numResponseThreads = flagValue(source, appId, Flags.RESPONSE_NUM_THREADS);
@@ -242,6 +244,7 @@ public class ModelContextImpl implements ModelContext {
@Override public boolean useThreePhaseUpdates() { return useThreePhaseUpdates; }
@Override public String feedSequencerType() { return feedSequencer; }
@Override public int feedTaskLimit() { return feedTaskLimit; }
+ @Override public int feedMasterTaskLimit() { return feedMasterTaskLimit; }
@Override public String sharedFieldWriterExecutor() { return sharedFieldWriterExecutor; }
@Override public String responseSequencerType() { return responseSequencer; }
@Override public int defaultNumResponseThreads() { return numResponseThreads; }