GH-1374: fix NPE on server.destroy() when queue mode is disabled

eclipse-leshan · Jan 4, 2023 · c1123be · c1123be
1 parent 938e43d
commit c1123be
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 2 deletions.
diff --git a/leshan-server-cf/src/main/java/org/eclipse/leshan/server/californium/LeshanServer.java b/leshan-server-cf/src/main/java/org/eclipse/leshan/server/californium/LeshanServer.java
@@ -404,7 +404,9 @@ public void destroy() {
             ((Stoppable) requestSender).stop();
         }
 
-        presenceService.destroy();
+        if (presenceService != null) {
+            presenceService.destroy();
+        }
 
         LOG.info("LWM2M server destroyed.");
     }

diff --git a/leshan-server-cf/src/test/java/org/eclipse/leshan/server/californium/LeshanServerTest.java b/leshan-server-cf/src/test/java/org/eclipse/leshan/server/californium/LeshanServerTest.java
@@ -80,11 +80,34 @@ public void testStartStopDestroy() throws InterruptedException {
         assertEquals("All news created threads must be destroyed", numberOfThreadbefore, Thread.activeCount());
     }
 
+    @Test
+    public void testStartStopDestroyQueueModeDisabled() throws InterruptedException {
+        // look at nb active thread before.
+        int numberOfThreadbefore = Thread.activeCount();
+
+        LeshanServer server = new LeshanServerBuilder().setLocalAddress(new InetSocketAddress(0))
+                .disableQueueModeSupport().build();
+        server.start();
+        Thread.sleep(100);
+        // HACK force creation thread creation.
+        forceThreadsCreation(server);
+        Thread.sleep(100);
+        server.stop();
+        Thread.sleep(100);
+        server.destroy();
+
+        // ensure all thread are destroyed
+        Thread.sleep(500);
+        assertEquals("All news created threads must be destroyed", numberOfThreadbefore, Thread.activeCount());
+    }
+
     private void forceThreadsCreation(LeshanServer server) {
         Registration reg = new Registration.Builder("id", "endpoint", Identity.unsecure(new InetSocketAddress(5555)))
                 .bindingMode(BindingMode.UQ).build();
         // Force timer thread creation of preference service.
-        ((PresenceServiceImpl) server.getPresenceService()).setAwake(reg);
+        if (server.getPresenceService() != null) {
+            ((PresenceServiceImpl) server.getPresenceService()).setAwake(reg);
+        }
         // Force time thread creation of CoapAsyncRequestObserver
         server.send(reg, new ReadRequest(3), new ResponseCallback<ReadResponse>() {
             @Override