hc-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ol...@apache.org
Subject 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...
Date Fri, 30 Oct 2015 13:06:04 GMT
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&lt;PipelineEntry&gt; 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&lt;Object&gt; getRequestHandler(<strong class="jxr_keyword">final</strong> HttpRequest request) {
-<a class="jxr_linenumber" name="759" href="#759">759</a>         HttpAsyncRequestHandler&lt;Object&gt; 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&lt;Object&gt;) <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&lt;Object&gt; getRequestHandler(<strong class="jxr_keyword">final</strong> HttpRequest request) {
+<a class="jxr_linenumber" name="754" href="#754">754</a>         HttpAsyncRequestHandler&lt;Object&gt; 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&lt;Object&gt;) <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&lt;Object&gt; handler;
+<a class="jxr_linenumber" name="768" href="#768">768</a>         <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer&lt;Object&gt; 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&lt;Object&gt; handler;
-<a class="jxr_linenumber" name="773" href="#773">773</a>         <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer&lt;Object&gt; 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&lt;Object&gt; handler,
-<a class="jxr_linenumber" name="779" href="#779">779</a>                 <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; handler,
+<a class="jxr_linenumber" name="774" href="#774">774</a>                 <strong class="jxr_keyword">final</strong> HttpAsyncRequestConsumer&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;PipelineEntry&gt; 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&lt;PipelineEntry&gt;();
-<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&lt;PipelineEntry&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;Object&gt; 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&lt;PipelineEntry&gt; 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&lt;PipelineEntry&gt;();
+<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&lt;PipelineEntry&gt; 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() &amp;&amp; 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() &amp;&amp; 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&lt;?&gt; 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&lt;?&gt; 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>




Mime
View raw message