updates from review
This commit is contained in:
parent
769687f773
commit
e2c710e086
|
@ -384,7 +384,7 @@ public class HttpConnection extends AbstractConnection implements Runnable, Http
|
||||||
}
|
}
|
||||||
|
|
||||||
// Handle connection upgrades
|
// Handle connection upgrades
|
||||||
if (_channel.getResponse().getStatus() == HttpStatus.SWITCHING_PROTOCOLS_101)
|
else if (_channel.getResponse().getStatus() == HttpStatus.SWITCHING_PROTOCOLS_101)
|
||||||
{
|
{
|
||||||
Connection connection = (Connection)_channel.getRequest().getAttribute(UPGRADE_CONNECTION_ATTRIBUTE);
|
Connection connection = (Connection)_channel.getRequest().getAttribute(UPGRADE_CONNECTION_ATTRIBUTE);
|
||||||
if (connection != null)
|
if (connection != null)
|
||||||
|
|
|
@ -436,8 +436,8 @@ public class HttpOutput extends ServletOutputStream implements Runnable
|
||||||
// If we can't complete due to the API state, then abort
|
// If we can't complete due to the API state, then abort
|
||||||
if (error != null)
|
if (error != null)
|
||||||
{
|
{
|
||||||
_writeBlocker.fail(error);
|
|
||||||
_channel.abort(error);
|
_channel.abort(error);
|
||||||
|
_writeBlocker.fail(error);
|
||||||
_state = State.CLOSED;
|
_state = State.CLOSED;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
|
Loading…
Reference in New Issue