summaryrefslogtreecommitdiffstats
path: root/container-disc
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2022-10-10 09:37:06 +0200
committerjonmv <venstad@gmail.com>2022-10-10 09:37:06 +0200
commitbf4cac21aaf3776667cfcb117a4b2f931c875675 (patch)
treeab07766c239bb023fe3b3b1b8fba4c60bcf2bacb /container-disc
parent240a62de8a9b3c93fb9f7031f5e204264d414817 (diff)
Start new mbus servers before stopping old ones
Diffstat (limited to 'container-disc')
-rw-r--r--container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java8
1 files changed, 7 insertions, 1 deletions
diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java
index 7ea91726673..625bd87c2db 100644
--- a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java
+++ b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java
@@ -366,6 +366,12 @@ public final class ConfiguredApplication implements Application {
synchronized (monitor) {
Set<ServerProvider> serversToClose = createIdentityHashSet(startedServers);
serversToClose.removeAll(currentServers);
+ for (ServerProvider server : currentServers) {
+ if ( ! startedServers.contains(server) && server.isMultiplexed()) {
+ server.start();
+ startedServers.add(server);
+ }
+ }
if (serversToClose.size() > 0) {
log.info(String.format("Closing %d server instances", serversToClose.size()));
for (ServerProvider server : serversToClose) {
@@ -374,7 +380,7 @@ public final class ConfiguredApplication implements Application {
}
}
for (ServerProvider server : currentServers) {
- if (!startedServers.contains(server)) {
+ if ( ! startedServers.contains(server)) {
server.start();
startedServers.add(server);
}