Skip to content

Commit

Permalink
Review
Browse files Browse the repository at this point in the history
Signed-off-by: Slimane AMAR <amarsli@gm0winl104.bureau.si.interne>
  • Loading branch information
Slimane AMAR committed Jan 3, 2025
1 parent e687d4b commit 397d716
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 15 deletions.
9 changes: 2 additions & 7 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -175,8 +175,8 @@
<artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-core</artifactId>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

<!-- elasticsearch -->
Expand All @@ -192,11 +192,6 @@
<artifactId>powsybl-config-classic</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-registry-prometheus</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -54,7 +54,7 @@ public class NetworkModificationApplicator {

@Getter private final FilterService filterService;

private final NetworkModificationExecutionService modificationExecutionService;
private final LargeNetworkModificationExecutionService modificationExecutionService;

private final NetworkModificationObserver networkModificationObserver;

Expand All @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,12 +21,12 @@
* @author Slimane Amar <slimane.amar at rte-france.com>
*/
@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);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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);

Expand Down

0 comments on commit 397d716

Please sign in to comment.