slukyano commented on code in PR #5315:
URL: https://github.com/apache/ignite-3/pull/5315#discussion_r1984170999
##########
modules/cluster-management/src/test/java/org/apache/ignite/internal/cluster/management/ClusterInitializerTest.java:
##########
@@ -112,6 +118,59 @@ void testNormalInit() {
assertThat(initFuture, willBe(nullValue(Void.class)));
}
+ @ParameterizedTest
+ @ValueSource(ints = {1, 2, 3, 4, 5, 9}) // Runs the test with 1 to 10
nodes
+ void testInitEmptyMsCmgNodes(int numNodes) {
+ // Create a list of nodes dynamically
+ List<ClusterNode> allNodes = IntStream.rangeClosed(1, numNodes)
+ .mapToObj(i -> (ClusterNode) new ClusterNodeImpl(
+ randomUUID(),
+ "node" + i,
+ new NetworkAddress("foo" + i, 1230 + i)))
+ .collect(Collectors.toList());
+
+ // Mock topology service behavior
+ for (var node : allNodes) {
+
when(topologyService.getByConsistentId(node.name())).thenReturn(node);
+ }
+ when(topologyService.allMembers()).thenReturn(allNodes);
+
+ when(messagingService.invoke(any(ClusterNode.class),
any(CmgInitMessage.class), anyLong()))
+ .thenReturn(initCompleteMessage());
+
+ // Initialize cluster
+ CompletableFuture<Void> initFuture = clusterInitializer.initCluster(
+ List.of(),
+ List.of(),
+ "cluster"
+ );
+
+ // Convert node names to a set for validation
+ var cmgNodeNameSet = allNodes.stream().map(ClusterNode::name).sorted()
Review Comment:
Should be in checkstyle then.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
