Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Jetty 9.4.x 4331 async close complete #4378

Closed
wants to merge 12 commits into from
Closed

Jetty 9.4.x 4331 async close complete #4378

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
b30755f
Issue #4376 Async Content Complete
gregw Nov 28, 2019
529ea5e
Issue #4331 Async Write Complete
gregw Nov 29, 2019
41b3d70
Issue #4331 Async Write Complete
gregw Nov 29, 2019
a872522
Issue #4331 Async Write Complete
gregw Nov 29, 2019
21209d7
Issue #4376 Async Content Complete
gregw Nov 29, 2019
f43a484
Merge branch 'jetty-9.4.x-4376-asynccontentcomplete' into jetty-9.4.x…
gregw Nov 29, 2019
d254158
Issue #4376 Async Content Complete
gregw Nov 29, 2019
abb7e3b
Issue #4376 Async Content Complete
gregw Nov 29, 2019
2fe92fc
Merge branch 'jetty-9.4.x-4376-asynccontentcomplete' into jetty-9.4.x…
gregw Nov 29, 2019
2b5ffeb
Issue #4331 Async Close Complete
gregw Nov 30, 2019
36cc246
Issue #4376 Async Content Complete
gregw Dec 2, 2019
50c9740
Merge branch 'jetty-9.4.x-4376-asynccontentcomplete' into jetty-9.4.x…
gregw Dec 2, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
13 changes: 7 additions & 6 deletions jetty-server/src/main/java/org/eclipse/jetty/server/HttpChannel.java
View file
Open in desktop
Expand Up @@ -717,6 +717,13 @@ public boolean onRequestComplete()
return result;
}

void onResponseComplete()
{
if (LOG.isDebugEnabled())
LOG.debug("onResponseComplete {}", this);
_combinedListener.onResponseEnd(_request);
}

public void onCompleted()
{
if (LOG.isDebugEnabled())
Expand Down Expand Up @@ -1194,11 +1201,6 @@ public void succeeded()
_combinedListener.onResponseCommit(_request);
if (_length > 0)
_combinedListener.onResponseContent(_request, _content);
if (_complete && _state.completeResponse())
{
_response.getHttpOutput().closed();
_combinedListener.onResponseEnd(_request);
}
super.succeeded();
}

Expand All @@ -1222,7 +1224,6 @@ public void succeeded()
@Override
public void failed(Throwable th)
{
_response.getHttpOutput().closed();
abort(x);
super.failed(x);
}
Expand Down