errorprone :: Interruption (#968)

NationalSecurityAgency · Oct 11, 2024 · d96641b · d96641b
1 parent 1f21daa
commit d96641b
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 0 deletions.
diff --git a/src/main/java/emissary/core/HDMobileAgent.java b/src/main/java/emissary/core/HDMobileAgent.java
@@ -586,6 +586,7 @@ public String getLastPlaceProcessed() {
      * Interrupt the agent's thread Seems a little weird to be public, but there aren't a lot of choices.
      */
     @Override
+    @SuppressWarnings("Interruption")
     public void interrupt() {
         this.thread.interrupt();
     }

diff --git a/src/main/java/emissary/core/MobileAgent.java b/src/main/java/emissary/core/MobileAgent.java
@@ -180,6 +180,7 @@ public void killAgent() {
      * Kill asynchronously
      */
     @Override
+    @SuppressWarnings("Interruption")
     public void killAgentAsync() {
         logger.debug("killAgentAsync called on {}", getName());
         this.timeToQuit = true;

diff --git a/src/main/java/emissary/util/shell/ReadOutputBuffer.java b/src/main/java/emissary/util/shell/ReadOutputBuffer.java
@@ -99,6 +99,7 @@ void runImpl() {
     }
 
     @Override
+    @SuppressWarnings("Interruption")
     public void finish() {
         this.finished = true;
         this.interrupt();

diff --git a/src/main/java/emissary/util/shell/ReadOutputLogger.java b/src/main/java/emissary/util/shell/ReadOutputLogger.java
@@ -51,6 +51,7 @@ void runImpl() {
     }
 
     @Override
+    @SuppressWarnings("Interruption")
     public void finish() {
         this.finished = true;
         this.interrupt();

diff --git a/src/test/java/emissary/core/InterruptibleCharSequenceTest.java b/src/test/java/emissary/core/InterruptibleCharSequenceTest.java
@@ -68,6 +68,7 @@ public Thread tryMatchInThread(final CharSequence input, final String regex, fin
     }
 
     @Test
+    @SuppressWarnings("Interruption")
     void testNoninterruptibleString() throws InterruptedException {
         BlockingQueue<Object> blockingQueue = new LinkedBlockingQueue<>();
         Thread t = tryMatchInThread(INPUT, BACKTRACKER, blockingQueue);
@@ -78,6 +79,7 @@ void testNoninterruptibleString() throws InterruptedException {
     }
 
     @Test
+    @SuppressWarnings("Interruption")
     void testInterruptibleCharSequence() throws InterruptedException {
         long sleepMillis = 32;
         String obnoxiousInput = "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaab";