diff options
author | Harald Musum <musum@yahooinc.com> | 2022-09-05 13:17:55 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-09-05 13:17:55 +0200 |
commit | 5a120fb3c2bf05416b39b8e214757c7b82dca32b (patch) | |
tree | 34f448ac341516147a0cfb68b3464999816457a9 /configserver/src/main/java/com | |
parent | 8efe91bfb05d060d38ae0cf75faa2d07756492d9 (diff) |
Use feature flag CLUSTER_CONTROLLER_STATE_GATHER_COUNT
Diffstat (limited to 'configserver/src/main/java/com')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java | 15 |
1 files changed, 9 insertions, 6 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 48450716131..683244e5e2f 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 @@ -217,12 +217,13 @@ public class ModelContextImpl implements ModelContext { private final boolean mbus_dispatch_on_encode; private final int mbus_threads; private final int mbus_network_threads; - private int mbus_java_num_targets; - private int mbus_java_events_before_wakeup; - private int mbus_cpp_num_targets; - private int mbus_cpp_events_before_wakeup; - private int rpc_num_targets; - private int rpc_events_before_wakeup; + private final int mbus_java_num_targets; + private final int mbus_java_events_before_wakeup; + private final int mbus_cpp_num_targets; + private final int mbus_cpp_events_before_wakeup; + private final int rpc_num_targets; + private final int rpc_events_before_wakeup; + private final int clusterControllerStateGatherCount; public FeatureFlags(FlagSource source, ApplicationId appId, Version version) { this.defaultTermwiseLimit = flagValue(source, appId, version, Flags.DEFAULT_TERM_WISE_LIMIT); @@ -282,6 +283,7 @@ public class ModelContextImpl implements ModelContext { this.rpc_events_before_wakeup = flagValue(source, appId, version, Flags.RPC_EVENTS_BEFORE_WAKEUP); this.queryDispatchPolicy = flagValue(source, appId, version, Flags.QUERY_DISPATCH_POLICY); this.phraseOptimization = flagValue(source, appId, version, Flags.PHRASE_OPTIMIZATION); + this.clusterControllerStateGatherCount = flagValue(source, appId, version, Flags.CLUSTER_CONTROLLER_STATE_GATHER_COUNT); } @Override public String queryDispatchPolicy() { return queryDispatchPolicy; } @@ -349,6 +351,7 @@ public class ModelContextImpl implements ModelContext { return defVal; } @Override public boolean useTwoPhaseDocumentGc() { return useTwoPhaseDocumentGc; } + @Override public int clusterControllerStateGatherCount() { return clusterControllerStateGatherCount; } private static <V> V flagValue(FlagSource source, ApplicationId appId, Version vespaVersion, UnboundFlag<? extends V, ?, ?> flag) { return flag.bindTo(source) |