diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-08-29 12:03:58 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2019-08-29 12:03:58 +0200 |
commit | 6091a2d01ec7af29b4df34c6a6609913f299d11b (patch) | |
tree | 86787200176c68067d0144a60434fd2206b9b003 /container-disc | |
parent | ef6f3a83ca9f64a7ac76ad4a7dc060325aa3f97e (diff) |
Remove unused code
Diffstat (limited to 'container-disc')
-rw-r--r-- | container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java | 25 | ||||
-rw-r--r-- | container-disc/src/main/java/com/yahoo/container/jdisc/ContainerDiscApplication.java | 30 |
2 files changed, 7 insertions, 48 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 c57149748e7..da4709a9ba3 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 @@ -76,7 +76,6 @@ public final class ConfiguredApplication implements Application { private final SubscriberFactory subscriberFactory; private final ContainerActivator activator; private final String configId; - private final ContainerDiscApplication applicationWithLegacySetup; private final OsgiFramework osgiFramework; private final com.yahoo.jdisc.Timer timerSingleton; @@ -118,15 +117,13 @@ public final class ConfiguredApplication implements Application { public ConfiguredApplication(ContainerActivator activator, OsgiFramework osgiFramework, com.yahoo.jdisc.Timer timer, - SubscriberFactory subscriberFactory) throws ListenFailedException { + SubscriberFactory subscriberFactory) { this.activator = activator; this.osgiFramework = osgiFramework; this.timerSingleton = timer; this.subscriberFactory = subscriberFactory; this.configId = System.getProperty("config.id"); this.restrictedOsgiFramework = new DisableOsgiFramework(new RestrictedBundleContext(osgiFramework.bundleContext())); - - applicationWithLegacySetup = new ContainerDiscApplication(configId); } @Override @@ -139,7 +136,7 @@ public final class ConfiguredApplication implements Application { ContainerBuilder builder = createBuilderWithGuiceBindings(); configurer = createConfigurer(builder.guiceModules().activate()); - intitializeAndActivateContainer(builder); + initializeAndActivateContainer(builder); startReconfigurerThread(); portWatcher = new Thread(this::watchPortChange); portWatcher.setDaemon(true); @@ -183,7 +180,6 @@ public final class ConfiguredApplication implements Application { supervisor.transport().shutdown().join(); } - @SuppressWarnings("deprecation") private static void hackToInitializeServer(QrConfig config) { try { Container.get().setupFileAcquirer(config.filedistributor()); @@ -224,7 +220,7 @@ public final class ConfiguredApplication implements Application { } } - private void intitializeAndActivateContainer(ContainerBuilder builder) { + private void initializeAndActivateContainer(ContainerBuilder builder) { addHandlerBindings(builder, Container.get().getRequestHandlerRegistry(), configurer.getComponent(ApplicationContext.class).discBindingsConfig); installServerProviders(builder); @@ -252,7 +248,7 @@ public final class ConfiguredApplication implements Application { // Block until new config arrives, and it should be applied configurer.getNewComponentGraph(builder.guiceModules().activate(), qrConfig.restartOnDeploy()); - intitializeAndActivateContainer(builder); + initializeAndActivateContainer(builder); } catch (ConfigInterruptedException e) { break; } catch (Exception | LinkageError e) { // LinkageError: OSGi problems @@ -325,7 +321,6 @@ public final class ConfiguredApplication implements Application { bind(FilterChainRepository.class).toInstance(defaultFilterChainRepository); } }); - modules.install(applicationWithLegacySetup.getMbusBindings()); } @Override @@ -376,15 +371,9 @@ public final class ConfiguredApplication implements Application { shutdownDeadlineExecutor = new ScheduledThreadPoolExecutor(1, new DaemonThreadFactory("Shutdown deadline timer")); shutdownDeadlineExecutor.setExecuteExistingDelayedTasksAfterShutdownPolicy(false); long delayMillis = 50 * 1000; - shutdownDeadlineExecutor.schedule(new Runnable() { - - @Override - public void run() { - com.yahoo.protect.Process.logAndDie( - "Timed out waiting for application shutdown. Please check that all your request handlers " + - "drain their request content channels.", true); - } - }, delayMillis, TimeUnit.MILLISECONDS); + shutdownDeadlineExecutor.schedule(() -> com.yahoo.protect.Process.logAndDie( + "Timed out waiting for application shutdown. Please check that all your request handlers " + + "drain their request content channels.", true), delayMillis, TimeUnit.MILLISECONDS); } private static void addHandlerBindings(ContainerBuilder builder, diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/ContainerDiscApplication.java b/container-disc/src/main/java/com/yahoo/container/jdisc/ContainerDiscApplication.java deleted file mode 100644 index 0d2224f8c1c..00000000000 --- a/container-disc/src/main/java/com/yahoo/container/jdisc/ContainerDiscApplication.java +++ /dev/null @@ -1,30 +0,0 @@ -// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package com.yahoo.container.jdisc; - -import com.google.inject.AbstractModule; -import com.google.inject.Inject; -import com.yahoo.container.jdisc.messagebus.SessionCache; -import com.yahoo.jrt.ListenFailedException; - -/** - * TODO: The contents of this class can probably be moved into ConfiguredApplication - */ -public class ContainerDiscApplication { - - private SessionCache sessionCache; - - @Inject - public ContainerDiscApplication(String configId) throws ListenFailedException { - sessionCache = new SessionCache(configId); - } - - AbstractModule getMbusBindings() { - return new AbstractModule() { - @Override - protected void configure() { - bind(SessionCache.class).toInstance(sessionCache); - } - }; - } - -} |