Commit c2023a8c authored by Stephane Nicoll's avatar Stephane Nicoll

Merge pull request #18206 from izeye

* pr/18206:
  Polish "Use Duration for ServerProperties.Jetty.idleTimeout"
  Use Duration for ServerProperties.Jetty.idleTimeout

Closes gh-18206
parents d86c72bf 70f7e470
...@@ -919,7 +919,7 @@ public class ServerProperties { ...@@ -919,7 +919,7 @@ public class ServerProperties {
/** /**
* Maximum thread idle time. * Maximum thread idle time.
*/ */
private Integer idleTimeout = 60000; private Duration idleTimeout = Duration.ofMillis(60000);
public Accesslog getAccesslog() { public Accesslog getAccesslog() {
return this.accesslog; return this.accesslog;
...@@ -965,11 +965,11 @@ public class ServerProperties { ...@@ -965,11 +965,11 @@ public class ServerProperties {
return this.maxThreads; return this.maxThreads;
} }
public void setIdleTimeout(Integer idleTimeout) { public void setIdleTimeout(Duration idleTimeout) {
this.idleTimeout = idleTimeout; this.idleTimeout = idleTimeout;
} }
public Integer getIdleTimeout() { public Duration getIdleTimeout() {
return this.idleTimeout; return this.idleTimeout;
} }
......
...@@ -86,7 +86,7 @@ public class JettyWebServerFactoryCustomizer ...@@ -86,7 +86,7 @@ public class JettyWebServerFactoryCustomizer
.to((maxThreads) -> customizeThreadPool(factory, (threadPool) -> threadPool.setMaxThreads(maxThreads))); .to((maxThreads) -> customizeThreadPool(factory, (threadPool) -> threadPool.setMaxThreads(maxThreads)));
propertyMapper.from(jettyProperties::getMinThreads).when(this::isPositive) propertyMapper.from(jettyProperties::getMinThreads).when(this::isPositive)
.to((minThreads) -> customizeThreadPool(factory, (threadPool) -> threadPool.setMinThreads(minThreads))); .to((minThreads) -> customizeThreadPool(factory, (threadPool) -> threadPool.setMinThreads(minThreads)));
propertyMapper.from(jettyProperties::getIdleTimeout).when(this::isPositive).to( propertyMapper.from(jettyProperties::getIdleTimeout).whenNonNull().asInt(Duration::toMillis).to(
(idleTimeout) -> customizeThreadPool(factory, (threadPool) -> threadPool.setIdleTimeout(idleTimeout))); (idleTimeout) -> customizeThreadPool(factory, (threadPool) -> threadPool.setIdleTimeout(idleTimeout)));
propertyMapper.from(properties::getConnectionTimeout).whenNonNull() propertyMapper.from(properties::getConnectionTimeout).whenNonNull()
.to((connectionTimeout) -> customizeConnectionTimeout(factory, connectionTimeout)); .to((connectionTimeout) -> customizeConnectionTimeout(factory, connectionTimeout));
......
...@@ -233,8 +233,8 @@ class ServerPropertiesTests { ...@@ -233,8 +233,8 @@ class ServerPropertiesTests {
@Test @Test
void testCustomizeJettyIdleTimeout() { void testCustomizeJettyIdleTimeout() {
bind("server.jetty.idle-timeout", "10"); bind("server.jetty.idle-timeout", "10s");
assertThat(this.properties.getJetty().getIdleTimeout()).isEqualTo(10); assertThat(this.properties.getJetty().getIdleTimeout()).isEqualTo(Duration.ofSeconds(10));
} }
@Test @Test
......
...@@ -132,10 +132,10 @@ class JettyWebServerFactoryCustomizerTests { ...@@ -132,10 +132,10 @@ class JettyWebServerFactoryCustomizerTests {
@Test @Test
void idleTimeoutCanBeCustomized() { void idleTimeoutCanBeCustomized() {
bind("server.jetty.idle-timeout=100"); bind("server.jetty.idle-timeout=100s");
JettyWebServer server = customizeAndGetServer(); JettyWebServer server = customizeAndGetServer();
QueuedThreadPool threadPool = (QueuedThreadPool) server.getServer().getThreadPool(); QueuedThreadPool threadPool = (QueuedThreadPool) server.getServer().getThreadPool();
assertThat(threadPool.getIdleTimeout()).isEqualTo(100); assertThat(threadPool.getIdleTimeout()).isEqualTo(100000);
} }
private CustomRequestLog getRequestLog(JettyWebServer server) { private CustomRequestLog getRequestLog(JettyWebServer server) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment