diff --git a/src/org/redkale/net/http/HttpServer.java b/src/org/redkale/net/http/HttpServer.java index 851b72ae8..7b7de5181 100644 --- a/src/org/redkale/net/http/HttpServer.java +++ b/src/org/redkale/net/http/HttpServer.java @@ -453,10 +453,10 @@ public class HttpServer extends Server createBufferPool(AtomicLong createCounter, AtomicLong cycleCounter, int bufferPoolSize) { - AtomicLong createBufferCounter = new AtomicLong(); - AtomicLong cycleBufferCounter = new AtomicLong(); + if (createCounter == null) createCounter = new AtomicLong(); + if (cycleCounter == null) cycleCounter = new AtomicLong(); final int rcapacity = this.bufferCapacity; - ObjectPool bufferPool = new ObjectPool<>(createBufferCounter, cycleBufferCounter, bufferPoolSize, + ObjectPool bufferPool = new ObjectPool<>(createCounter, cycleCounter, bufferPoolSize, (Object... params) -> ByteBuffer.allocateDirect(rcapacity), null, (e) -> { if (e == null || e.isReadOnly() || e.capacity() != rcapacity) return false; e.clear();