Skip to content

Commit ba9529a

Browse files
authored
Mninor naming fixes (#1425)
1 parent 95d25fe commit ba9529a

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ private void submitReconciliationExecution(ResourceState state) {
160160
state.unMarkEventReceived();
161161
metrics.reconcileCustomResource(state.getId(), state.getRetry(), metricsMetadata);
162162
log.debug("Executing events for custom resource. Scope: {}", executionScope);
163-
executor.execute(new ControllerExecution(executionScope));
163+
executor.execute(new ReconcilerExecutor(executionScope));
164164
} else {
165165
log.debug(
166166
"Skipping executing controller for resource id: {}. Controller in execution: {}. Latest Resource present: {}",
@@ -376,10 +376,10 @@ private void handleAlreadyMarkedEvents() {
376376
}
377377
}
378378

379-
private class ControllerExecution implements Runnable {
379+
private class ReconcilerExecutor implements Runnable {
380380
private final ExecutionScope<R> executionScope;
381381

382-
private ControllerExecution(ExecutionScope<R> executionScope) {
382+
private ReconcilerExecutor(ExecutionScope<R> executionScope) {
383383
this.executionScope = executionScope;
384384
}
385385

@@ -390,7 +390,7 @@ public void run() {
390390
final var name = thread.getName();
391391
try {
392392
MDCUtils.addResourceInfo(executionScope.getResource());
393-
thread.setName("EventHandler-" + controllerName);
393+
thread.setName("ReconcilerExecutor-" + controllerName + "-" + thread.getId());
394394
PostExecutionControl<R> postExecutionControl =
395395
reconciliationDispatcher.handleExecution(executionScope);
396396
eventProcessingFinished(executionScope, postExecutionControl);

operator-framework/src/test/java/io/javaoperatorsdk/operator/ControllerExecutionIT.java renamed to operator-framework/src/test/java/io/javaoperatorsdk/operator/ReconcilerExecutorIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
import static org.assertj.core.api.Assertions.assertThat;
1616
import static org.awaitility.Awaitility.await;
1717

18-
class ControllerExecutionIT {
18+
class ReconcilerExecutorIT {
1919

2020
@RegisterExtension
2121
LocallyRunOperatorExtension operator =

0 commit comments

Comments
 (0)