Skip to content

Commit d4e9708

Browse files
committed
test
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 95a19ad commit d4e9708

File tree

1 file changed

+3
-6
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer

1 file changed

+3
-6
lines changed

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

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,6 @@ public void onAdd(R newResource) {
129129
resourceType().getSimpleName(),
130130
newResource.getMetadata().getResourceVersion());
131131
}
132-
complementaryPrimaryToSecondaryIndex.cleanupForResource(newResource);
133132
onAddOrUpdate(
134133
Operation.ADD, newResource, null, () -> InformerEventSource.super.onAdd(newResource));
135134
}
@@ -160,7 +159,7 @@ public void onDelete(R resource, boolean b) {
160159
ResourceID.fromResource(resource),
161160
resourceType().getSimpleName());
162161
}
163-
162+
complementaryPrimaryToSecondaryIndex.cleanupForResource(resource);
164163
super.onDelete(resource, b);
165164
if (acceptedByDeleteFilters(resource, b)) {
166165
propagateEvent(resource);
@@ -170,7 +169,7 @@ public void onDelete(R resource, boolean b) {
170169
private synchronized void onAddOrUpdate(
171170
Operation operation, R newObject, R oldObject, Runnable superOnOp) {
172171
var resourceID = ResourceID.fromResource(newObject);
173-
172+
complementaryPrimaryToSecondaryIndex.cleanupForResource(newObject);
174173
if (canSkipEvent(newObject, oldObject, resourceID)) {
175174
log.debug(
176175
"Skipping event propagation for {}, since was a result of a reconcile action. Resource"
@@ -309,9 +308,7 @@ public synchronized void handleRecentResourceCreate(ResourceID resourceID, R res
309308
}
310309

311310
private void handleRecentCreateOrUpdate(Operation operation, R newResource, R oldResource) {
312-
if (operation == Operation.ADD) {
313-
complementaryPrimaryToSecondaryIndex.explicitAdd(newResource);
314-
}
311+
complementaryPrimaryToSecondaryIndex.explicitAdd(newResource);
315312
temporaryResourceCache.putResource(
316313
newResource,
317314
Optional.ofNullable(oldResource)

0 commit comments

Comments
 (0)