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

357240 more half close refinements

This commit is contained in:
Greg Wilkins 2011-10-06 11:24:06 +11:00
parent 12469af499
commit 76cdf9badb
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java
View File

@ -360,10 +360,11 @@ public class HttpConnection extends AbstractConnection implements Dumpable
// we wont be called again so let the parser see the close
complete=true;
_parser.parseAvailable();
// TODO should not need this
if (!(_parser.isComplete()||_parser.isIdle()))
{
LOG.warn("Incomplete {} {}",_parser,_endp);
if (_exchange!=null)
if (_exchange!=null && !_exchange.isDone())
{
_exchange.setStatus(HttpExchange.STATUS_EXCEPTED);
_exchange.getEventListener().onException(new EOFException("Incomplete"));
@ -372,17 +373,16 @@ public class HttpConnection extends AbstractConnection implements Dumpable
}
}
/* TODO - is this needed ?
if (_generator.isComplete() && !_parser.isComplete())
// TODO should not need this
if (_endp.isInputShutdown() && !_parser.isComplete())
{
if (!_endp.isOpen() || _endp.isInputShutdown())
if (_exchange!=null && !_exchange.isDone())
{
complete=true;
close=true;
close();
_exchange.setStatus(HttpExchange.STATUS_EXCEPTED);
_exchange.getEventListener().onException(new EOFException("Incomplete"));
}
_endp.close();
}
*/
if (complete || failed)
{