Correct logic

Author: rjeberhard

operator/src/main/java/oracle/kubernetes/operator/Watcher.java

@@ -122,14 +122,16 @@ protected boolean isStopping() {
 
   private void watchForEvents() {
     long now = System.currentTimeMillis();
-    long delta = now - lastInitialize;
-    if (lastInitialize != 0 && delta > (tuning.watchMinimumDelay * 1000)) {
+    long delay = (tuning.watchMinimumDelay * 1000) - (now - lastInitialize);
+    if (lastInitialize != 0 && delay > 0) {
       try {
-        Thread.sleep(delta);
+        Thread.sleep(delay);
       } catch (InterruptedException ex) {
         LOGGER.warning(MessageKeys.EXCEPTION, ex);
       }
       lastInitialize = System.currentTimeMillis();
+    } else {
+      lastInitialize = now;
     }
     try (WatchI<T> watch =
         initiateWatch(

operator/src/test/java/oracle/kubernetes/operator/WatcherTestBase.java

@@ -41,7 +41,7 @@ public abstract class WatcherTestBase extends ThreadFactoryTestBase
 
   private int resourceVersion = INITIAL_RESOURCE_VERSION;
 
-  protected WatchTuning tuning = new WatchTuning(30, 5);
+  protected WatchTuning tuning = new WatchTuning(30, 0);
 
   private V1ObjectMeta createMetaData() {
     return createMetaData("test", NAMESPACE);

operator/src/test/java/oracle/kubernetes/operator/helpers/DomainIntrospectorJobTest.java

@@ -290,7 +290,7 @@ static String getJobName() {
   }
 
   FiberTestSupport.StepFactory getStepFactory() {
-    return next -> JobHelper.createDomainIntrospectorJobStep(new WatchTuning(30, 5), next);
+    return next -> JobHelper.createDomainIntrospectorJobStep(new WatchTuning(30, 0), next);
   }
 
   V1PodList createListPods() {