File tree Expand file tree Collapse file tree 4 files changed +13
-2
lines changed
integrationTest/java/org/apache/ignite/internal/metastorage/impl
testFixtures/java/org/apache/ignite/internal/metastorage/impl Expand file tree Collapse file tree 4 files changed +13
-2
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ micronautPicocli = "4.4.0"
4646micronautJunit5 = " 3.9.2"
4747micronautSecurity =" 3.11.1"
4848micronautReactor =" 2.6.0"
49- mockito = " 5.20 .0"
49+ mockito = " 5.21 .0"
5050picocli = " 4.7.5"
5151slf4j = " 2.0.17"
5252log4j = " 2.25.2"
Original file line number Diff line number Diff line change 2727import static org .apache .ignite .internal .network .utils .ClusterServiceTestUtils .clusterService ;
2828import static org .apache .ignite .internal .testframework .IgniteTestUtils .waitForCondition ;
2929import static org .apache .ignite .internal .testframework .matchers .CompletableFutureMatcher .willCompleteSuccessfully ;
30+ import static org .apache .ignite .internal .util .CompletableFutures .emptySetCompletedFuture ;
3031import static org .apache .ignite .internal .util .IgniteUtils .closeAll ;
3132import static org .apache .ignite .internal .util .IgniteUtils .startAsync ;
3233import static org .apache .ignite .internal .util .IgniteUtils .stopAsync ;
@@ -214,6 +215,8 @@ private static class Node implements AutoCloseable {
214215
215216 var logicalTopologyService = mock (LogicalTopologyService .class );
216217
218+ when (logicalTopologyService .validatedNodesOnLeader ()).thenReturn (emptySetCompletedFuture ());
219+
217220 var topologyAwareRaftGroupServiceFactory = new TopologyAwareRaftGroupServiceFactory (
218221 clusterService ,
219222 logicalTopologyService ,
Original file line number Diff line number Diff line change 3131import static org .apache .ignite .internal .testframework .matchers .CompletableFutureMatcher .willCompleteSuccessfully ;
3232import static org .apache .ignite .internal .testframework .matchers .CompletableFutureMatcher .willSucceedFast ;
3333import static org .apache .ignite .internal .testframework .matchers .CompletableFutureMatcher .willSucceedIn ;
34+ import static org .apache .ignite .internal .util .CompletableFutures .emptySetCompletedFuture ;
3435import static org .apache .ignite .internal .util .CompletableFutures .nullCompletedFuture ;
3536import static org .apache .ignite .internal .util .IgniteUtils .closeAll ;
3637import static org .apache .ignite .internal .util .IgniteUtils .startAsync ;
@@ -177,6 +178,8 @@ void setUp(
177178
178179 var logicalTopologyService = mock (LogicalTopologyService .class );
179180
181+ when (logicalTopologyService .validatedNodesOnLeader ()).thenReturn (emptySetCompletedFuture ());
182+
180183 var topologyAwareRaftGroupServiceFactory = new TopologyAwareRaftGroupServiceFactory (
181184 clusterService ,
182185 logicalTopologyService ,
Original file line number Diff line number Diff line change 1919
2020import static java .util .Collections .singleton ;
2121import static java .util .concurrent .CompletableFuture .completedFuture ;
22+ import static org .apache .ignite .internal .util .CompletableFutures .emptySetCompletedFuture ;
2223import static org .apache .ignite .internal .util .CompletableFutures .nullCompletedFuture ;
2324import static org .mockito .ArgumentMatchers .anyLong ;
2425import static org .mockito .Mockito .any ;
@@ -159,10 +160,14 @@ public static StandaloneMetaStorageManager create(
159160 HybridClock clock ,
160161 ReadOperationForCompactionTracker readOperationForCompactionTracker
161162 ) {
163+ LogicalTopologyService logicalTopologyService = mock (LogicalTopologyService .class );
164+
165+ when (logicalTopologyService .validatedNodesOnLeader ()).thenReturn (emptySetCompletedFuture ());
166+
162167 return new StandaloneMetaStorageManager (
163168 mockClusterService (),
164169 mockClusterGroupManager (),
165- mock ( LogicalTopologyService . class ) ,
170+ logicalTopologyService ,
166171 mockRaftManager (),
167172 keyValueStorage ,
168173 mock (TopologyAwareRaftGroupServiceFactory .class ),
You can’t perform that action at this time.
0 commit comments