Control num response threads with flag

1 files changed, 8 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 dfc71c7fd9f..fa7a107f953 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
@@ -154,6 +154,7 @@ public class ModelContextImpl implements ModelContext {
         private final double defaultSoftStartSeconds;
         private final double threadPoolSizeFactor;
         private final double queueSizefactor;
+        private final int defaultNumResponseThreads;
         private final Optional<AthenzDomain> athenzDomain;
 
         public Properties(ApplicationId applicationId,
@@ -198,6 +199,8 @@ public class ModelContextImpl implements ModelContext {
                     .with(FetchVector.Dimension.APPLICATION_ID, applicationId.serializedForm()).value();
             queueSizefactor = Flags.DEFAULT_QUEUE_SIZE_FACTOR.bindTo(flagSource)
                     .with(FetchVector.Dimension.APPLICATION_ID, applicationId.serializedForm()).value();
+            defaultNumResponseThreads = Flags.DEFAULT_NUM_RESPONSE_THREADS.bindTo(flagSource)
+                    .with(FetchVector.Dimension.APPLICATION_ID, applicationId.serializedForm()).value();
             this.athenzDomain = athenzDomain;
         }
 
@@ -277,6 +280,11 @@ public class ModelContextImpl implements ModelContext {
         }
 
         @Override
+        public int defaultNumResponseThreads() {
+            return defaultNumResponseThreads;
+        }
+
+        @Override
         public Optional<AthenzDomain> athenzDomain() { return athenzDomain; }
 
     }