jetty-9 ssl tests pass
This commit is contained in:
parent
ba4157d8e6
commit
8f8c3f7760
|
@ -63,7 +63,6 @@ public class SslConnection extends AbstractAsyncConnection
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
private IOFuture.Callback _writeable = new IOFuture.Callback()
|
private IOFuture.Callback _writeable = new IOFuture.Callback()
|
||||||
{
|
{
|
||||||
@Override
|
@Override
|
||||||
|
@ -75,7 +74,11 @@ public class SslConnection extends AbstractAsyncConnection
|
||||||
@Override
|
@Override
|
||||||
public void onFail(Throwable cause)
|
public void onFail(Throwable cause)
|
||||||
{
|
{
|
||||||
LOG.warn("FAILED: "+cause);
|
LOG.debug("write FAILED",cause);
|
||||||
|
if (!_appWriteFuture.isComplete())
|
||||||
|
_appWriteFuture.fail(cause);
|
||||||
|
else
|
||||||
|
LOG.warn("write FAILED",cause);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -816,9 +819,6 @@ public class SslConnection extends AbstractAsyncConnection
|
||||||
_lock.lock();
|
_lock.lock();
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (!_appWriteFuture.isComplete())
|
|
||||||
throw new IllegalStateException("previous write not complete");
|
|
||||||
|
|
||||||
// Try to process all
|
// Try to process all
|
||||||
for (ByteBuffer b : _writeBuffers)
|
for (ByteBuffer b : _writeBuffers)
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue