diff options
author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2023-09-05 12:49:39 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-09-05 12:49:39 +0200 |
commit | 6d783357cf83163a1298372e88020d3d73c25e3c (patch) | |
tree | 459daa166d10f7fe743031e707a32c78f839091e /container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java | |
parent | 2697fbc195ef428210925e4b05223e0ab64405a4 (diff) | |
parent | 05df635cab10d2e312a10e0620a0e6558a4de013 (diff) |
Merge branch 'master' into renovate/junit5-monorepo
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java b/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java index c86c21d677f..2962fd3a3ec 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/ReconfigurableDispatcher.java @@ -1,5 +1,6 @@ package com.yahoo.search.dispatch; +import ai.vespa.cloud.SystemInfo; import com.yahoo.component.ComponentId; import com.yahoo.component.annotation.Inject; import com.yahoo.config.subscription.ConfigSubscriber; @@ -20,12 +21,12 @@ public class ReconfigurableDispatcher extends Dispatcher { private final ConfigSubscriber subscriber; @Inject - public ReconfigurableDispatcher(ComponentId clusterId, DispatchConfig dispatchConfig, QrConfig qrConfig, VipStatus vipStatus) { + public ReconfigurableDispatcher(ComponentId clusterId, DispatchConfig dispatchConfig, SystemInfo systemInfo, VipStatus vipStatus) { super(clusterId, dispatchConfig, new DispatchNodesConfig.Builder().build(), vipStatus); this.subscriber = new ConfigSubscriber(); CountDownLatch configured = new CountDownLatch(1); this.subscriber.subscribe(config -> { updateWithNewConfig(config); configured.countDown(); }, - DispatchNodesConfig.class, configId(clusterId, qrConfig)); + DispatchNodesConfig.class, configId(clusterId, systemInfo)); try { if ( ! configured.await(1, TimeUnit.MINUTES)) throw new IllegalStateException("timed out waiting for initial dispatch nodes config for " + clusterId.getName()); @@ -41,8 +42,8 @@ public class ReconfigurableDispatcher extends Dispatcher { super.deconstruct(); } - private static String configId(ComponentId clusterId, QrConfig qrConfig) { - return qrConfig.clustername() + "/component/" + clusterId.getName(); + private static String configId(ComponentId clusterId, SystemInfo systemInfo) { + return systemInfo.clusterName() + "/component/" + clusterId.getName(); } } |