Skip to content

Commit

Permalink
Proposal: Jetty settings. Removing Optional. (#2214)
Browse files Browse the repository at this point in the history
Remove use of Optional for storing Jetty settings

---------

Co-authored-by: Kirill Peshin <kirill.peshin@bscmsc.ru>
  • Loading branch information
pks-1981 and Kirill Peshin committed Jun 14, 2023
1 parent a02ea76 commit f530a59
Show file tree
Hide file tree
Showing 2 changed files with 35 additions and 39 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,26 +18,26 @@
import java.util.Optional;

/**
* Exposed Jetty tuning options. See:
* https://www.eclipse.org/jetty/javadoc/jetty-11/org/eclipse/jetty/server/AbstractConnector.html
* Exposed Jetty tuning options. See: <a
* href="https://www.eclipse.org/jetty/javadoc/jetty-11/org/eclipse/jetty/server/AbstractConnector.html">AbstractConnector</a>
*/
public class JettySettings {
private final Optional<Integer> acceptors;
private final Optional<Integer> acceptQueueSize;
private final Optional<Integer> requestHeaderSize;
private final Optional<Integer> responseHeaderSize;
private final Optional<Long> stopTimeout;
private final Optional<Long> idleTimeout;
private final Optional<Long> shutdownIdleTimeout;
private final Integer acceptors;
private final Integer acceptQueueSize;
private final Integer requestHeaderSize;
private final Integer responseHeaderSize;
private final Long stopTimeout;
private final Long idleTimeout;
private final Long shutdownIdleTimeout;

private JettySettings(
Optional<Integer> acceptors,
Optional<Integer> acceptQueueSize,
Optional<Integer> requestHeaderSize,
Optional<Integer> responseHeaderSize,
Optional<Long> stopTimeout,
Optional<Long> idleTimeout,
Optional<Long> shutdownIdleTimeout) {
Integer acceptors,
Integer acceptQueueSize,
Integer requestHeaderSize,
Integer responseHeaderSize,
Long stopTimeout,
Long idleTimeout,
Long shutdownIdleTimeout) {
this.acceptors = acceptors;
this.acceptQueueSize = acceptQueueSize;
this.requestHeaderSize = requestHeaderSize;
Expand All @@ -48,31 +48,31 @@ private JettySettings(
}

public Optional<Integer> getAcceptors() {
return acceptors;
return Optional.ofNullable(acceptors);
}

public Optional<Integer> getAcceptQueueSize() {
return acceptQueueSize;
return Optional.ofNullable(acceptQueueSize);
}

public Optional<Integer> getRequestHeaderSize() {
return requestHeaderSize;
return Optional.ofNullable(requestHeaderSize);
}

public Optional<Integer> getResponseHeaderSize() {
return responseHeaderSize;
return Optional.ofNullable(responseHeaderSize);
}

public Optional<Long> getStopTimeout() {
return stopTimeout;
return Optional.ofNullable(stopTimeout);
}

public Optional<Long> getIdleTimeout() {
return idleTimeout;
return Optional.ofNullable(idleTimeout);
}

public Optional<Long> getShutdownIdleTimeout() {
return shutdownIdleTimeout;
return Optional.ofNullable(shutdownIdleTimeout);
}

@Override
Expand Down Expand Up @@ -134,20 +134,20 @@ public Builder withIdleTimeout(Long idleTimeout) {
return this;
}

public Builder withShutodwnIdleTimeout(Long shutdownIdleTimeout) {
public Builder withShutdownIdleTimeout(Long shutdownIdleTimeout) {
this.shutdownIdleTimeout = shutdownIdleTimeout;
return this;
}

public JettySettings build() {
return new JettySettings(
Optional.ofNullable(acceptors),
Optional.ofNullable(acceptQueueSize),
Optional.ofNullable(requestHeaderSize),
Optional.ofNullable(responseHeaderSize),
Optional.ofNullable(stopTimeout),
Optional.ofNullable(idleTimeout),
Optional.ofNullable(shutdownIdleTimeout));
acceptors,
acceptQueueSize,
requestHeaderSize,
responseHeaderSize,
stopTimeout,
idleTimeout,
shutdownIdleTimeout);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,8 @@

public class Jetty11Utils {

private Jetty11Utils() {}

private static final int DEFAULT_ACCEPTORS = 3;
private static final int DEFAULT_HEADER_SIZE = 32768;

Expand All @@ -46,14 +48,8 @@ public static ServerConnector createServerConnector(
}

public static void setJettySettings(JettySettings jettySettings, ServerConnector connector) {
if (jettySettings.getAcceptQueueSize().isPresent()) {
connector.setAcceptQueueSize(jettySettings.getAcceptQueueSize().get());
}

if (jettySettings.getIdleTimeout().isPresent()) {
connector.setIdleTimeout(jettySettings.getIdleTimeout().get());
}

jettySettings.getAcceptQueueSize().ifPresent(connector::setAcceptQueueSize);
jettySettings.getIdleTimeout().ifPresent(connector::setIdleTimeout);
connector.setShutdownIdleTimeout(jettySettings.getShutdownIdleTimeout().orElse(200L));
}

Expand Down

0 comments on commit f530a59

Please sign in to comment.