From 397d716cf77cdfc30bab14a7676ed8d92f41df31 Mon Sep 17 00:00:00 2001 From: Slimane AMAR Date: Fri, 3 Jan 2025 15:54:11 +0100 Subject: [PATCH] Review Signed-off-by: Slimane AMAR --- pom.xml | 9 ++------- .../modifications/NetworkModificationApplicator.java | 6 +++--- ...ava => LargeNetworkModificationExecutionService.java} | 6 +++--- .../modification/server/VoltageInitReportTest.java | 4 ++-- 4 files changed, 10 insertions(+), 15 deletions(-) rename src/main/java/org/gridsuite/modification/server/service/{NetworkModificationExecutionService.java => LargeNetworkModificationExecutionService.java} (79%) diff --git a/pom.xml b/pom.xml index de072efeb..509977f48 100644 --- a/pom.xml +++ b/pom.xml @@ -175,8 +175,8 @@ spring-cloud-stream - io.micrometer - micrometer-core + org.springframework.boot + spring-boot-starter-actuator @@ -192,11 +192,6 @@ powsybl-config-classic runtime - - org.springframework.boot - spring-boot-starter-actuator - runtime - io.micrometer micrometer-registry-prometheus diff --git a/src/main/java/org/gridsuite/modification/server/modifications/NetworkModificationApplicator.java b/src/main/java/org/gridsuite/modification/server/modifications/NetworkModificationApplicator.java index 7733b2dfc..8b0d8df8a 100644 --- a/src/main/java/org/gridsuite/modification/server/modifications/NetworkModificationApplicator.java +++ b/src/main/java/org/gridsuite/modification/server/modifications/NetworkModificationApplicator.java @@ -28,7 +28,7 @@ import org.gridsuite.modification.server.elasticsearch.EquipmentInfosService; import org.gridsuite.modification.server.impacts.AbstractBaseImpact; import org.gridsuite.modification.server.service.FilterService; -import org.gridsuite.modification.server.service.NetworkModificationExecutionService; +import org.gridsuite.modification.server.service.LargeNetworkModificationExecutionService; import org.gridsuite.modification.server.service.NetworkModificationObserver; import org.gridsuite.modification.server.service.ReportService; import org.slf4j.Logger; @@ -54,7 +54,7 @@ public class NetworkModificationApplicator { @Getter private final FilterService filterService; - private final NetworkModificationExecutionService modificationExecutionService; + private final LargeNetworkModificationExecutionService modificationExecutionService; private final NetworkModificationObserver networkModificationObserver; @@ -65,7 +65,7 @@ public class NetworkModificationApplicator { public NetworkModificationApplicator(NetworkStoreService networkStoreService, EquipmentInfosService equipmentInfosService, ReportService reportService, FilterService filterService, NetworkModificationObserver networkModificationObserver, - NetworkModificationExecutionService modificationExecutionService) { + LargeNetworkModificationExecutionService modificationExecutionService) { this.networkStoreService = networkStoreService; this.equipmentInfosService = equipmentInfosService; this.reportService = reportService; diff --git a/src/main/java/org/gridsuite/modification/server/service/NetworkModificationExecutionService.java b/src/main/java/org/gridsuite/modification/server/service/LargeNetworkModificationExecutionService.java similarity index 79% rename from src/main/java/org/gridsuite/modification/server/service/NetworkModificationExecutionService.java rename to src/main/java/org/gridsuite/modification/server/service/LargeNetworkModificationExecutionService.java index 18af9686f..27211d2d4 100644 --- a/src/main/java/org/gridsuite/modification/server/service/NetworkModificationExecutionService.java +++ b/src/main/java/org/gridsuite/modification/server/service/LargeNetworkModificationExecutionService.java @@ -21,12 +21,12 @@ * @author Slimane Amar */ @Service -public class NetworkModificationExecutionService { +public class LargeNetworkModificationExecutionService { private ThreadPoolExecutor executorService; - public NetworkModificationExecutionService(@Value("${max-large-concurrent-applications}") int maxConcurrentLargeModifications, - @NonNull NetworkModificationObserver networkModificationObserver) { + public LargeNetworkModificationExecutionService(@Value("${max-large-concurrent-applications}") int maxConcurrentLargeModifications, + @NonNull NetworkModificationObserver networkModificationObserver) { executorService = (ThreadPoolExecutor) Executors.newFixedThreadPool(maxConcurrentLargeModifications); networkModificationObserver.createThreadPoolMetric(executorService); } diff --git a/src/test/java/org/gridsuite/modification/server/VoltageInitReportTest.java b/src/test/java/org/gridsuite/modification/server/VoltageInitReportTest.java index 55df456f8..dbbec9625 100644 --- a/src/test/java/org/gridsuite/modification/server/VoltageInitReportTest.java +++ b/src/test/java/org/gridsuite/modification/server/VoltageInitReportTest.java @@ -29,7 +29,7 @@ import org.gridsuite.modification.server.dto.NetworkModificationResult.ApplicationStatus; import org.gridsuite.modification.server.elasticsearch.EquipmentInfosService; import org.gridsuite.modification.server.modifications.NetworkModificationApplicator; -import org.gridsuite.modification.server.service.NetworkModificationExecutionService; +import org.gridsuite.modification.server.service.LargeNetworkModificationExecutionService; import org.gridsuite.modification.server.service.NetworkModificationObserver; import org.gridsuite.modification.server.service.ReportService; import org.junit.jupiter.api.DisplayName; @@ -70,7 +70,7 @@ void testVoltageInitDuplicationLogs(final ApplicationStatus resultStatus, final (restClient_, preloadingStrategy, executorService) -> new CachedNetworkStoreClient(new OfflineNetworkStoreClient())); final EquipmentInfosService equipmentInfosService = Mockito.mock(EquipmentInfosService.class); final NetworkModificationObserver networkModificationObserver = new NetworkModificationObserver(ObservationRegistry.NOOP, new SimpleMeterRegistry()); - final NetworkModificationExecutionService modificationExecutionService = new NetworkModificationExecutionService(2, networkModificationObserver); + final LargeNetworkModificationExecutionService modificationExecutionService = new LargeNetworkModificationExecutionService(2, networkModificationObserver); final NetworkModificationApplicator networkModificationApplicator = new NetworkModificationApplicator(networkStoreService, equipmentInfosService, reportService, null, networkModificationObserver, modificationExecutionService); networkModificationApplicator.setCollectionThreshold(5);