Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

357240 remove buffer counts

This commit is contained in:
Greg Wilkins 2011-09-28 10:44:43 +10:00
parent ac7fcd9ab7
commit c20ce1fc4e
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
jetty-io/src/main/java/org/eclipse/jetty/io/nio/SslSelectChannelEndPoint.java
View File

@ -50,7 +50,6 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
private final SSLEngine _engine;
private final SSLSession _session;
private int _inCount;
private volatile NIOBuffer _inNIOBuffer;
private volatile NIOBuffer _outNIOBuffer;
@ -90,14 +89,12 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
if (_debug) LOG.debug(_session+" channel="+channel);
}
int _outCount;
/* ------------------------------------------------------------ */
private void needOutBuffer()
{
synchronized (this)
{
_outCount++;
if (_outNIOBuffer==null)
_outNIOBuffer=(NIOBuffer)_buffers.getBuffer(_session.getPacketBufferSize());
}
@ -108,11 +105,10 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
{
synchronized (this)
{
if (--_outCount<=0 && _outNIOBuffer!=null && _outNIOBuffer.length()==0)
if (_outNIOBuffer!=null && _outNIOBuffer.length()==0)
{
_buffers.returnBuffer(_outNIOBuffer);
_outNIOBuffer=null;
_outCount=0;
}
}
}
@ -122,7 +118,6 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
{
synchronized (this)
{
_inCount++;
if(_inNIOBuffer==null)
_inNIOBuffer=(NIOBuffer)_buffers.getBuffer(_session.getPacketBufferSize());
}
@ -133,11 +128,10 @@ public class SslSelectChannelEndPoint extends SelectChannelEndPoint
{
synchronized (this)
{
if (--_inCount<=0 &&_inNIOBuffer!=null && _inNIOBuffer.length()==0)
if (_inNIOBuffer!=null && _inNIOBuffer.length()==0)
{
_buffers.returnBuffer(_inNIOBuffer);
_inNIOBuffer=null;
_inCount=0;
}
}
}