Corrects collection loop period (#323)

DataDog · Sep 9, 2020 · d27e516 · d27e516
1 parent 450ffd8
commit d27e516
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/main/java/org/datadog/jmxfetch/App.java b/src/main/java/org/datadog/jmxfetch/App.java
@@ -484,9 +484,15 @@ void start() {
             // Sleep until next collection
             try {
                 long loopPeriod = appConfig.getCheckPeriod();
-                long sleepPeriod = (duration > loopPeriod) ? loopPeriod : loopPeriod - duration;
-                log.debug("Sleeping for " + loopPeriod + " ms.");
-                Thread.sleep(loopPeriod);
+                long sleepPeriod = loopPeriod - duration;
+                if (sleepPeriod <= 0) {
+                    log.debug(
+                        "The collection cycle took longer that the configured check period,"
+                        + " the next cycle will start immediatly");
+                } else {
+                    log.debug("Sleeping for " + sleepPeriod + " ms.");
+                    Thread.sleep(sleepPeriod);    
+                }
             } catch (InterruptedException e) {
                 log.warn(e.getMessage(), e);
             }