checkstyle

Signed-off-by: David Kral <[email protected]>
Verdent · Oct 18, 2024 · eefca6f · eefca6f
1 parent 5d4c5e4
commit eefca6f
Showing 1 changed file with 10 additions and 7 deletions.
diff --git a/webclient/http1/src/main/java/io/helidon/webclient/http1/Http1ConnectionCache.java b/webclient/http1/src/main/java/io/helidon/webclient/http1/Http1ConnectionCache.java
@@ -63,7 +63,8 @@ class Http1ConnectionCache extends ClientConnectionCache {
     private static final Duration QUEUE_TIMEOUT = Duration.ofMillis(10);
     private static final Http1ConnectionCacheConfig EMPTY_CONFIG = Http1ConnectionCacheConfig.create();
     private static final Http1ConnectionCache SHARED = new Http1ConnectionCache(true,
-                                                                                Http1ClientImpl.globalConfig().connectionCacheConfig());
+                                                                                Http1ClientImpl.globalConfig()
+                                                                                        .connectionCacheConfig());
     private final ConnectionCreationStrategy connectionCreationStrategy;
     private final Duration keepAliveWaiting;
     private final Map<ConnectionKey, LinkedBlockingDeque<TcpClientConnection>> cache = new ConcurrentHashMap<>();
@@ -186,7 +187,8 @@ private ClientConnection keepAliveConnection(Http1ClientImpl http1Client,
                     throw new RuntimeException(e);
                 }
                 if (connection == null) {
-                    throw new IllegalStateException("Could not make a new HTTP connection. Maximum number of connections reached.");
+                    throw new IllegalStateException("Could not make a new HTTP connection. "
+                                                            + "Maximum number of connections reached.");
                 } else {
                     if (LOGGER.isLoggable(DEBUG)) {
                         LOGGER.log(DEBUG, String.format("[%s] client connection obtained %s",
@@ -236,7 +238,8 @@ private boolean finishRequest(LinkedBlockingDeque<TcpClientConnection> connectio
         if (conn.isConnected()) {
             try {
                 //Connection needs to be marked as idle here.
-                //This prevents race condition where another thread takes it out of the connection before setting it to idle state.
+                //This prevents race condition where another thread takes it out of the connection before setting it to
+                //idle state.
                 conn.helidonSocket().idle(); // mark it as idle to stay blocked at read for closed conn detection
                 if (connectionQueue.offer(conn, QUEUE_TIMEOUT.toMillis(), TimeUnit.MILLISECONDS)) {
                     if (LOGGER.isLoggable(DEBUG)) {
@@ -427,10 +430,10 @@ private TcpClientConnection checkHostLimit(LimitAlgorithm.Token maxConnectionTok
             try {
                 hostsConnectionLimitLock.lock();
                 hostLimit = connectionLimitsPerHost.computeIfAbsent(hostKey,
-                                                                    key -> Optional.ofNullable(proxyConfigs.get(proxyIdent))
-                                                                            .flatMap(Http1ProxyLimitConfigBlueprint::connectionPerHostLimit)
-                                                                            .orElse(connectionPerHostLimit)
-                                                                            .copy());
+                                                        key -> Optional.ofNullable(proxyConfigs.get(proxyIdent))
+                                                                .flatMap(Http1ProxyLimitConfigBlueprint::connectionPerHostLimit)
+                                                                .orElse(connectionPerHostLimit)
+                                                                .copy());
             } finally {
                 hostsConnectionLimitLock.unlock();
             }