Fix #623 issue about observation reset by starting only one cleaningTask

eclipse-leshan · Dec 3, 2018 · 18f0888 · 18f0888
1 parent 3a565f8
commit 18f0888
Showing 1 changed file with 10 additions and 7 deletions.
diff --git a/...n-core-cf/src/main/java/org/eclipse/leshan/core/californium/CoapAsyncRequestObserver.java b/...n-core-cf/src/main/java/org/eclipse/leshan/core/californium/CoapAsyncRequestObserver.java
@@ -104,13 +104,16 @@ public void onSendError(Throwable error) {
 
     private synchronized void scheduleCleaningTask() {
         if (!cancelled)
-            cleaningTask = getExecutor().schedule(new Runnable() {
-                @Override
-                public void run() {
-                    responseTimedOut.set(true);
-                    coapRequest.cancel();
-                }
-            }, timeoutInMs, TimeUnit.MILLISECONDS);
+            if (cleaningTask == null) {
+                LOG.trace("Schedule Cleaning Task for {}", coapRequest);
+                cleaningTask = getExecutor().schedule(new Runnable() {
+                    @Override
+                    public void run() {
+                        responseTimedOut.set(true);
+                        coapRequest.cancel();
+                    }
+                }, timeoutInMs, TimeUnit.MILLISECONDS);
+            }
     }
 
     private synchronized void cancelCleaningTask() {