summaryrefslogtreecommitdiffstats
path: root/vespajlib
diff options
context:
space:
mode:
authorHÃ¥kon Hallingstad <hakon@oath.com>2019-02-01 16:39:20 +0100
committerGitHub <noreply@github.com>2019-02-01 16:39:20 +0100
commitcc7f508288a991a8580bfdff86b4d2f408cc9c29 (patch)
tree2fa75c7b3f1dd899769c6598c3f00fe28b3df36f /vespajlib
parent809e726cb714fd357eec4de4553e0b5d331423ba (diff)
parent1e8a2974fc3e7b756c966eda3cc3d94efd850f64 (diff)
Merge pull request #8247 from vespa-engine/hakonhall/terminate-standalone-container-cleanly-on-sigintcontrol-c
Terminate standalone container cleanly on SIGINT/control-C
Diffstat (limited to 'vespajlib')
-rw-r--r--vespajlib/src/main/java/com/yahoo/system/CatchSigTerm.java70
-rw-r--r--vespajlib/src/test/java/com/yahoo/system/CatchSigTermTestCase.java18
2 files changed, 0 insertions, 88 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/system/CatchSigTerm.java b/vespajlib/src/main/java/com/yahoo/system/CatchSigTerm.java
deleted file mode 100644
index e1f037f5d98..00000000000
--- a/vespajlib/src/main/java/com/yahoo/system/CatchSigTerm.java
+++ /dev/null
@@ -1,70 +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.system;
-
-import java.lang.reflect.*;
-
-// import sun.misc.Signal;
-// import sun.misc.SignalHandler;
-
-import java.util.concurrent.atomic.AtomicBoolean;
-
-public class CatchSigTerm {
- /**
- * Sets up a signal handler for SIGTERM, where a given AtomicBoolean
- * gets a true value when the TERM signal is caught.
- *
- * Callers basically have two options for acting on the TERM signal:
- *
- * They may choose to synchronize and wait() on this variable,
- * and they will be notified when it changes state to true. To avoid
- * problems with spurious wakeups, use a while loop and wait()
- * again if the state is still false. As soon as the caller has been
- * woken up and the state is true, the application should exit as
- * soon as possible.
- *
- * They may also choose to poll the state of this variable. As soon
- * as its state becomes true, the signal has been received, and the
- * application should exit as soon as possible.
- *
- * @param signalCaught set to false initially, will be set to true when SIGTERM is caught.
- */
- @SuppressWarnings("rawtypes")
- public static void setup(final AtomicBoolean signalCaught) {
- signalCaught.set(false);
- try {
- Class shc = Class.forName("sun.misc.SignalHandler");
- Class ssc = Class.forName("sun.misc.Signal");
-
- InvocationHandler ihandler = new InvocationHandler() {
- public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
- synchronized (signalCaught) {
- signalCaught.set(true);
- signalCaught.notifyAll();
- }
- return null;
- }
- };
- Object shandler = Proxy.newProxyInstance(CatchSigTerm.class.getClassLoader(),
- new Class[] { shc },
- ihandler);
- Constructor[] c = ssc.getDeclaredConstructors();
- assert c.length == 1;
- Object sigterm = c[0].newInstance("TERM");
- Method m = findMethod(ssc, "handle");
- assert m != null; // "NoSuchMethodException"
- m.invoke(null, sigterm, shandler);
- } catch (ClassNotFoundException | InvocationTargetException | InstantiationException | IllegalAccessException e) {
- System.err.println("FAILED setting up signal catching: "+e);
- }
- }
-
- @SuppressWarnings("rawtypes")
- private static Method findMethod(Class c, String name) {
- for (Method m : c.getDeclaredMethods()) {
- if (m.getName().equals(name)) {
- return m;
- }
- }
- return null;
- }
-}
diff --git a/vespajlib/src/test/java/com/yahoo/system/CatchSigTermTestCase.java b/vespajlib/src/test/java/com/yahoo/system/CatchSigTermTestCase.java
deleted file mode 100644
index 9b370d4ce10..00000000000
--- a/vespajlib/src/test/java/com/yahoo/system/CatchSigTermTestCase.java
+++ /dev/null
@@ -1,18 +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.system;
-
-import org.junit.Test;
-
-import java.util.concurrent.atomic.AtomicBoolean;
-
-/**
- * @author arnej27959
- */
-public class CatchSigTermTestCase {
-
- @Test
- public void testThatSetupCompiles() {
- CatchSigTerm.setup(new AtomicBoolean(false));
- }
-
-}