From 32f7822c1a80cbef5ff0a25d07a5aa99314119f9 Mon Sep 17 00:00:00 2001 From: Greg Wilkins Date: Wed, 9 Nov 2011 23:38:09 +1100 Subject: [PATCH] Reverted the unwrapBuf to not be pooled. --- .../org/eclipse/jetty/io/nio/SslConnection.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SslConnection.java b/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SslConnection.java index af41cd5c2ce..19ea712a9ee 100644 --- a/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SslConnection.java +++ b/jetty-io/src/main/java/org/eclipse/jetty/io/nio/SslConnection.java @@ -73,13 +73,11 @@ public class SslConnection extends AbstractConnection implements AsyncConnection { final NIOBuffer _in; final NIOBuffer _out; - final NIOBuffer _unwrap; SslBuffers(int packetSize, int appSize) { _in=new IndirectNIOBuffer(packetSize); _out=new IndirectNIOBuffer(packetSize); - _unwrap=new IndirectNIOBuffer(appSize); } } @@ -149,7 +147,6 @@ public class SslConnection extends AbstractConnection implements AsyncConnection _buffers=new SslBuffers(_session.getPacketBufferSize()*2,_session.getApplicationBufferSize()*2); _inbound=_buffers._in; _outbound=_buffers._out; - _unwrapBuf=_buffers._unwrap; __buffers.set(null); } } @@ -165,15 +162,16 @@ public class SslConnection extends AbstractConnection implements AsyncConnection { if (_buffers!=null && _inbound.length()==0 && - _outbound.length()==0 && - _unwrapBuf.length()==0) + _outbound.length()==0 ) { _inbound=null; _outbound=null; - _unwrapBuf=null; __buffers.set(_buffers); _buffers=null; } + + if (_unwrapBuf!=null && _unwrapBuf.length()==0) + _unwrapBuf=null; } } } @@ -244,7 +242,11 @@ public class SslConnection extends AbstractConnection implements AsyncConnection private synchronized boolean process(Buffer toFill, Buffer toFlush) throws IOException { if (toFill==null) + { + if (_unwrapBuf==null) + _unwrapBuf=new IndirectNIOBuffer(_session.getApplicationBufferSize()*2); toFill=_unwrapBuf; + } else if (toFill.capacity()<_session.getApplicationBufferSize()) { boolean progress=process(null,toFlush);