wip

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/EventFilterDetails.java

@@ -49,4 +49,8 @@ public Optional<ResourceEvent> getLatestEventAfterLastUpdateEvent(String updated
     }
     return Optional.empty();
   }
+
+  public int getActiveUpdates() {
+    return activeUpdates;
+  }
 }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/ManagedInformerEventSource.java

@@ -93,9 +93,7 @@ public void changeNamespaces(Set<String> namespaces) {
   @SuppressWarnings("unchecked")
   public R eventFilteringUpdateAndCacheResource(R resourceToUpdate, UnaryOperator<R> updateMethod) {
     ResourceID id = ResourceID.fromResource(resourceToUpdate);
-    if (log.isDebugEnabled()) {
-      log.debug("Update and cache: {}", id);
-    }
+    log.debug("Update and cache: {}", id);
     R updatedResource = null;
     try {
       temporaryResourceCache.startEventFilteringModify(id);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java

@@ -87,8 +87,16 @@ public synchronized Optional<ResourceEvent> doneEventFilterModify(
     var ed = activeUpdates.get(resourceID);
     if (ed.decreaseActiveUpdates()) {
       activeUpdates.remove(resourceID);
-      return ed.getLatestEventAfterLastUpdateEvent(updatedResourceVersion);
+      var res = ed.getLatestEventAfterLastUpdateEvent(updatedResourceVersion);
+      log.debug(
+          "Zero active updates for resource id: {}; event after update event: {}; updated resource"
+              + " version: {}",
+          resourceID,
+          res.isPresent(),
+          updatedResourceVersion);
+      return res;
     } else {
+      log.debug("Active updates {} for resource id: {}", ed.getActiveUpdates(), resourceID);
       return Optional.empty();
     }
   }