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

Issue #1721 async read failure on big POST 

Modified isReady to not fillAndParseContent if known to be isReady()==false already.
Added mutex on produceContent
This commit is contained in:
Greg Wilkins 2017-08-15 10:08:08 +10:00
parent a58447aea1
commit 3c3d05f722
3 changed files with 23 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
jetty-io/src/main/java/org/eclipse/jetty/io/FillInterest.java
View File

@ -39,7 +39,6 @@ public abstract class FillInterest
{
private final static Logger LOG = Log.getLogger(FillInterest.class);
private final AtomicReference<Callback> _interested = new AtomicReference<>(null);
private Throwable _lastSet;
protected FillInterest()
{
@ -58,8 +57,6 @@ public abstract class FillInterest
if (!tryRegister(callback))
{
LOG.warn("Read pending for {} prevented {}", _interested, callback);
if (LOG.isDebugEnabled())
LOG.warn("callback set at ",_lastSet);
throw new ReadPendingException();
}
}
@ -81,10 +78,7 @@ public abstract class FillInterest
return false;
if (LOG.isDebugEnabled())
{
LOG.debug("{} register {}",this,callback);
_lastSet=new Throwable(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()) + ":" + Thread.currentThread().getName());
}
LOG.debug("interested {}",this);
try
{
@ -103,9 +97,9 @@ public abstract class FillInterest
*/
public void fillable()
{
Callback callback = _interested.get();
if (LOG.isDebugEnabled())
LOG.debug("{} fillable {}",this,callback);
LOG.debug("fillable {}",this);
Callback callback = _interested.get();
if (callback != null && _interested.compareAndSet(callback, null))
callback.succeeded();
else if (LOG.isDebugEnabled())
@ -134,6 +128,8 @@ public abstract class FillInterest
*/
public boolean onFail(Throwable cause)
{
if (LOG.isDebugEnabled())
LOG.debug("onFail {} {}",this,cause);
Callback callback = _interested.get();
if (callback != null && _interested.compareAndSet(callback, null))
{
@ -145,9 +141,9 @@ public abstract class FillInterest
public void onClose()
{
Callback callback = _interested.get();
if (LOG.isDebugEnabled())
LOG.debug("{} onClose {}",this,callback);
LOG.debug("onClose {}",this);
Callback callback = _interested.get();
if (callback != null && _interested.compareAndSet(callback, null))
callback.failed(new ClosedChannelException());
}
@ -155,7 +151,7 @@ public abstract class FillInterest
@Override
public String toString()
{
return String.format("FillInterest@%x{%b,%s}", hashCode(), _interested.get()!=null, _interested.get());
return String.format("FillInterest@%x{%s}", hashCode(), _interested.get());
}

2
jetty-server/src/main/java/org/eclipse/jetty/server/HttpChannel.java
View File

@ -404,7 +404,7 @@ public class HttpChannel implements Runnable, HttpOutput.Interceptor
case READ_PRODUCE:
{
_request.getHttpInput().produceContent();
_request.getHttpInput().asyncReadProduce();
break;
}

14
jetty-server/src/main/java/org/eclipse/jetty/server/HttpInput.java
View File

@ -330,6 +330,18 @@ public class HttpInput extends ServletInputStream implements Runnable
protected void produceContent() throws IOException
{
}
/**
* Called by channel when asynchronous IO needs to produce more content
* @throws IOException
*/
public void asyncReadProduce() throws IOException
{
synchronized (_inputQ)
{
produceContent();
}
}
/**
* Get the next content from the inputQ, calling {@link #produceContent()} if need be. EOF is processed and state changed.
@ -707,6 +719,8 @@ public class HttpInput extends ServletInputStream implements Runnable
return true;
if (_state instanceof EOFState)
return true;
if (_waitingForContent)
return false;
if (produceNextContext() != null)
return true;
_channelState.onReadUnready();