From 95f92165b1b6c863e86952fd37b2b6cbbb5f44cb Mon Sep 17 00:00:00 2001 From: Violeta Georgieva Date: Fri, 3 Jun 2022 16:16:24 +0300 Subject: [PATCH] Fix checkstyle warnings --- codequality/checkstyle.xml | 2 +- .../java/reactor/netty/http/client/HTTP2AllocationStrategy.java | 2 +- .../src/main/java/reactor/netty/http/client/Http2Pool.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/codequality/checkstyle.xml b/codequality/checkstyle.xml index 87e01f8411..2ed2bace7f 100644 --- a/codequality/checkstyle.xml +++ b/codequality/checkstyle.xml @@ -76,7 +76,7 @@ - + diff --git a/reactor-netty-http/src/main/java/reactor/netty/http/client/HTTP2AllocationStrategy.java b/reactor-netty-http/src/main/java/reactor/netty/http/client/HTTP2AllocationStrategy.java index 88790ae63a..b64606c106 100644 --- a/reactor-netty-http/src/main/java/reactor/netty/http/client/HTTP2AllocationStrategy.java +++ b/reactor-netty-http/src/main/java/reactor/netty/http/client/HTTP2AllocationStrategy.java @@ -124,7 +124,7 @@ public int permitMaximum() { @Override public void returnPermits(int returned) { - for(;;) { + for (;;) { int p = PERMITS.get(this); if (p + returned > maxConnections) { throw new IllegalArgumentException("Too many permits returned: returned=" + returned + diff --git a/reactor-netty-http/src/main/java/reactor/netty/http/client/Http2Pool.java b/reactor-netty-http/src/main/java/reactor/netty/http/client/Http2Pool.java index ce0009d724..b938723495 100644 --- a/reactor-netty-http/src/main/java/reactor/netty/http/client/Http2Pool.java +++ b/reactor-netty-http/src/main/java/reactor/netty/http/client/Http2Pool.java @@ -169,7 +169,7 @@ final class Http2Pool implements InstrumentedPool, InstrumentedPool. ((HTTP2AllocationStrategy) allocationStrategy).maxConcurrentStreams() : -1; this.maxIdleTime = maxIdleTime; this.maxLifeTime = maxLifeTime; - this.minConnections = allocationStrategy == null ? 0: allocationStrategy.permitMinimum(); + this.minConnections = allocationStrategy == null ? 0 : allocationStrategy.permitMinimum(); this.pending = new ConcurrentLinkedDeque<>(); this.poolConfig = poolConfig;