diff options
author | jonmv <venstad@gmail.com> | 2023-10-11 19:45:29 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-10-11 19:45:29 +0200 |
commit | 7584971f259e6aef476aa2e596b4cbce4a3559d5 (patch) | |
tree | 324e16009429b1f1b94f0e055b3868265089c427 /container-disc | |
parent | 57deef966539acdd3c96b52701fb29cf9062f6e0 (diff) |
Silly hack to close HTTP server before mbus server
Diffstat (limited to 'container-disc')
-rw-r--r-- | container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java | 30 |
1 files changed, 26 insertions, 4 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 dca83e8e556..ab32c7683ed 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 @@ -29,6 +29,7 @@ import com.yahoo.jdisc.application.DeactivatedContainer; import com.yahoo.jdisc.application.GuiceRepository; import com.yahoo.jdisc.application.OsgiFramework; import com.yahoo.jdisc.handler.RequestHandler; +import com.yahoo.jdisc.http.server.jetty.JettyHttpServer; import com.yahoo.jdisc.service.ClientProvider; import com.yahoo.jdisc.service.ServerProvider; import com.yahoo.jrt.Acceptor; @@ -41,6 +42,7 @@ import com.yahoo.jrt.Supervisor; import com.yahoo.jrt.Transport; import com.yahoo.jrt.slobrok.api.Register; import com.yahoo.jrt.slobrok.api.SlobrokList; +import com.yahoo.messagebus.jdisc.MbusServer; import com.yahoo.messagebus.network.rpc.SlobrokConfigSubscriber; import com.yahoo.net.HostName; import com.yahoo.security.tls.Capability; @@ -53,8 +55,12 @@ import java.security.Provider; import java.security.Security; import java.time.Duration; import java.time.Instant; +import java.util.ArrayDeque; +import java.util.ArrayList; import java.util.Collection; import java.util.Collections; +import java.util.Comparator; +import java.util.Deque; import java.util.IdentityHashMap; import java.util.List; import java.util.Map; @@ -377,20 +383,20 @@ public final class ConfiguredApplication implements Application { synchronized (monitor) { Set<ServerProvider> serversToClose = createIdentityHashSet(startedServers); serversToClose.removeAll(currentServers); - for (ServerProvider server : currentServers) { + for (ServerProvider server : ordered(currentServers, MbusServer.class, JettyHttpServer.class)) { if ( ! startedServers.contains(server) && server.isMultiplexed()) { server.start(); startedServers.add(server); } } - if (serversToClose.size() > 0) { + if ( ! serversToClose.isEmpty()) { log.info(String.format("Closing %d server instances", serversToClose.size())); - for (ServerProvider server : serversToClose) { + for (ServerProvider server : ordered(serversToClose, JettyHttpServer.class, MbusServer.class)) { server.close(); startedServers.remove(server); } } - for (ServerProvider server : currentServers) { + for (ServerProvider server : ordered(currentServers, MbusServer.class, JettyHttpServer.class)) { if ( ! startedServers.contains(server)) { server.start(); startedServers.add(server); @@ -525,6 +531,22 @@ public final class ConfiguredApplication implements Application { } } + /** Returns a list with the given elements, ordered by the enumerated classes, ordering more specific matches first. */ + @SafeVarargs + static <T> List<T> ordered(Collection<T> items, Class<? extends T>... order) { + List<T> ordered = new ArrayList<>(items); + ordered.sort(Comparator.comparingInt(item -> { + int best = order.length; + for (int i = 0; i < order.length; i++) { + if ( order[i].isInstance(item) + && ( best == order.length + || order[best].isAssignableFrom(order[i]))) best = i; + } + return best; + })); + return ordered; + } + private static <E> Set<E> createIdentityHashSet() { return Collections.newSetFromMap(new IdentityHashMap<>()); } |