Skip to content

Commit 4e3e7ff

Browse files
committed
fix: removing lock, fix bug
1 parent 8c7f490 commit 4e3e7ff

File tree

1 file changed

+13
-18
lines changed

1 file changed

+13
-18
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

Lines changed: 13 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -111,26 +111,21 @@ public final void registerEventSource(EventSource eventSource)
111111
}
112112

113113
public void broadcastOnResourceEvent(ResourceAction action, R resource, R oldResource) {
114-
lock.lock();
115-
try {
116-
for (EventSource eventSource : this.eventSources) {
117-
if (eventSource instanceof LifecycleAwareEventSource) {
118-
var lifecycleAwareES = ((ResourceEventAware<R>) eventSource);
119-
switch (action) {
120-
case ADDED:
121-
lifecycleAwareES.onResourceCreated(resource);
122-
break;
123-
case UPDATED:
124-
lifecycleAwareES.onResourceUpdated(resource, oldResource);
125-
break;
126-
case DELETED:
127-
lifecycleAwareES.onResourceDeleted(resource);
128-
break;
129-
}
114+
for (EventSource eventSource : this.eventSources) {
115+
if (eventSource instanceof ResourceEventAware) {
116+
var lifecycleAwareES = ((ResourceEventAware<R>) eventSource);
117+
switch (action) {
118+
case ADDED:
119+
lifecycleAwareES.onResourceCreated(resource);
120+
break;
121+
case UPDATED:
122+
lifecycleAwareES.onResourceUpdated(resource, oldResource);
123+
break;
124+
case DELETED:
125+
lifecycleAwareES.onResourceDeleted(resource);
126+
break;
130127
}
131128
}
132-
} finally {
133-
lock.unlock();
134129
}
135130
}
136131

0 commit comments

Comments
 (0)