You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2015/10/30 14:06:04 UTC
svn commit: r1711465 [18/34] - in
/httpcomponents/site/httpcomponents-core-4.4.x: ./ httpcore-ab/
httpcore-nio/ httpcore-nio/apidocs/
httpcore-nio/apidocs/org/apache/http/impl/nio/
httpcore-nio/apidocs/org/apache/http/impl/nio/bootstrap/ httpcore-nio/a...
Modified: httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/HttpAsyncService.html
URL: http://svn.apache.org/viewvc/httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/HttpAsyncService.html?rev=1711465&r1=1711464&r2=1711465&view=diff
==============================================================================
--- httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/HttpAsyncService.html (original)
+++ httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/HttpAsyncService.html Fri Oct 30 13:05:47 2015
@@ -755,341 +755,336 @@
<a class="jxr_linenumber" name="745" href="#745">745</a> <strong class="jxr_keyword">if</strong> (!<strong class="jxr_keyword">this</strong>.connStrategy.keepAlive(response, context)) {
<a class="jxr_linenumber" name="746" href="#746">746</a> conn.close();
<a class="jxr_linenumber" name="747" href="#747">747</a> } <strong class="jxr_keyword">else</strong> {
-<a class="jxr_linenumber" name="748" href="#748">748</a> <em class="jxr_comment">// Ready to process new request</em>
-<a class="jxr_linenumber" name="749" href="#749">749</a> <strong class="jxr_keyword">final</strong> Queue<PipelineEntry> pipeline = state.getPipeline();
-<a class="jxr_linenumber" name="750" href="#750">750</a> <strong class="jxr_keyword">if</strong> (pipeline.isEmpty()) {
-<a class="jxr_linenumber" name="751" href="#751">751</a> conn.suspendOutput();
-<a class="jxr_linenumber" name="752" href="#752">752</a> }
-<a class="jxr_linenumber" name="753" href="#753">753</a> conn.requestInput();
-<a class="jxr_linenumber" name="754" href="#754">754</a> }
-<a class="jxr_linenumber" name="755" href="#755">755</a> }
-<a class="jxr_linenumber" name="756" href="#756">756</a>
-<a class="jxr_linenumber" name="757" href="#757">757</a> @SuppressWarnings(<span class="jxr_string">"unchecked"</span>)
-<a class="jxr_linenumber" name="758" href="#758">758</a> <strong class="jxr_keyword">private</strong> HttpAsyncRequestHandler<Object> getRequestHandler(<strong class="jxr_keyword">final</strong> HttpRequest request) {
-<a class="jxr_linenumber" name="759" href="#759">759</a> HttpAsyncRequestHandler<Object> handler = <strong class="jxr_keyword">null</strong>;
-<a class="jxr_linenumber" name="760" href="#760">760</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.handlerMapper != <strong class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="761" href="#761">761</a> handler = (HttpAsyncRequestHandler<Object>) <strong class="jxr_keyword">this</strong>.handlerMapper.lookup(request);
-<a class="jxr_linenumber" name="762" href="#762">762</a> }
-<a class="jxr_linenumber" name="763" href="#763">763</a> <strong class="jxr_keyword">if</strong> (handler == <strong class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="764" href="#764">764</a> handler = <strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/http/nio/protocol/NullRequestHandler.html">NullRequestHandler</a>();
-<a class="jxr_linenumber" name="765" href="#765">765</a> }
-<a class="jxr_linenumber" name="766" href="#766">766</a> <strong class="jxr_keyword">return</strong> handler;
-<a class="jxr_linenumber" name="767" href="#767">767</a> }
-<a class="jxr_linenumber" name="768" href="#768">768</a>
-<a class="jxr_linenumber" name="769" href="#769">769</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> {
+<a class="jxr_linenumber" name="748" href="#748">748</a> conn.requestInput();
+<a class="jxr_linenumber" name="749" href="#749">749</a> }
+<a class="jxr_linenumber" name="750" href="#750">750</a> }
+<a class="jxr_linenumber" name="751" href="#751">751</a>
+<a class="jxr_linenumber" name="752" href="#752">752</a> @SuppressWarnings(<span class="jxr_string">"unchecked"</span>)
+<a class="jxr_linenumber" name="753" href="#753">753</a> <strong class="jxr_keyword">private</strong> HttpAsyncRequestHandler<Object> getRequestHandler(<strong class="jxr_keyword">final</strong> HttpRequest request) {
+<a class="jxr_linenumber" name="754" href="#754">754</a> HttpAsyncRequestHandler<Object> handler = <strong class="jxr_keyword">null</strong>;
+<a class="jxr_linenumber" name="755" href="#755">755</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.handlerMapper != <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="756" href="#756">756</a> handler = (HttpAsyncRequestHandler<Object>) <strong class="jxr_keyword">this</strong>.handlerMapper.lookup(request);
+<a class="jxr_linenumber" name="757" href="#757">757</a> }
+<a class="jxr_linenumber" name="758" href="#758">758</a> <strong class="jxr_keyword">if</strong> (handler == <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="759" href="#759">759</a> handler = <strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/http/nio/protocol/NullRequestHandler.html">NullRequestHandler</a>();
+<a class="jxr_linenumber" name="760" href="#760">760</a> }
+<a class="jxr_linenumber" name="761" href="#761">761</a> <strong class="jxr_keyword">return</strong> handler;
+<a class="jxr_linenumber" name="762" href="#762">762</a> }
+<a class="jxr_linenumber" name="763" href="#763">763</a>
+<a class="jxr_linenumber" name="764" href="#764">764</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> {
+<a class="jxr_linenumber" name="765" href="#765">765</a>
+<a class="jxr_linenumber" name="766" href="#766">766</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
+<a class="jxr_linenumber" name="767" href="#767">767</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler;
+<a class="jxr_linenumber" name="768" href="#768">768</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer<Object> consumer;
+<a class="jxr_linenumber" name="769" href="#769">769</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
<a class="jxr_linenumber" name="770" href="#770">770</a>
-<a class="jxr_linenumber" name="771" href="#771">771</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
-<a class="jxr_linenumber" name="772" href="#772">772</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler;
-<a class="jxr_linenumber" name="773" href="#773">773</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer<Object> consumer;
-<a class="jxr_linenumber" name="774" href="#774">774</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
-<a class="jxr_linenumber" name="775" href="#775">775</a>
-<a class="jxr_linenumber" name="776" href="#776">776</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a>(
-<a class="jxr_linenumber" name="777" href="#777">777</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
-<a class="jxr_linenumber" name="778" href="#778">778</a> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler,
-<a class="jxr_linenumber" name="779" href="#779">779</a> <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer<Object> consumer,
-<a class="jxr_linenumber" name="780" href="#780">780</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
-<a class="jxr_linenumber" name="781" href="#781">781</a> <strong class="jxr_keyword">this</strong>.request = request;
-<a class="jxr_linenumber" name="782" href="#782">782</a> <strong class="jxr_keyword">this</strong>.handler = handler;
-<a class="jxr_linenumber" name="783" href="#783">783</a> <strong class="jxr_keyword">this</strong>.consumer = consumer;
-<a class="jxr_linenumber" name="784" href="#784">784</a> <strong class="jxr_keyword">this</strong>.context = context;
-<a class="jxr_linenumber" name="785" href="#785">785</a> }
-<a class="jxr_linenumber" name="786" href="#786">786</a>
-<a class="jxr_linenumber" name="787" href="#787">787</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
-<a class="jxr_linenumber" name="788" href="#788">788</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
-<a class="jxr_linenumber" name="789" href="#789">789</a> }
-<a class="jxr_linenumber" name="790" href="#790">790</a>
-<a class="jxr_linenumber" name="791" href="#791">791</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestHandler<Object> getHandler() {
-<a class="jxr_linenumber" name="792" href="#792">792</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.handler;
-<a class="jxr_linenumber" name="793" href="#793">793</a> }
-<a class="jxr_linenumber" name="794" href="#794">794</a>
-<a class="jxr_linenumber" name="795" href="#795">795</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestConsumer<Object> getConsumer() {
-<a class="jxr_linenumber" name="796" href="#796">796</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.consumer;
-<a class="jxr_linenumber" name="797" href="#797">797</a> }
+<a class="jxr_linenumber" name="771" href="#771">771</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a>(
+<a class="jxr_linenumber" name="772" href="#772">772</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
+<a class="jxr_linenumber" name="773" href="#773">773</a> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler,
+<a class="jxr_linenumber" name="774" href="#774">774</a> <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer<Object> consumer,
+<a class="jxr_linenumber" name="775" href="#775">775</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
+<a class="jxr_linenumber" name="776" href="#776">776</a> <strong class="jxr_keyword">this</strong>.request = request;
+<a class="jxr_linenumber" name="777" href="#777">777</a> <strong class="jxr_keyword">this</strong>.handler = handler;
+<a class="jxr_linenumber" name="778" href="#778">778</a> <strong class="jxr_keyword">this</strong>.consumer = consumer;
+<a class="jxr_linenumber" name="779" href="#779">779</a> <strong class="jxr_keyword">this</strong>.context = context;
+<a class="jxr_linenumber" name="780" href="#780">780</a> }
+<a class="jxr_linenumber" name="781" href="#781">781</a>
+<a class="jxr_linenumber" name="782" href="#782">782</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
+<a class="jxr_linenumber" name="783" href="#783">783</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
+<a class="jxr_linenumber" name="784" href="#784">784</a> }
+<a class="jxr_linenumber" name="785" href="#785">785</a>
+<a class="jxr_linenumber" name="786" href="#786">786</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestHandler<Object> getHandler() {
+<a class="jxr_linenumber" name="787" href="#787">787</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.handler;
+<a class="jxr_linenumber" name="788" href="#788">788</a> }
+<a class="jxr_linenumber" name="789" href="#789">789</a>
+<a class="jxr_linenumber" name="790" href="#790">790</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestConsumer<Object> getConsumer() {
+<a class="jxr_linenumber" name="791" href="#791">791</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.consumer;
+<a class="jxr_linenumber" name="792" href="#792">792</a> }
+<a class="jxr_linenumber" name="793" href="#793">793</a>
+<a class="jxr_linenumber" name="794" href="#794">794</a> <strong class="jxr_keyword">public</strong> HttpContext getContext() {
+<a class="jxr_linenumber" name="795" href="#795">795</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.context;
+<a class="jxr_linenumber" name="796" href="#796">796</a> }
+<a class="jxr_linenumber" name="797" href="#797">797</a> }
<a class="jxr_linenumber" name="798" href="#798">798</a>
-<a class="jxr_linenumber" name="799" href="#799">799</a> <strong class="jxr_keyword">public</strong> HttpContext getContext() {
-<a class="jxr_linenumber" name="800" href="#800">800</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.context;
-<a class="jxr_linenumber" name="801" href="#801">801</a> }
-<a class="jxr_linenumber" name="802" href="#802">802</a> }
-<a class="jxr_linenumber" name="803" href="#803">803</a>
-<a class="jxr_linenumber" name="804" href="#804">804</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> {
+<a class="jxr_linenumber" name="799" href="#799">799</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> {
+<a class="jxr_linenumber" name="800" href="#800">800</a>
+<a class="jxr_linenumber" name="801" href="#801">801</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
+<a class="jxr_linenumber" name="802" href="#802">802</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpResponse response;
+<a class="jxr_linenumber" name="803" href="#803">803</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> producer;
+<a class="jxr_linenumber" name="804" href="#804">804</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
<a class="jxr_linenumber" name="805" href="#805">805</a>
-<a class="jxr_linenumber" name="806" href="#806">806</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
-<a class="jxr_linenumber" name="807" href="#807">807</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpResponse response;
-<a class="jxr_linenumber" name="808" href="#808">808</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> producer;
-<a class="jxr_linenumber" name="809" href="#809">809</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
-<a class="jxr_linenumber" name="810" href="#810">810</a>
-<a class="jxr_linenumber" name="811" href="#811">811</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a>(
-<a class="jxr_linenumber" name="812" href="#812">812</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
-<a class="jxr_linenumber" name="813" href="#813">813</a> <strong class="jxr_keyword">final</strong> HttpResponse response,
-<a class="jxr_linenumber" name="814" href="#814">814</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> producer,
-<a class="jxr_linenumber" name="815" href="#815">815</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
-<a class="jxr_linenumber" name="816" href="#816">816</a> <strong class="jxr_keyword">this</strong>.request = request;
-<a class="jxr_linenumber" name="817" href="#817">817</a> <strong class="jxr_keyword">this</strong>.response = response;
-<a class="jxr_linenumber" name="818" href="#818">818</a> <strong class="jxr_keyword">this</strong>.producer = producer;
-<a class="jxr_linenumber" name="819" href="#819">819</a> <strong class="jxr_keyword">this</strong>.context = context;
-<a class="jxr_linenumber" name="820" href="#820">820</a> }
-<a class="jxr_linenumber" name="821" href="#821">821</a>
-<a class="jxr_linenumber" name="822" href="#822">822</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
-<a class="jxr_linenumber" name="823" href="#823">823</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
-<a class="jxr_linenumber" name="824" href="#824">824</a> }
-<a class="jxr_linenumber" name="825" href="#825">825</a>
-<a class="jxr_linenumber" name="826" href="#826">826</a> <strong class="jxr_keyword">public</strong> HttpResponse getResponse() {
-<a class="jxr_linenumber" name="827" href="#827">827</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.response;
-<a class="jxr_linenumber" name="828" href="#828">828</a> }
-<a class="jxr_linenumber" name="829" href="#829">829</a>
-<a class="jxr_linenumber" name="830" href="#830">830</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> getProducer() {
-<a class="jxr_linenumber" name="831" href="#831">831</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.producer;
-<a class="jxr_linenumber" name="832" href="#832">832</a> }
+<a class="jxr_linenumber" name="806" href="#806">806</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a>(
+<a class="jxr_linenumber" name="807" href="#807">807</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
+<a class="jxr_linenumber" name="808" href="#808">808</a> <strong class="jxr_keyword">final</strong> HttpResponse response,
+<a class="jxr_linenumber" name="809" href="#809">809</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> producer,
+<a class="jxr_linenumber" name="810" href="#810">810</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
+<a class="jxr_linenumber" name="811" href="#811">811</a> <strong class="jxr_keyword">this</strong>.request = request;
+<a class="jxr_linenumber" name="812" href="#812">812</a> <strong class="jxr_keyword">this</strong>.response = response;
+<a class="jxr_linenumber" name="813" href="#813">813</a> <strong class="jxr_keyword">this</strong>.producer = producer;
+<a class="jxr_linenumber" name="814" href="#814">814</a> <strong class="jxr_keyword">this</strong>.context = context;
+<a class="jxr_linenumber" name="815" href="#815">815</a> }
+<a class="jxr_linenumber" name="816" href="#816">816</a>
+<a class="jxr_linenumber" name="817" href="#817">817</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
+<a class="jxr_linenumber" name="818" href="#818">818</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
+<a class="jxr_linenumber" name="819" href="#819">819</a> }
+<a class="jxr_linenumber" name="820" href="#820">820</a>
+<a class="jxr_linenumber" name="821" href="#821">821</a> <strong class="jxr_keyword">public</strong> HttpResponse getResponse() {
+<a class="jxr_linenumber" name="822" href="#822">822</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.response;
+<a class="jxr_linenumber" name="823" href="#823">823</a> }
+<a class="jxr_linenumber" name="824" href="#824">824</a>
+<a class="jxr_linenumber" name="825" href="#825">825</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> getProducer() {
+<a class="jxr_linenumber" name="826" href="#826">826</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.producer;
+<a class="jxr_linenumber" name="827" href="#827">827</a> }
+<a class="jxr_linenumber" name="828" href="#828">828</a>
+<a class="jxr_linenumber" name="829" href="#829">829</a> <strong class="jxr_keyword">public</strong> HttpContext getContext() {
+<a class="jxr_linenumber" name="830" href="#830">830</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.context;
+<a class="jxr_linenumber" name="831" href="#831">831</a> }
+<a class="jxr_linenumber" name="832" href="#832">832</a> }
<a class="jxr_linenumber" name="833" href="#833">833</a>
-<a class="jxr_linenumber" name="834" href="#834">834</a> <strong class="jxr_keyword">public</strong> HttpContext getContext() {
-<a class="jxr_linenumber" name="835" href="#835">835</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.context;
-<a class="jxr_linenumber" name="836" href="#836">836</a> }
-<a class="jxr_linenumber" name="837" href="#837">837</a> }
-<a class="jxr_linenumber" name="838" href="#838">838</a>
-<a class="jxr_linenumber" name="839" href="#839">839</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">PipelineEntry</a> {
-<a class="jxr_linenumber" name="840" href="#840">840</a>
-<a class="jxr_linenumber" name="841" href="#841">841</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
-<a class="jxr_linenumber" name="842" href="#842">842</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Object result;
-<a class="jxr_linenumber" name="843" href="#843">843</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Exception exception;
-<a class="jxr_linenumber" name="844" href="#844">844</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler;
-<a class="jxr_linenumber" name="845" href="#845">845</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
-<a class="jxr_linenumber" name="846" href="#846">846</a>
-<a class="jxr_linenumber" name="847" href="#847">847</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">PipelineEntry</a>(
-<a class="jxr_linenumber" name="848" href="#848">848</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
-<a class="jxr_linenumber" name="849" href="#849">849</a> <strong class="jxr_keyword">final</strong> Object result,
-<a class="jxr_linenumber" name="850" href="#850">850</a> <strong class="jxr_keyword">final</strong> Exception exception,
-<a class="jxr_linenumber" name="851" href="#851">851</a> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler,
-<a class="jxr_linenumber" name="852" href="#852">852</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
-<a class="jxr_linenumber" name="853" href="#853">853</a> <strong class="jxr_keyword">this</strong>.request = request;
-<a class="jxr_linenumber" name="854" href="#854">854</a> <strong class="jxr_keyword">this</strong>.result = result;
-<a class="jxr_linenumber" name="855" href="#855">855</a> <strong class="jxr_keyword">this</strong>.exception = exception;
-<a class="jxr_linenumber" name="856" href="#856">856</a> <strong class="jxr_keyword">this</strong>.handler = handler;
-<a class="jxr_linenumber" name="857" href="#857">857</a> <strong class="jxr_keyword">this</strong>.context = context;
-<a class="jxr_linenumber" name="858" href="#858">858</a> }
-<a class="jxr_linenumber" name="859" href="#859">859</a>
-<a class="jxr_linenumber" name="860" href="#860">860</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
-<a class="jxr_linenumber" name="861" href="#861">861</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
-<a class="jxr_linenumber" name="862" href="#862">862</a> }
-<a class="jxr_linenumber" name="863" href="#863">863</a>
-<a class="jxr_linenumber" name="864" href="#864">864</a> <strong class="jxr_keyword">public</strong> Object getResult() {
-<a class="jxr_linenumber" name="865" href="#865">865</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.result;
-<a class="jxr_linenumber" name="866" href="#866">866</a> }
-<a class="jxr_linenumber" name="867" href="#867">867</a>
-<a class="jxr_linenumber" name="868" href="#868">868</a> <strong class="jxr_keyword">public</strong> Exception getException() {
-<a class="jxr_linenumber" name="869" href="#869">869</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.exception;
-<a class="jxr_linenumber" name="870" href="#870">870</a> }
-<a class="jxr_linenumber" name="871" href="#871">871</a>
-<a class="jxr_linenumber" name="872" href="#872">872</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestHandler<Object> getHandler() {
-<a class="jxr_linenumber" name="873" href="#873">873</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.handler;
-<a class="jxr_linenumber" name="874" href="#874">874</a> }
-<a class="jxr_linenumber" name="875" href="#875">875</a>
-<a class="jxr_linenumber" name="876" href="#876">876</a> <strong class="jxr_keyword">public</strong> HttpContext getContext() {
-<a class="jxr_linenumber" name="877" href="#877">877</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.context;
-<a class="jxr_linenumber" name="878" href="#878">878</a> }
-<a class="jxr_linenumber" name="879" href="#879">879</a>
-<a class="jxr_linenumber" name="880" href="#880">880</a> }
-<a class="jxr_linenumber" name="881" href="#881">881</a>
-<a class="jxr_linenumber" name="882" href="#882">882</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a> {
-<a class="jxr_linenumber" name="883" href="#883">883</a>
-<a class="jxr_linenumber" name="884" href="#884">884</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Queue<PipelineEntry> pipeline;
-<a class="jxr_linenumber" name="885" href="#885">885</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <strong class="jxr_keyword">boolean</strong> terminated;
-<a class="jxr_linenumber" name="886" href="#886">886</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> requestState;
-<a class="jxr_linenumber" name="887" href="#887">887</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> responseState;
-<a class="jxr_linenumber" name="888" href="#888">888</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> incoming;
-<a class="jxr_linenumber" name="889" href="#889">889</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> outgoing;
-<a class="jxr_linenumber" name="890" href="#890">890</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> Cancellable cancellable;
-<a class="jxr_linenumber" name="891" href="#891">891</a>
-<a class="jxr_linenumber" name="892" href="#892">892</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a>() {
-<a class="jxr_linenumber" name="893" href="#893">893</a> <strong class="jxr_keyword">super</strong>();
-<a class="jxr_linenumber" name="894" href="#894">894</a> <strong class="jxr_keyword">this</strong>.pipeline = <strong class="jxr_keyword">new</strong> ConcurrentLinkedQueue<PipelineEntry>();
-<a class="jxr_linenumber" name="895" href="#895">895</a> <strong class="jxr_keyword">this</strong>.requestState = MessageState.READY;
-<a class="jxr_linenumber" name="896" href="#896">896</a> <strong class="jxr_keyword">this</strong>.responseState = MessageState.READY;
-<a class="jxr_linenumber" name="897" href="#897">897</a> }
-<a class="jxr_linenumber" name="898" href="#898">898</a>
-<a class="jxr_linenumber" name="899" href="#899">899</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">boolean</strong> isTerminated() {
-<a class="jxr_linenumber" name="900" href="#900">900</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.terminated;
-<a class="jxr_linenumber" name="901" href="#901">901</a> }
-<a class="jxr_linenumber" name="902" href="#902">902</a>
-<a class="jxr_linenumber" name="903" href="#903">903</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setTerminated() {
-<a class="jxr_linenumber" name="904" href="#904">904</a> <strong class="jxr_keyword">this</strong>.terminated = <strong class="jxr_keyword">true</strong>;
-<a class="jxr_linenumber" name="905" href="#905">905</a> }
-<a class="jxr_linenumber" name="906" href="#906">906</a>
-<a class="jxr_linenumber" name="907" href="#907">907</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> getRequestState() {
-<a class="jxr_linenumber" name="908" href="#908">908</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.requestState;
-<a class="jxr_linenumber" name="909" href="#909">909</a> }
-<a class="jxr_linenumber" name="910" href="#910">910</a>
-<a class="jxr_linenumber" name="911" href="#911">911</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setRequestState(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> state) {
-<a class="jxr_linenumber" name="912" href="#912">912</a> <strong class="jxr_keyword">this</strong>.requestState = state;
-<a class="jxr_linenumber" name="913" href="#913">913</a> }
-<a class="jxr_linenumber" name="914" href="#914">914</a>
-<a class="jxr_linenumber" name="915" href="#915">915</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> getResponseState() {
-<a class="jxr_linenumber" name="916" href="#916">916</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.responseState;
-<a class="jxr_linenumber" name="917" href="#917">917</a> }
-<a class="jxr_linenumber" name="918" href="#918">918</a>
-<a class="jxr_linenumber" name="919" href="#919">919</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setResponseState(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> state) {
-<a class="jxr_linenumber" name="920" href="#920">920</a> <strong class="jxr_keyword">this</strong>.responseState = state;
-<a class="jxr_linenumber" name="921" href="#921">921</a> }
-<a class="jxr_linenumber" name="922" href="#922">922</a>
-<a class="jxr_linenumber" name="923" href="#923">923</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> getIncoming() {
-<a class="jxr_linenumber" name="924" href="#924">924</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.incoming;
-<a class="jxr_linenumber" name="925" href="#925">925</a> }
-<a class="jxr_linenumber" name="926" href="#926">926</a>
-<a class="jxr_linenumber" name="927" href="#927">927</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setIncoming(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> incoming) {
-<a class="jxr_linenumber" name="928" href="#928">928</a> <strong class="jxr_keyword">this</strong>.incoming = incoming;
-<a class="jxr_linenumber" name="929" href="#929">929</a> }
-<a class="jxr_linenumber" name="930" href="#930">930</a>
-<a class="jxr_linenumber" name="931" href="#931">931</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> getOutgoing() {
-<a class="jxr_linenumber" name="932" href="#932">932</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.outgoing;
-<a class="jxr_linenumber" name="933" href="#933">933</a> }
-<a class="jxr_linenumber" name="934" href="#934">934</a>
-<a class="jxr_linenumber" name="935" href="#935">935</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setOutgoing(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> outgoing) {
-<a class="jxr_linenumber" name="936" href="#936">936</a> <strong class="jxr_keyword">this</strong>.outgoing = outgoing;
-<a class="jxr_linenumber" name="937" href="#937">937</a> }
-<a class="jxr_linenumber" name="938" href="#938">938</a>
-<a class="jxr_linenumber" name="939" href="#939">939</a> <strong class="jxr_keyword">public</strong> Cancellable getCancellable() {
-<a class="jxr_linenumber" name="940" href="#940">940</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.cancellable;
-<a class="jxr_linenumber" name="941" href="#941">941</a> }
-<a class="jxr_linenumber" name="942" href="#942">942</a>
-<a class="jxr_linenumber" name="943" href="#943">943</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setCancellable(<strong class="jxr_keyword">final</strong> Cancellable cancellable) {
-<a class="jxr_linenumber" name="944" href="#944">944</a> <strong class="jxr_keyword">this</strong>.cancellable = cancellable;
-<a class="jxr_linenumber" name="945" href="#945">945</a> }
-<a class="jxr_linenumber" name="946" href="#946">946</a>
-<a class="jxr_linenumber" name="947" href="#947">947</a> <strong class="jxr_keyword">public</strong> Queue<PipelineEntry> getPipeline() {
-<a class="jxr_linenumber" name="948" href="#948">948</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.pipeline;
-<a class="jxr_linenumber" name="949" href="#949">949</a> }
-<a class="jxr_linenumber" name="950" href="#950">950</a>
-<a class="jxr_linenumber" name="951" href="#951">951</a> @Override
-<a class="jxr_linenumber" name="952" href="#952">952</a> <strong class="jxr_keyword">public</strong> String toString() {
-<a class="jxr_linenumber" name="953" href="#953">953</a> <strong class="jxr_keyword">final</strong> StringBuilder buf = <strong class="jxr_keyword">new</strong> StringBuilder();
-<a class="jxr_linenumber" name="954" href="#954">954</a> buf.append(<span class="jxr_string">"[incoming "</span>);
-<a class="jxr_linenumber" name="955" href="#955">955</a> buf.append(<strong class="jxr_keyword">this</strong>.requestState);
-<a class="jxr_linenumber" name="956" href="#956">956</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.incoming != <strong class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="957" href="#957">957</a> buf.append(<span class="jxr_string">" "</span>);
-<a class="jxr_linenumber" name="958" href="#958">958</a> buf.append(<strong class="jxr_keyword">this</strong>.incoming.getRequest().getRequestLine());
-<a class="jxr_linenumber" name="959" href="#959">959</a> }
-<a class="jxr_linenumber" name="960" href="#960">960</a> buf.append(<span class="jxr_string">"; outgoing "</span>);
-<a class="jxr_linenumber" name="961" href="#961">961</a> buf.append(<strong class="jxr_keyword">this</strong>.responseState);
-<a class="jxr_linenumber" name="962" href="#962">962</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.outgoing != <strong class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="963" href="#963">963</a> buf.append(<span class="jxr_string">" "</span>);
-<a class="jxr_linenumber" name="964" href="#964">964</a> buf.append(<strong class="jxr_keyword">this</strong>.outgoing.getResponse().getStatusLine());
-<a class="jxr_linenumber" name="965" href="#965">965</a> }
-<a class="jxr_linenumber" name="966" href="#966">966</a> buf.append(<span class="jxr_string">"]"</span>);
-<a class="jxr_linenumber" name="967" href="#967">967</a> <strong class="jxr_keyword">return</strong> buf.toString();
-<a class="jxr_linenumber" name="968" href="#968">968</a> }
-<a class="jxr_linenumber" name="969" href="#969">969</a>
-<a class="jxr_linenumber" name="970" href="#970">970</a> }
-<a class="jxr_linenumber" name="971" href="#971">971</a>
-<a class="jxr_linenumber" name="972" href="#972">972</a> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncExchangeImpl</a> <strong class="jxr_keyword">implements</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncExchange.html">HttpAsyncExchange</a> {
-<a class="jxr_linenumber" name="973" href="#973">973</a>
-<a class="jxr_linenumber" name="974" href="#974">974</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> AtomicBoolean completed = <strong class="jxr_keyword">new</strong> AtomicBoolean();
-<a class="jxr_linenumber" name="975" href="#975">975</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
-<a class="jxr_linenumber" name="976" href="#976">976</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpResponse response;
-<a class="jxr_linenumber" name="977" href="#977">977</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a> state;
-<a class="jxr_linenumber" name="978" href="#978">978</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/NHttpServerConnection.html">NHttpServerConnection</a> conn;
-<a class="jxr_linenumber" name="979" href="#979">979</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
-<a class="jxr_linenumber" name="980" href="#980">980</a>
-<a class="jxr_linenumber" name="981" href="#981">981</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncExchangeImpl</a>(
-<a class="jxr_linenumber" name="982" href="#982">982</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
-<a class="jxr_linenumber" name="983" href="#983">983</a> <strong class="jxr_keyword">final</strong> HttpResponse response,
-<a class="jxr_linenumber" name="984" href="#984">984</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a> state,
-<a class="jxr_linenumber" name="985" href="#985">985</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/NHttpServerConnection.html">NHttpServerConnection</a> conn,
-<a class="jxr_linenumber" name="986" href="#986">986</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
-<a class="jxr_linenumber" name="987" href="#987">987</a> <strong class="jxr_keyword">super</strong>();
-<a class="jxr_linenumber" name="988" href="#988">988</a> <strong class="jxr_keyword">this</strong>.request = request;
-<a class="jxr_linenumber" name="989" href="#989">989</a> <strong class="jxr_keyword">this</strong>.response = response;
-<a class="jxr_linenumber" name="990" href="#990">990</a> <strong class="jxr_keyword">this</strong>.state = state;
-<a class="jxr_linenumber" name="991" href="#991">991</a> <strong class="jxr_keyword">this</strong>.conn = conn;
-<a class="jxr_linenumber" name="992" href="#992">992</a> <strong class="jxr_keyword">this</strong>.context = context;
+<a class="jxr_linenumber" name="834" href="#834">834</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">PipelineEntry</a> {
+<a class="jxr_linenumber" name="835" href="#835">835</a>
+<a class="jxr_linenumber" name="836" href="#836">836</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
+<a class="jxr_linenumber" name="837" href="#837">837</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Object result;
+<a class="jxr_linenumber" name="838" href="#838">838</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Exception exception;
+<a class="jxr_linenumber" name="839" href="#839">839</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler;
+<a class="jxr_linenumber" name="840" href="#840">840</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
+<a class="jxr_linenumber" name="841" href="#841">841</a>
+<a class="jxr_linenumber" name="842" href="#842">842</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">PipelineEntry</a>(
+<a class="jxr_linenumber" name="843" href="#843">843</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
+<a class="jxr_linenumber" name="844" href="#844">844</a> <strong class="jxr_keyword">final</strong> Object result,
+<a class="jxr_linenumber" name="845" href="#845">845</a> <strong class="jxr_keyword">final</strong> Exception exception,
+<a class="jxr_linenumber" name="846" href="#846">846</a> <strong class="jxr_keyword">final</strong> HttpAsyncRequestHandler<Object> handler,
+<a class="jxr_linenumber" name="847" href="#847">847</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
+<a class="jxr_linenumber" name="848" href="#848">848</a> <strong class="jxr_keyword">this</strong>.request = request;
+<a class="jxr_linenumber" name="849" href="#849">849</a> <strong class="jxr_keyword">this</strong>.result = result;
+<a class="jxr_linenumber" name="850" href="#850">850</a> <strong class="jxr_keyword">this</strong>.exception = exception;
+<a class="jxr_linenumber" name="851" href="#851">851</a> <strong class="jxr_keyword">this</strong>.handler = handler;
+<a class="jxr_linenumber" name="852" href="#852">852</a> <strong class="jxr_keyword">this</strong>.context = context;
+<a class="jxr_linenumber" name="853" href="#853">853</a> }
+<a class="jxr_linenumber" name="854" href="#854">854</a>
+<a class="jxr_linenumber" name="855" href="#855">855</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
+<a class="jxr_linenumber" name="856" href="#856">856</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
+<a class="jxr_linenumber" name="857" href="#857">857</a> }
+<a class="jxr_linenumber" name="858" href="#858">858</a>
+<a class="jxr_linenumber" name="859" href="#859">859</a> <strong class="jxr_keyword">public</strong> Object getResult() {
+<a class="jxr_linenumber" name="860" href="#860">860</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.result;
+<a class="jxr_linenumber" name="861" href="#861">861</a> }
+<a class="jxr_linenumber" name="862" href="#862">862</a>
+<a class="jxr_linenumber" name="863" href="#863">863</a> <strong class="jxr_keyword">public</strong> Exception getException() {
+<a class="jxr_linenumber" name="864" href="#864">864</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.exception;
+<a class="jxr_linenumber" name="865" href="#865">865</a> }
+<a class="jxr_linenumber" name="866" href="#866">866</a>
+<a class="jxr_linenumber" name="867" href="#867">867</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestHandler<Object> getHandler() {
+<a class="jxr_linenumber" name="868" href="#868">868</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.handler;
+<a class="jxr_linenumber" name="869" href="#869">869</a> }
+<a class="jxr_linenumber" name="870" href="#870">870</a>
+<a class="jxr_linenumber" name="871" href="#871">871</a> <strong class="jxr_keyword">public</strong> HttpContext getContext() {
+<a class="jxr_linenumber" name="872" href="#872">872</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.context;
+<a class="jxr_linenumber" name="873" href="#873">873</a> }
+<a class="jxr_linenumber" name="874" href="#874">874</a>
+<a class="jxr_linenumber" name="875" href="#875">875</a> }
+<a class="jxr_linenumber" name="876" href="#876">876</a>
+<a class="jxr_linenumber" name="877" href="#877">877</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a> {
+<a class="jxr_linenumber" name="878" href="#878">878</a>
+<a class="jxr_linenumber" name="879" href="#879">879</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Queue<PipelineEntry> pipeline;
+<a class="jxr_linenumber" name="880" href="#880">880</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <strong class="jxr_keyword">boolean</strong> terminated;
+<a class="jxr_linenumber" name="881" href="#881">881</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> requestState;
+<a class="jxr_linenumber" name="882" href="#882">882</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> responseState;
+<a class="jxr_linenumber" name="883" href="#883">883</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> incoming;
+<a class="jxr_linenumber" name="884" href="#884">884</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> outgoing;
+<a class="jxr_linenumber" name="885" href="#885">885</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">volatile</strong> Cancellable cancellable;
+<a class="jxr_linenumber" name="886" href="#886">886</a>
+<a class="jxr_linenumber" name="887" href="#887">887</a> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a>() {
+<a class="jxr_linenumber" name="888" href="#888">888</a> <strong class="jxr_keyword">super</strong>();
+<a class="jxr_linenumber" name="889" href="#889">889</a> <strong class="jxr_keyword">this</strong>.pipeline = <strong class="jxr_keyword">new</strong> ConcurrentLinkedQueue<PipelineEntry>();
+<a class="jxr_linenumber" name="890" href="#890">890</a> <strong class="jxr_keyword">this</strong>.requestState = MessageState.READY;
+<a class="jxr_linenumber" name="891" href="#891">891</a> <strong class="jxr_keyword">this</strong>.responseState = MessageState.READY;
+<a class="jxr_linenumber" name="892" href="#892">892</a> }
+<a class="jxr_linenumber" name="893" href="#893">893</a>
+<a class="jxr_linenumber" name="894" href="#894">894</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">boolean</strong> isTerminated() {
+<a class="jxr_linenumber" name="895" href="#895">895</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.terminated;
+<a class="jxr_linenumber" name="896" href="#896">896</a> }
+<a class="jxr_linenumber" name="897" href="#897">897</a>
+<a class="jxr_linenumber" name="898" href="#898">898</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setTerminated() {
+<a class="jxr_linenumber" name="899" href="#899">899</a> <strong class="jxr_keyword">this</strong>.terminated = <strong class="jxr_keyword">true</strong>;
+<a class="jxr_linenumber" name="900" href="#900">900</a> }
+<a class="jxr_linenumber" name="901" href="#901">901</a>
+<a class="jxr_linenumber" name="902" href="#902">902</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> getRequestState() {
+<a class="jxr_linenumber" name="903" href="#903">903</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.requestState;
+<a class="jxr_linenumber" name="904" href="#904">904</a> }
+<a class="jxr_linenumber" name="905" href="#905">905</a>
+<a class="jxr_linenumber" name="906" href="#906">906</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setRequestState(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> state) {
+<a class="jxr_linenumber" name="907" href="#907">907</a> <strong class="jxr_keyword">this</strong>.requestState = state;
+<a class="jxr_linenumber" name="908" href="#908">908</a> }
+<a class="jxr_linenumber" name="909" href="#909">909</a>
+<a class="jxr_linenumber" name="910" href="#910">910</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> getResponseState() {
+<a class="jxr_linenumber" name="911" href="#911">911</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.responseState;
+<a class="jxr_linenumber" name="912" href="#912">912</a> }
+<a class="jxr_linenumber" name="913" href="#913">913</a>
+<a class="jxr_linenumber" name="914" href="#914">914</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setResponseState(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/MessageState.html">MessageState</a> state) {
+<a class="jxr_linenumber" name="915" href="#915">915</a> <strong class="jxr_keyword">this</strong>.responseState = state;
+<a class="jxr_linenumber" name="916" href="#916">916</a> }
+<a class="jxr_linenumber" name="917" href="#917">917</a>
+<a class="jxr_linenumber" name="918" href="#918">918</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> getIncoming() {
+<a class="jxr_linenumber" name="919" href="#919">919</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.incoming;
+<a class="jxr_linenumber" name="920" href="#920">920</a> }
+<a class="jxr_linenumber" name="921" href="#921">921</a>
+<a class="jxr_linenumber" name="922" href="#922">922</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setIncoming(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Incoming</a> incoming) {
+<a class="jxr_linenumber" name="923" href="#923">923</a> <strong class="jxr_keyword">this</strong>.incoming = incoming;
+<a class="jxr_linenumber" name="924" href="#924">924</a> }
+<a class="jxr_linenumber" name="925" href="#925">925</a>
+<a class="jxr_linenumber" name="926" href="#926">926</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> getOutgoing() {
+<a class="jxr_linenumber" name="927" href="#927">927</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.outgoing;
+<a class="jxr_linenumber" name="928" href="#928">928</a> }
+<a class="jxr_linenumber" name="929" href="#929">929</a>
+<a class="jxr_linenumber" name="930" href="#930">930</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setOutgoing(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> outgoing) {
+<a class="jxr_linenumber" name="931" href="#931">931</a> <strong class="jxr_keyword">this</strong>.outgoing = outgoing;
+<a class="jxr_linenumber" name="932" href="#932">932</a> }
+<a class="jxr_linenumber" name="933" href="#933">933</a>
+<a class="jxr_linenumber" name="934" href="#934">934</a> <strong class="jxr_keyword">public</strong> Cancellable getCancellable() {
+<a class="jxr_linenumber" name="935" href="#935">935</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.cancellable;
+<a class="jxr_linenumber" name="936" href="#936">936</a> }
+<a class="jxr_linenumber" name="937" href="#937">937</a>
+<a class="jxr_linenumber" name="938" href="#938">938</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setCancellable(<strong class="jxr_keyword">final</strong> Cancellable cancellable) {
+<a class="jxr_linenumber" name="939" href="#939">939</a> <strong class="jxr_keyword">this</strong>.cancellable = cancellable;
+<a class="jxr_linenumber" name="940" href="#940">940</a> }
+<a class="jxr_linenumber" name="941" href="#941">941</a>
+<a class="jxr_linenumber" name="942" href="#942">942</a> <strong class="jxr_keyword">public</strong> Queue<PipelineEntry> getPipeline() {
+<a class="jxr_linenumber" name="943" href="#943">943</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.pipeline;
+<a class="jxr_linenumber" name="944" href="#944">944</a> }
+<a class="jxr_linenumber" name="945" href="#945">945</a>
+<a class="jxr_linenumber" name="946" href="#946">946</a> @Override
+<a class="jxr_linenumber" name="947" href="#947">947</a> <strong class="jxr_keyword">public</strong> String toString() {
+<a class="jxr_linenumber" name="948" href="#948">948</a> <strong class="jxr_keyword">final</strong> StringBuilder buf = <strong class="jxr_keyword">new</strong> StringBuilder();
+<a class="jxr_linenumber" name="949" href="#949">949</a> buf.append(<span class="jxr_string">"[incoming "</span>);
+<a class="jxr_linenumber" name="950" href="#950">950</a> buf.append(<strong class="jxr_keyword">this</strong>.requestState);
+<a class="jxr_linenumber" name="951" href="#951">951</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.incoming != <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="952" href="#952">952</a> buf.append(<span class="jxr_string">" "</span>);
+<a class="jxr_linenumber" name="953" href="#953">953</a> buf.append(<strong class="jxr_keyword">this</strong>.incoming.getRequest().getRequestLine());
+<a class="jxr_linenumber" name="954" href="#954">954</a> }
+<a class="jxr_linenumber" name="955" href="#955">955</a> buf.append(<span class="jxr_string">"; outgoing "</span>);
+<a class="jxr_linenumber" name="956" href="#956">956</a> buf.append(<strong class="jxr_keyword">this</strong>.responseState);
+<a class="jxr_linenumber" name="957" href="#957">957</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.outgoing != <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="958" href="#958">958</a> buf.append(<span class="jxr_string">" "</span>);
+<a class="jxr_linenumber" name="959" href="#959">959</a> buf.append(<strong class="jxr_keyword">this</strong>.outgoing.getResponse().getStatusLine());
+<a class="jxr_linenumber" name="960" href="#960">960</a> }
+<a class="jxr_linenumber" name="961" href="#961">961</a> buf.append(<span class="jxr_string">"]"</span>);
+<a class="jxr_linenumber" name="962" href="#962">962</a> <strong class="jxr_keyword">return</strong> buf.toString();
+<a class="jxr_linenumber" name="963" href="#963">963</a> }
+<a class="jxr_linenumber" name="964" href="#964">964</a>
+<a class="jxr_linenumber" name="965" href="#965">965</a> }
+<a class="jxr_linenumber" name="966" href="#966">966</a>
+<a class="jxr_linenumber" name="967" href="#967">967</a> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncExchangeImpl</a> <strong class="jxr_keyword">implements</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncExchange.html">HttpAsyncExchange</a> {
+<a class="jxr_linenumber" name="968" href="#968">968</a>
+<a class="jxr_linenumber" name="969" href="#969">969</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> AtomicBoolean completed = <strong class="jxr_keyword">new</strong> AtomicBoolean();
+<a class="jxr_linenumber" name="970" href="#970">970</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpRequest request;
+<a class="jxr_linenumber" name="971" href="#971">971</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpResponse response;
+<a class="jxr_linenumber" name="972" href="#972">972</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a> state;
+<a class="jxr_linenumber" name="973" href="#973">973</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/NHttpServerConnection.html">NHttpServerConnection</a> conn;
+<a class="jxr_linenumber" name="974" href="#974">974</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpContext context;
+<a class="jxr_linenumber" name="975" href="#975">975</a>
+<a class="jxr_linenumber" name="976" href="#976">976</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncExchangeImpl</a>(
+<a class="jxr_linenumber" name="977" href="#977">977</a> <strong class="jxr_keyword">final</strong> HttpRequest request,
+<a class="jxr_linenumber" name="978" href="#978">978</a> <strong class="jxr_keyword">final</strong> HttpResponse response,
+<a class="jxr_linenumber" name="979" href="#979">979</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">State</a> state,
+<a class="jxr_linenumber" name="980" href="#980">980</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/NHttpServerConnection.html">NHttpServerConnection</a> conn,
+<a class="jxr_linenumber" name="981" href="#981">981</a> <strong class="jxr_keyword">final</strong> HttpContext context) {
+<a class="jxr_linenumber" name="982" href="#982">982</a> <strong class="jxr_keyword">super</strong>();
+<a class="jxr_linenumber" name="983" href="#983">983</a> <strong class="jxr_keyword">this</strong>.request = request;
+<a class="jxr_linenumber" name="984" href="#984">984</a> <strong class="jxr_keyword">this</strong>.response = response;
+<a class="jxr_linenumber" name="985" href="#985">985</a> <strong class="jxr_keyword">this</strong>.state = state;
+<a class="jxr_linenumber" name="986" href="#986">986</a> <strong class="jxr_keyword">this</strong>.conn = conn;
+<a class="jxr_linenumber" name="987" href="#987">987</a> <strong class="jxr_keyword">this</strong>.context = context;
+<a class="jxr_linenumber" name="988" href="#988">988</a> }
+<a class="jxr_linenumber" name="989" href="#989">989</a>
+<a class="jxr_linenumber" name="990" href="#990">990</a> @Override
+<a class="jxr_linenumber" name="991" href="#991">991</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
+<a class="jxr_linenumber" name="992" href="#992">992</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
<a class="jxr_linenumber" name="993" href="#993">993</a> }
<a class="jxr_linenumber" name="994" href="#994">994</a>
<a class="jxr_linenumber" name="995" href="#995">995</a> @Override
-<a class="jxr_linenumber" name="996" href="#996">996</a> <strong class="jxr_keyword">public</strong> HttpRequest getRequest() {
-<a class="jxr_linenumber" name="997" href="#997">997</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.request;
+<a class="jxr_linenumber" name="996" href="#996">996</a> <strong class="jxr_keyword">public</strong> HttpResponse getResponse() {
+<a class="jxr_linenumber" name="997" href="#997">997</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.response;
<a class="jxr_linenumber" name="998" href="#998">998</a> }
<a class="jxr_linenumber" name="999" href="#999">999</a>
<a class="jxr_linenumber" name="1000" href="#1000">1000</a> @Override
-<a class="jxr_linenumber" name="1001" href="#1001">1001</a> <strong class="jxr_keyword">public</strong> HttpResponse getResponse() {
-<a class="jxr_linenumber" name="1002" href="#1002">1002</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.response;
-<a class="jxr_linenumber" name="1003" href="#1003">1003</a> }
-<a class="jxr_linenumber" name="1004" href="#1004">1004</a>
-<a class="jxr_linenumber" name="1005" href="#1005">1005</a> @Override
-<a class="jxr_linenumber" name="1006" href="#1006">1006</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setCallback(<strong class="jxr_keyword">final</strong> Cancellable cancellable) {
-<a class="jxr_linenumber" name="1007" href="#1007">1007</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.completed.get()) {
-<a class="jxr_linenumber" name="1008" href="#1008">1008</a> handleAlreadySubmittedResponse(cancellable, context);
-<a class="jxr_linenumber" name="1009" href="#1009">1009</a> } <strong class="jxr_keyword">else</strong> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.state.isTerminated() && cancellable != <strong class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="1010" href="#1010">1010</a> cancellable.cancel();
-<a class="jxr_linenumber" name="1011" href="#1011">1011</a> } <strong class="jxr_keyword">else</strong> {
-<a class="jxr_linenumber" name="1012" href="#1012">1012</a> <strong class="jxr_keyword">this</strong>.state.setCancellable(cancellable);
-<a class="jxr_linenumber" name="1013" href="#1013">1013</a> }
-<a class="jxr_linenumber" name="1014" href="#1014">1014</a> }
-<a class="jxr_linenumber" name="1015" href="#1015">1015</a>
-<a class="jxr_linenumber" name="1016" href="#1016">1016</a> @Override
-<a class="jxr_linenumber" name="1017" href="#1017">1017</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> submitResponse(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> responseProducer) {
-<a class="jxr_linenumber" name="1018" href="#1018">1018</a> Args.notNull(responseProducer, <span class="jxr_string">"Response producer"</span>);
-<a class="jxr_linenumber" name="1019" href="#1019">1019</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.completed.getAndSet(<strong class="jxr_keyword">true</strong>)) {
-<a class="jxr_linenumber" name="1020" href="#1020">1020</a> handleAlreadySubmittedResponse(responseProducer, context);
-<a class="jxr_linenumber" name="1021" href="#1021">1021</a> } <strong class="jxr_keyword">else</strong> <strong class="jxr_keyword">if</strong> (!<strong class="jxr_keyword">this</strong>.state.isTerminated()) {
-<a class="jxr_linenumber" name="1022" href="#1022">1022</a> <strong class="jxr_keyword">final</strong> HttpResponse response = responseProducer.generateResponse();
-<a class="jxr_linenumber" name="1023" href="#1023">1023</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> outgoing = <strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a>(
-<a class="jxr_linenumber" name="1024" href="#1024">1024</a> <strong class="jxr_keyword">this</strong>.request, response, responseProducer, <strong class="jxr_keyword">this</strong>.context);
-<a class="jxr_linenumber" name="1025" href="#1025">1025</a>
-<a class="jxr_linenumber" name="1026" href="#1026">1026</a> <strong class="jxr_keyword">synchronized</strong> (<strong class="jxr_keyword">this</strong>.state) {
-<a class="jxr_linenumber" name="1027" href="#1027">1027</a> <strong class="jxr_keyword">this</strong>.state.setOutgoing(outgoing);
-<a class="jxr_linenumber" name="1028" href="#1028">1028</a> <strong class="jxr_keyword">this</strong>.state.setCancellable(<strong class="jxr_keyword">null</strong>);
-<a class="jxr_linenumber" name="1029" href="#1029">1029</a> <strong class="jxr_keyword">this</strong>.conn.requestOutput();
-<a class="jxr_linenumber" name="1030" href="#1030">1030</a> }
-<a class="jxr_linenumber" name="1031" href="#1031">1031</a>
-<a class="jxr_linenumber" name="1032" href="#1032">1032</a> } <strong class="jxr_keyword">else</strong> {
-<a class="jxr_linenumber" name="1033" href="#1033">1033</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="1034" href="#1034">1034</a> responseProducer.close();
-<a class="jxr_linenumber" name="1035" href="#1035">1035</a> } <strong class="jxr_keyword">catch</strong> (<strong class="jxr_keyword">final</strong> IOException ex) {
-<a class="jxr_linenumber" name="1036" href="#1036">1036</a> log(ex);
-<a class="jxr_linenumber" name="1037" href="#1037">1037</a> }
-<a class="jxr_linenumber" name="1038" href="#1038">1038</a> }
+<a class="jxr_linenumber" name="1001" href="#1001">1001</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setCallback(<strong class="jxr_keyword">final</strong> Cancellable cancellable) {
+<a class="jxr_linenumber" name="1002" href="#1002">1002</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.completed.get()) {
+<a class="jxr_linenumber" name="1003" href="#1003">1003</a> handleAlreadySubmittedResponse(cancellable, context);
+<a class="jxr_linenumber" name="1004" href="#1004">1004</a> } <strong class="jxr_keyword">else</strong> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.state.isTerminated() && cancellable != <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="1005" href="#1005">1005</a> cancellable.cancel();
+<a class="jxr_linenumber" name="1006" href="#1006">1006</a> } <strong class="jxr_keyword">else</strong> {
+<a class="jxr_linenumber" name="1007" href="#1007">1007</a> <strong class="jxr_keyword">this</strong>.state.setCancellable(cancellable);
+<a class="jxr_linenumber" name="1008" href="#1008">1008</a> }
+<a class="jxr_linenumber" name="1009" href="#1009">1009</a> }
+<a class="jxr_linenumber" name="1010" href="#1010">1010</a>
+<a class="jxr_linenumber" name="1011" href="#1011">1011</a> @Override
+<a class="jxr_linenumber" name="1012" href="#1012">1012</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> submitResponse(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncResponseProducer.html">HttpAsyncResponseProducer</a> responseProducer) {
+<a class="jxr_linenumber" name="1013" href="#1013">1013</a> Args.notNull(responseProducer, <span class="jxr_string">"Response producer"</span>);
+<a class="jxr_linenumber" name="1014" href="#1014">1014</a> <strong class="jxr_keyword">if</strong> (<strong class="jxr_keyword">this</strong>.completed.getAndSet(<strong class="jxr_keyword">true</strong>)) {
+<a class="jxr_linenumber" name="1015" href="#1015">1015</a> handleAlreadySubmittedResponse(responseProducer, context);
+<a class="jxr_linenumber" name="1016" href="#1016">1016</a> } <strong class="jxr_keyword">else</strong> <strong class="jxr_keyword">if</strong> (!<strong class="jxr_keyword">this</strong>.state.isTerminated()) {
+<a class="jxr_linenumber" name="1017" href="#1017">1017</a> <strong class="jxr_keyword">final</strong> HttpResponse response = responseProducer.generateResponse();
+<a class="jxr_linenumber" name="1018" href="#1018">1018</a> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a> outgoing = <strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">Outgoing</a>(
+<a class="jxr_linenumber" name="1019" href="#1019">1019</a> <strong class="jxr_keyword">this</strong>.request, response, responseProducer, <strong class="jxr_keyword">this</strong>.context);
+<a class="jxr_linenumber" name="1020" href="#1020">1020</a>
+<a class="jxr_linenumber" name="1021" href="#1021">1021</a> <strong class="jxr_keyword">synchronized</strong> (<strong class="jxr_keyword">this</strong>.state) {
+<a class="jxr_linenumber" name="1022" href="#1022">1022</a> <strong class="jxr_keyword">this</strong>.state.setOutgoing(outgoing);
+<a class="jxr_linenumber" name="1023" href="#1023">1023</a> <strong class="jxr_keyword">this</strong>.state.setCancellable(<strong class="jxr_keyword">null</strong>);
+<a class="jxr_linenumber" name="1024" href="#1024">1024</a> <strong class="jxr_keyword">this</strong>.conn.requestOutput();
+<a class="jxr_linenumber" name="1025" href="#1025">1025</a> }
+<a class="jxr_linenumber" name="1026" href="#1026">1026</a>
+<a class="jxr_linenumber" name="1027" href="#1027">1027</a> } <strong class="jxr_keyword">else</strong> {
+<a class="jxr_linenumber" name="1028" href="#1028">1028</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="1029" href="#1029">1029</a> responseProducer.close();
+<a class="jxr_linenumber" name="1030" href="#1030">1030</a> } <strong class="jxr_keyword">catch</strong> (<strong class="jxr_keyword">final</strong> IOException ex) {
+<a class="jxr_linenumber" name="1031" href="#1031">1031</a> log(ex);
+<a class="jxr_linenumber" name="1032" href="#1032">1032</a> }
+<a class="jxr_linenumber" name="1033" href="#1033">1033</a> }
+<a class="jxr_linenumber" name="1034" href="#1034">1034</a> }
+<a class="jxr_linenumber" name="1035" href="#1035">1035</a>
+<a class="jxr_linenumber" name="1036" href="#1036">1036</a> @Override
+<a class="jxr_linenumber" name="1037" href="#1037">1037</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> submitResponse() {
+<a class="jxr_linenumber" name="1038" href="#1038">1038</a> submitResponse(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/http/nio/protocol/BasicAsyncResponseProducer.html">BasicAsyncResponseProducer</a>(<strong class="jxr_keyword">this</strong>.response));
<a class="jxr_linenumber" name="1039" href="#1039">1039</a> }
<a class="jxr_linenumber" name="1040" href="#1040">1040</a>
<a class="jxr_linenumber" name="1041" href="#1041">1041</a> @Override
-<a class="jxr_linenumber" name="1042" href="#1042">1042</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> submitResponse() {
-<a class="jxr_linenumber" name="1043" href="#1043">1043</a> submitResponse(<strong class="jxr_keyword">new</strong> <a href="../../../../../org/apache/http/nio/protocol/BasicAsyncResponseProducer.html">BasicAsyncResponseProducer</a>(<strong class="jxr_keyword">this</strong>.response));
+<a class="jxr_linenumber" name="1042" href="#1042">1042</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">boolean</strong> isCompleted() {
+<a class="jxr_linenumber" name="1043" href="#1043">1043</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.completed.get();
<a class="jxr_linenumber" name="1044" href="#1044">1044</a> }
<a class="jxr_linenumber" name="1045" href="#1045">1045</a>
<a class="jxr_linenumber" name="1046" href="#1046">1046</a> @Override
-<a class="jxr_linenumber" name="1047" href="#1047">1047</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">boolean</strong> isCompleted() {
-<a class="jxr_linenumber" name="1048" href="#1048">1048</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.completed.get();
+<a class="jxr_linenumber" name="1047" href="#1047">1047</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setTimeout(<strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> timeout) {
+<a class="jxr_linenumber" name="1048" href="#1048">1048</a> <strong class="jxr_keyword">this</strong>.conn.setSocketTimeout(timeout);
<a class="jxr_linenumber" name="1049" href="#1049">1049</a> }
<a class="jxr_linenumber" name="1050" href="#1050">1050</a>
<a class="jxr_linenumber" name="1051" href="#1051">1051</a> @Override
-<a class="jxr_linenumber" name="1052" href="#1052">1052</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setTimeout(<strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> timeout) {
-<a class="jxr_linenumber" name="1053" href="#1053">1053</a> <strong class="jxr_keyword">this</strong>.conn.setSocketTimeout(timeout);
+<a class="jxr_linenumber" name="1052" href="#1052">1052</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">int</strong> getTimeout() {
+<a class="jxr_linenumber" name="1053" href="#1053">1053</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.conn.getSocketTimeout();
<a class="jxr_linenumber" name="1054" href="#1054">1054</a> }
<a class="jxr_linenumber" name="1055" href="#1055">1055</a>
-<a class="jxr_linenumber" name="1056" href="#1056">1056</a> @Override
-<a class="jxr_linenumber" name="1057" href="#1057">1057</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">int</strong> getTimeout() {
-<a class="jxr_linenumber" name="1058" href="#1058">1058</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">this</strong>.conn.getSocketTimeout();
-<a class="jxr_linenumber" name="1059" href="#1059">1059</a> }
-<a class="jxr_linenumber" name="1060" href="#1060">1060</a>
-<a class="jxr_linenumber" name="1061" href="#1061">1061</a> }
-<a class="jxr_linenumber" name="1062" href="#1062">1062</a>
-<a class="jxr_linenumber" name="1063" href="#1063">1063</a> <em class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="1064" href="#1064">1064</a> <em class="jxr_javadoccomment"> * Adaptor class to transition from HttpAsyncRequestHandlerResolver to HttpAsyncRequestHandlerMapper.</em>
-<a class="jxr_linenumber" name="1065" href="#1065">1065</a> <em class="jxr_javadoccomment"> */</em>
-<a class="jxr_linenumber" name="1066" href="#1066">1066</a> @Deprecated
-<a class="jxr_linenumber" name="1067" href="#1067">1067</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncRequestHandlerResolverAdapter</a> <strong class="jxr_keyword">implements</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncRequestHandlerMapper.html">HttpAsyncRequestHandlerMapper</a> {
-<a class="jxr_linenumber" name="1068" href="#1068">1068</a>
-<a class="jxr_linenumber" name="1069" href="#1069">1069</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncRequestHandlerResolver.html">HttpAsyncRequestHandlerResolver</a> resolver;
-<a class="jxr_linenumber" name="1070" href="#1070">1070</a>
-<a class="jxr_linenumber" name="1071" href="#1071">1071</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncRequestHandlerResolverAdapter</a>(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncRequestHandlerResolver.html">HttpAsyncRequestHandlerResolver</a> resolver) {
-<a class="jxr_linenumber" name="1072" href="#1072">1072</a> <strong class="jxr_keyword">this</strong>.resolver = resolver;
+<a class="jxr_linenumber" name="1056" href="#1056">1056</a> }
+<a class="jxr_linenumber" name="1057" href="#1057">1057</a>
+<a class="jxr_linenumber" name="1058" href="#1058">1058</a> <em class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="1059" href="#1059">1059</a> <em class="jxr_javadoccomment"> * Adaptor class to transition from HttpAsyncRequestHandlerResolver to HttpAsyncRequestHandlerMapper.</em>
+<a class="jxr_linenumber" name="1060" href="#1060">1060</a> <em class="jxr_javadoccomment"> */</em>
+<a class="jxr_linenumber" name="1061" href="#1061">1061</a> @Deprecated
+<a class="jxr_linenumber" name="1062" href="#1062">1062</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncRequestHandlerResolverAdapter</a> <strong class="jxr_keyword">implements</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncRequestHandlerMapper.html">HttpAsyncRequestHandlerMapper</a> {
+<a class="jxr_linenumber" name="1063" href="#1063">1063</a>
+<a class="jxr_linenumber" name="1064" href="#1064">1064</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncRequestHandlerResolver.html">HttpAsyncRequestHandlerResolver</a> resolver;
+<a class="jxr_linenumber" name="1065" href="#1065">1065</a>
+<a class="jxr_linenumber" name="1066" href="#1066">1066</a> <strong class="jxr_keyword">public</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncService.html">HttpAsyncRequestHandlerResolverAdapter</a>(<strong class="jxr_keyword">final</strong> <a href="../../../../../org/apache/http/nio/protocol/HttpAsyncRequestHandlerResolver.html">HttpAsyncRequestHandlerResolver</a> resolver) {
+<a class="jxr_linenumber" name="1067" href="#1067">1067</a> <strong class="jxr_keyword">this</strong>.resolver = resolver;
+<a class="jxr_linenumber" name="1068" href="#1068">1068</a> }
+<a class="jxr_linenumber" name="1069" href="#1069">1069</a>
+<a class="jxr_linenumber" name="1070" href="#1070">1070</a> @Override
+<a class="jxr_linenumber" name="1071" href="#1071">1071</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestHandler<?> lookup(<strong class="jxr_keyword">final</strong> HttpRequest request) {
+<a class="jxr_linenumber" name="1072" href="#1072">1072</a> <strong class="jxr_keyword">return</strong> resolver.lookup(request.getRequestLine().getUri());
<a class="jxr_linenumber" name="1073" href="#1073">1073</a> }
<a class="jxr_linenumber" name="1074" href="#1074">1074</a>
-<a class="jxr_linenumber" name="1075" href="#1075">1075</a> @Override
-<a class="jxr_linenumber" name="1076" href="#1076">1076</a> <strong class="jxr_keyword">public</strong> HttpAsyncRequestHandler<?> lookup(<strong class="jxr_keyword">final</strong> HttpRequest request) {
-<a class="jxr_linenumber" name="1077" href="#1077">1077</a> <strong class="jxr_keyword">return</strong> resolver.lookup(request.getRequestLine().getUri());
-<a class="jxr_linenumber" name="1078" href="#1078">1078</a> }
-<a class="jxr_linenumber" name="1079" href="#1079">1079</a>
-<a class="jxr_linenumber" name="1080" href="#1080">1080</a> }
-<a class="jxr_linenumber" name="1081" href="#1081">1081</a>
-<a class="jxr_linenumber" name="1082" href="#1082">1082</a> }
+<a class="jxr_linenumber" name="1075" href="#1075">1075</a> }
+<a class="jxr_linenumber" name="1076" href="#1076">1076</a>
+<a class="jxr_linenumber" name="1077" href="#1077">1077</a> }
</pre>
<hr/><div id="footer">This page was automatically generated by <a href="http://maven.apache.org/">Maven</a></div></body>
</html>
Modified: httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-frame.html
URL: http://svn.apache.org/viewvc/httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-frame.html?rev=1711465&r1=1711464&r2=1711465&view=diff
==============================================================================
--- httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-frame.html (original)
+++ httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-frame.html Fri Oct 30 13:05:47 2015
@@ -3,7 +3,7 @@
<html xml:lang="en" lang="en">
<head>
<meta http-equiv="content-type" content="text/html; charset=UTF-8" />
- <title>Apache HttpCore NIO 4.4.3 Reference Package org.apache.http.nio.protocol</title>
+ <title>Apache HttpCore NIO 4.4.4 Reference Package org.apache.http.nio.protocol</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="style" />
</head>
<body>
Modified: httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-summary.html
URL: http://svn.apache.org/viewvc/httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-summary.html?rev=1711465&r1=1711464&r2=1711465&view=diff
==============================================================================
--- httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-summary.html (original)
+++ httpcomponents/site/httpcomponents-core-4.4.x/httpcore-nio/xref/org/apache/http/nio/protocol/package-summary.html Fri Oct 30 13:05:47 2015
@@ -3,7 +3,7 @@
<html xml:lang="en" lang="en">
<head>
<meta http-equiv="content-type" content="text/html; charset=UTF-8" />
- <title>Apache HttpCore NIO 4.4.3 Reference Package org.apache.http.nio.protocol</title>
+ <title>Apache HttpCore NIO 4.4.4 Reference Package org.apache.http.nio.protocol</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="style" />
</head>
<body>