diff options
author | Bjørn Christian Seime <bjorncs@yahoo-inc.com> | 2016-12-01 12:48:09 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@yahoo-inc.com> | 2016-12-01 12:48:09 +0100 |
commit | 82e8cfccdfce60711a066c9b0157ce022ab78dfe (patch) | |
tree | 57290faa8672302d9bcbff953d5af094245e93fe /jdisc_http_service | |
parent | 95129f9f45929204aa65a39581d4c8755b414bad (diff) |
Move write listener registration from constructor to dispatch methods
Diffstat (limited to 'jdisc_http_service')
-rw-r--r-- | jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java index 55b31d6e696..f41e44b0a73 100644 --- a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java +++ b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java @@ -70,7 +70,6 @@ class HttpRequestDispatch { this.async = servletRequest.startAsync(); async.setTimeout(0); - servletResponseController.registerWriteListener(); } public void dispatch() throws IOException { @@ -144,6 +143,7 @@ class HttpRequestDispatch { @SuppressWarnings("try") private ServletRequestReader handleRequest() throws IOException { + servletResponseController.registerWriteListener(); HttpRequest jdiscRequest = HttpRequestFactory.newJDiscRequest(jDiscContext.container, servletRequest); final ContentChannel requestContentChannel; @@ -175,6 +175,7 @@ class HttpRequestDispatch { ContentChannel handleRequestFilterResponse(Response response) { try { + servletResponseController.registerWriteListener(); servletRequest.getInputStream().close(); ContentChannel responseContentChannel = servletResponseController.responseHandler.handleResponse(response); servletResponseController.finishedFuture().whenComplete(completeRequestCallback); |