[Java] Use SigInt.register.

aeron-io · Dec 16, 2024 · 37ff343 · 37ff343
1 parent 633025e
commit 37ff343
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git a/benchmarks-aeron/src/main/java/uk/co/real_logic/benchmarks/aeron/remote/AeronUtil.java b/benchmarks-aeron/src/main/java/uk/co/real_logic/benchmarks/aeron/remote/AeronUtil.java
@@ -40,13 +40,11 @@
 import org.agrona.concurrent.AtomicBuffer;
 import org.agrona.concurrent.IdleStrategy;
 import org.agrona.concurrent.NanoClock;
-import org.agrona.concurrent.ShutdownSignalBarrier;
+import org.agrona.concurrent.SigInt;
 import org.agrona.concurrent.SystemEpochClock;
 import org.agrona.concurrent.UnsafeBuffer;
 import org.agrona.concurrent.errors.ErrorLogReader;
 import org.agrona.concurrent.status.CountersReader;
-import sun.misc.Signal;
-import sun.misc.SignalHandler;
 import uk.co.real_logic.benchmarks.remote.Configuration;
 
 import java.io.File;
@@ -389,12 +387,7 @@ static int sendMessages(
 
     static void installSignalHandler(final Runnable onSignal)
     {
-        final SignalHandler terminationHandler = signal -> onSignal.run();
-
-        for (final String signalName : ShutdownSignalBarrier.SIGNAL_NAMES)
-        {
-            Signal.handle(new Signal(signalName), terminationHandler);
-        }
+        SigInt.register(onSignal);
     }
 
     static void yieldUninterruptedly()

diff --git a/benchmarks-aeron/src/main/java/uk/co/real_logic/benchmarks/aeron/remote/ClusterNode.java b/benchmarks-aeron/src/main/java/uk/co/real_logic/benchmarks/aeron/remote/ClusterNode.java
@@ -128,7 +128,6 @@ public static void main(final String[] args)
         IoUtil.delete(clusterDir, false);
 
         final ShutdownSignalBarrier signalBarrier = new ShutdownSignalBarrier();
-        installSignalHandler(signalBarrier::signal);
 
         try (Archive archive = Archive.launch(archiveContext);
             Component<ConsensusModule> cm = consensusModule.start();