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

@@ -32,7 +32,20 @@ public void increaseActiveUpdates() {
     activeUpdates = activeUpdates + 1;
   }
 
-  public boolean decreaseActiveUpdates() {
+  /**
+   * resourceVersion is needed for case when multiple parallel updates happening inside the
+   * controller to prevent race condition and send event from {@link
+   * ManagedInformerEventSource#eventFilteringUpdateAndCacheResource(HasMetadata, UnaryOperator)}
+   */
+  public boolean decreaseActiveUpdates(String updatedResourceVersion) {
+    if (updatedResourceVersion != null
+        && (lastOwnUpdatedResourceVersion == null
+            || ReconcilerUtilsInternal.compareResourceVersions(
+                    updatedResourceVersion, lastOwnUpdatedResourceVersion)
+                > 0)) {
+      lastOwnUpdatedResourceVersion = updatedResourceVersion;
+    }
+
     activeUpdates = activeUpdates - 1;
     return activeUpdates == 0;
   }
@@ -41,23 +54,6 @@ public void setLastEvent(ResourceEvent event) {
     lastEvent = event;
   }
 
-  /**
-   * This is needed for case when multiple parallel updates happening inside the controller to
-   * prevent race condition and send event from {@link
-   * ManagedInformerEventSource#eventFilteringUpdateAndCacheResource(HasMetadata, UnaryOperator)}
-   */
-  public void handleLastOwnUpdatedResourceVersion(String resourceVersion) {
-    if (resourceVersion == null) {
-      return;
-    }
-    if (lastOwnUpdatedResourceVersion == null
-        || ReconcilerUtilsInternal.compareResourceVersions(
-                resourceVersion, lastOwnUpdatedResourceVersion)
-            > 0) {
-      lastOwnUpdatedResourceVersion = resourceVersion;
-    }
-  }
-
   public Optional<ResourceEvent> getLatestEventAfterLastUpdateEvent() {
     if (lastEvent != null
         && (lastOwnUpdatedResourceVersion == null

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

@@ -85,8 +85,7 @@ public synchronized Optional<ResourceEvent> doneEventFilterModify(
       return Optional.empty();
     }
     var ed = activeUpdates.get(resourceID);
-    ed.handleLastOwnUpdatedResourceVersion(updatedResourceVersion);
-    if (ed.decreaseActiveUpdates()) {
+    if (ed.decreaseActiveUpdates(updatedResourceVersion)) {
       activeUpdates.remove(resourceID);
       var res = ed.getLatestEventAfterLastUpdateEvent();
       log.debug(