optimise out extra notify
This commit is contained in:
parent
60828fe8a3
commit
3cd59fe1b8
|
@ -498,6 +498,27 @@ public class HttpConnection extends AbstractConnection implements Runnable, Http
|
||||||
*/
|
*/
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void earlyEOF()
|
||||||
|
{
|
||||||
|
synchronized (lock())
|
||||||
|
{
|
||||||
|
_inputEOF=true;
|
||||||
|
_earlyEOF = true;
|
||||||
|
LOG.debug("{} early EOF", this);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void shutdown()
|
||||||
|
{
|
||||||
|
synchronized (lock())
|
||||||
|
{
|
||||||
|
_inputEOF=true;
|
||||||
|
LOG.debug("{} shutdown", this);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void onAllContentConsumed()
|
protected void onAllContentConsumed()
|
||||||
{
|
{
|
||||||
|
|
|
@ -43,8 +43,8 @@ public abstract class HttpInput<T> extends ServletInputStream
|
||||||
{
|
{
|
||||||
private final static Logger LOG = Log.getLogger(HttpInput.class);
|
private final static Logger LOG = Log.getLogger(HttpInput.class);
|
||||||
private final ArrayQueue<T> _inputQ = new ArrayQueue<>();
|
private final ArrayQueue<T> _inputQ = new ArrayQueue<>();
|
||||||
private boolean _earlyEOF;
|
protected boolean _earlyEOF;
|
||||||
private boolean _inputEOF;
|
protected boolean _inputEOF;
|
||||||
|
|
||||||
public Object lock()
|
public Object lock()
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue