minor cleanup
Signed-off-by: Greg Wilkins <gregw@webtide.com>
This commit is contained in:
parent
38735f8457
commit
0e2daba7a2
|
@ -399,32 +399,26 @@ public class SslConnection extends AbstractConnection
|
|||
try
|
||||
{
|
||||
// If we are handshaking, then wake up any waiting write as well as it may have been blocked on the read
|
||||
boolean waiting_for_fill = false;
|
||||
boolean waiting_for_fill;
|
||||
synchronized(_decryptedEndPoint)
|
||||
{
|
||||
if (LOG.isDebugEnabled())
|
||||
LOG.debug("onFillable {}", SslConnection.this);
|
||||
|
||||
_fillState = FillState.IDLE;
|
||||
switch(_flushState)
|
||||
{
|
||||
case WAIT_FOR_FILL:
|
||||
waiting_for_fill = true;
|
||||
break;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
waiting_for_fill = _flushState==FlushState.WAIT_FOR_FILL;
|
||||
}
|
||||
|
||||
getFillInterest().fillable();
|
||||
|
||||
if (waiting_for_fill)
|
||||
{
|
||||
synchronized(_decryptedEndPoint)
|
||||
{
|
||||
waiting_for_fill = _flushState==FlushState.WAIT_FOR_FILL;
|
||||
}
|
||||
if (waiting_for_fill)
|
||||
fill(BufferUtil.EMPTY_BUFFER);
|
||||
synchronized(_decryptedEndPoint)
|
||||
{
|
||||
waiting_for_fill = _flushState==FlushState.WAIT_FOR_FILL;
|
||||
}
|
||||
if (waiting_for_fill)
|
||||
fill(BufferUtil.EMPTY_BUFFER);
|
||||
}
|
||||
}
|
||||
catch (Throwable e)
|
||||
|
|
Loading…
Reference in New Issue