svn commit: r1000189 [37/39] - in /websites/production/mina/content/mina-project: apidocs/ apidocs/org/apache/mina/core/ apidocs/org/apache/mina/core/buffer/ apidocs/org/apache/mina/core/buffer/class-use/ apidocs/org/apache/mina/core/class-use/ apidocs...

[elecharny]

Modified: 
websites/production/mina/content/mina-project/xref/org/apache/mina/core/session/AbstractIoSession.html
==============================================================================
--- 
websites/production/mina/content/mina-project/xref/org/apache/mina/core/session/AbstractIoSession.html
 (original)
+++ 
websites/production/mina/content/mina-project/xref/org/apache/mina/core/session/AbstractIoSession.html
 Mon Oct 31 10:43:06 2016
@@ -374,1066 +374,1069 @@
 <a class="jxr_linenumber" name="L366" href="#L366">366</a>         <strong 
class="jxr_keyword">if</strong> (writeRequestQueue != <strong 
class="jxr_keyword">null</strong>) {
 <a class="jxr_linenumber" name="L367" href="#L367">367</a>             <strong 
class="jxr_keyword">while</strong> (!writeRequestQueue.isEmpty(<strong 
class="jxr_keyword">this</strong>)) {
 <a class="jxr_linenumber" name="L368" href="#L368">368</a>                 <a 
href="../../../../../org/apache/mina/core/write/WriteRequest.html">WriteRequest</a>
 writeRequest = writeRequestQueue.poll(<strong 
class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L369" href="#L369">369</a>                 <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 writeFuture = writeRequest.getFuture();
-<a class="jxr_linenumber" name="L370" href="#L370">370</a>                 
-<a class="jxr_linenumber" name="L371" href="#L371">371</a>                 <em 
class="jxr_comment">// The WriteRequest may not always have a future : The 
CLOSE_REQUEST</em>
-<a class="jxr_linenumber" name="L372" href="#L372">372</a>                 <em 
class="jxr_comment">// and MESSAGE_SENT_REQUEST don't.</em>
-<a class="jxr_linenumber" name="L373" href="#L373">373</a>                 
<strong class="jxr_keyword">if</strong> (writeFuture != <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L374" href="#L374">374</a>                     
writeFuture.setWritten();
-<a class="jxr_linenumber" name="L375" href="#L375">375</a>                 }
-<a class="jxr_linenumber" name="L376" href="#L376">376</a>             }
-<a class="jxr_linenumber" name="L377" href="#L377">377</a>         }
-<a class="jxr_linenumber" name="L378" href="#L378">378</a>     }
-<a class="jxr_linenumber" name="L379" href="#L379">379</a> 
-<a class="jxr_linenumber" name="L380" href="#L380">380</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L381" href="#L381">381</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L382" href="#L382">382</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L383" href="#L383">383</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/service/IoHandler.html">IoHandler</a> 
getHandler() {
-<a class="jxr_linenumber" name="L384" href="#L384">384</a>         <strong 
class="jxr_keyword">return</strong> handler;
-<a class="jxr_linenumber" name="L385" href="#L385">385</a>     }
-<a class="jxr_linenumber" name="L386" href="#L386">386</a> 
-<a class="jxr_linenumber" name="L387" href="#L387">387</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L388" href="#L388">388</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L389" href="#L389">389</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L390" href="#L390">390</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/session/IoSessionConfig.html">IoSessionConfig</a>
 getConfig() {
-<a class="jxr_linenumber" name="L391" href="#L391">391</a>         <strong 
class="jxr_keyword">return</strong> config;
-<a class="jxr_linenumber" name="L392" href="#L392">392</a>     }
-<a class="jxr_linenumber" name="L393" href="#L393">393</a> 
-<a class="jxr_linenumber" name="L394" href="#L394">394</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L395" href="#L395">395</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L396" href="#L396">396</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L397" href="#L397">397</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 read() {
-<a class="jxr_linenumber" name="L398" href="#L398">398</a>         <strong 
class="jxr_keyword">if</strong> (!getConfig().isUseReadOperation()) {
-<a class="jxr_linenumber" name="L399" href="#L399">399</a>             <strong 
class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> 
IllegalStateException(<span class="jxr_string">"useReadOperation is not 
enabled."</span>);
-<a class="jxr_linenumber" name="L400" href="#L400">400</a>         }
-<a class="jxr_linenumber" name="L401" href="#L401">401</a> 
-<a class="jxr_linenumber" name="L402" href="#L402">402</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = getReadyReadFutures();
-<a class="jxr_linenumber" name="L403" href="#L403">403</a>         <a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 future;
-<a class="jxr_linenumber" name="L404" href="#L404">404</a>         
-<a class="jxr_linenumber" name="L405" href="#L405">405</a>         <strong 
class="jxr_keyword">synchronized</strong> (readyReadFutures) {
-<a class="jxr_linenumber" name="L406" href="#L406">406</a>             future 
= readyReadFutures.poll();
-<a class="jxr_linenumber" name="L407" href="#L407">407</a>             
-<a class="jxr_linenumber" name="L408" href="#L408">408</a>             <strong 
class="jxr_keyword">if</strong> (future != <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L409" href="#L409">409</a>                 
<strong class="jxr_keyword">if</strong> (future.isClosed()) {
-<a class="jxr_linenumber" name="L410" href="#L410">410</a>                     
<em class="jxr_comment">// Let other readers get notified.</em>
-<a class="jxr_linenumber" name="L411" href="#L411">411</a>                     
readyReadFutures.offer(future);
-<a class="jxr_linenumber" name="L412" href="#L412">412</a>                 }
-<a class="jxr_linenumber" name="L413" href="#L413">413</a>             } 
<strong class="jxr_keyword">else</strong> {
-<a class="jxr_linenumber" name="L414" href="#L414">414</a>                 
future = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultReadFuture.html">DefaultReadFuture</a>(<strong
 class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L415" href="#L415">415</a>                 
getWaitingReadFutures().offer(future);
-<a class="jxr_linenumber" name="L416" href="#L416">416</a>             }
-<a class="jxr_linenumber" name="L417" href="#L417">417</a>         }
-<a class="jxr_linenumber" name="L418" href="#L418">418</a> 
-<a class="jxr_linenumber" name="L419" href="#L419">419</a>         <strong 
class="jxr_keyword">return</strong> future;
-<a class="jxr_linenumber" name="L420" href="#L420">420</a>     }
+<a class="jxr_linenumber" name="L369" href="#L369">369</a>                 
+<a class="jxr_linenumber" name="L370" href="#L370">370</a>                 
<strong class="jxr_keyword">if</strong> (writeRequest != <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L371" href="#L371">371</a>                     
<a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 writeFuture = writeRequest.getFuture();
+<a class="jxr_linenumber" name="L372" href="#L372">372</a>                     
+<a class="jxr_linenumber" name="L373" href="#L373">373</a>                     
<em class="jxr_comment">// The WriteRequest may not always have a future : The 
CLOSE_REQUEST</em>
+<a class="jxr_linenumber" name="L374" href="#L374">374</a>                     
<em class="jxr_comment">// and MESSAGE_SENT_REQUEST don't.</em>
+<a class="jxr_linenumber" name="L375" href="#L375">375</a>                     
<strong class="jxr_keyword">if</strong> (writeFuture != <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L376" href="#L376">376</a>                     
    writeFuture.setWritten();
+<a class="jxr_linenumber" name="L377" href="#L377">377</a>                     
}
+<a class="jxr_linenumber" name="L378" href="#L378">378</a>                 }
+<a class="jxr_linenumber" name="L379" href="#L379">379</a>             }
+<a class="jxr_linenumber" name="L380" href="#L380">380</a>         }
+<a class="jxr_linenumber" name="L381" href="#L381">381</a>     }
+<a class="jxr_linenumber" name="L382" href="#L382">382</a> 
+<a class="jxr_linenumber" name="L383" href="#L383">383</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L384" href="#L384">384</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
+<a class="jxr_linenumber" name="L385" href="#L385">385</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L386" href="#L386">386</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/service/IoHandler.html">IoHandler</a> 
getHandler() {
+<a class="jxr_linenumber" name="L387" href="#L387">387</a>         <strong 
class="jxr_keyword">return</strong> handler;
+<a class="jxr_linenumber" name="L388" href="#L388">388</a>     }
+<a class="jxr_linenumber" name="L389" href="#L389">389</a> 
+<a class="jxr_linenumber" name="L390" href="#L390">390</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L391" href="#L391">391</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
+<a class="jxr_linenumber" name="L392" href="#L392">392</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L393" href="#L393">393</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/session/IoSessionConfig.html">IoSessionConfig</a>
 getConfig() {
+<a class="jxr_linenumber" name="L394" href="#L394">394</a>         <strong 
class="jxr_keyword">return</strong> config;
+<a class="jxr_linenumber" name="L395" href="#L395">395</a>     }
+<a class="jxr_linenumber" name="L396" href="#L396">396</a> 
+<a class="jxr_linenumber" name="L397" href="#L397">397</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L398" href="#L398">398</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
+<a class="jxr_linenumber" name="L399" href="#L399">399</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L400" href="#L400">400</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 read() {
+<a class="jxr_linenumber" name="L401" href="#L401">401</a>         <strong 
class="jxr_keyword">if</strong> (!getConfig().isUseReadOperation()) {
+<a class="jxr_linenumber" name="L402" href="#L402">402</a>             <strong 
class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> 
IllegalStateException(<span class="jxr_string">"useReadOperation is not 
enabled."</span>);
+<a class="jxr_linenumber" name="L403" href="#L403">403</a>         }
+<a class="jxr_linenumber" name="L404" href="#L404">404</a> 
+<a class="jxr_linenumber" name="L405" href="#L405">405</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = getReadyReadFutures();
+<a class="jxr_linenumber" name="L406" href="#L406">406</a>         <a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 future;
+<a class="jxr_linenumber" name="L407" href="#L407">407</a>         
+<a class="jxr_linenumber" name="L408" href="#L408">408</a>         <strong 
class="jxr_keyword">synchronized</strong> (readyReadFutures) {
+<a class="jxr_linenumber" name="L409" href="#L409">409</a>             future 
= readyReadFutures.poll();
+<a class="jxr_linenumber" name="L410" href="#L410">410</a>             
+<a class="jxr_linenumber" name="L411" href="#L411">411</a>             <strong 
class="jxr_keyword">if</strong> (future != <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L412" href="#L412">412</a>                 
<strong class="jxr_keyword">if</strong> (future.isClosed()) {
+<a class="jxr_linenumber" name="L413" href="#L413">413</a>                     
<em class="jxr_comment">// Let other readers get notified.</em>
+<a class="jxr_linenumber" name="L414" href="#L414">414</a>                     
readyReadFutures.offer(future);
+<a class="jxr_linenumber" name="L415" href="#L415">415</a>                 }
+<a class="jxr_linenumber" name="L416" href="#L416">416</a>             } 
<strong class="jxr_keyword">else</strong> {
+<a class="jxr_linenumber" name="L417" href="#L417">417</a>                 
future = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultReadFuture.html">DefaultReadFuture</a>(<strong
 class="jxr_keyword">this</strong>);
+<a class="jxr_linenumber" name="L418" href="#L418">418</a>                 
getWaitingReadFutures().offer(future);
+<a class="jxr_linenumber" name="L419" href="#L419">419</a>             }
+<a class="jxr_linenumber" name="L420" href="#L420">420</a>         }
 <a class="jxr_linenumber" name="L421" href="#L421">421</a> 
-<a class="jxr_linenumber" name="L422" href="#L422">422</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L423" href="#L423">423</a> <em 
class="jxr_javadoccomment">     * Associates a message to a ReadFuture</em>
-<a class="jxr_linenumber" name="L424" href="#L424">424</a> <em 
class="jxr_javadoccomment">     * </em>
-<a class="jxr_linenumber" name="L425" href="#L425">425</a> <em 
class="jxr_javadoccomment">     * @param message the message to associate to 
the ReadFuture</em>
-<a class="jxr_linenumber" name="L426" href="#L426">426</a> <em 
class="jxr_javadoccomment">     * </em>
-<a class="jxr_linenumber" name="L427" href="#L427">427</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L428" href="#L428">428</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> offerReadFuture(Object message) {
-<a class="jxr_linenumber" name="L429" href="#L429">429</a>         
newReadFuture().setRead(message);
-<a class="jxr_linenumber" name="L430" href="#L430">430</a>     }
-<a class="jxr_linenumber" name="L431" href="#L431">431</a> 
-<a class="jxr_linenumber" name="L432" href="#L432">432</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L433" href="#L433">433</a> <em 
class="jxr_javadoccomment">     * Associates a failure to a ReadFuture</em>
-<a class="jxr_linenumber" name="L434" href="#L434">434</a> <em 
class="jxr_javadoccomment">     * </em>
-<a class="jxr_linenumber" name="L435" href="#L435">435</a> <em 
class="jxr_javadoccomment">     * @param exception the exception to associate 
to the ReadFuture</em>
-<a class="jxr_linenumber" name="L436" href="#L436">436</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L437" href="#L437">437</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> offerFailedReadFuture(Throwable 
exception) {
-<a class="jxr_linenumber" name="L438" href="#L438">438</a>         
newReadFuture().setException(exception);
-<a class="jxr_linenumber" name="L439" href="#L439">439</a>     }
-<a class="jxr_linenumber" name="L440" href="#L440">440</a> 
-<a class="jxr_linenumber" name="L441" href="#L441">441</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L442" href="#L442">442</a> <em 
class="jxr_javadoccomment">     * Inform the ReadFuture that the session has 
been closed</em>
-<a class="jxr_linenumber" name="L443" href="#L443">443</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L444" href="#L444">444</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> offerClosedReadFuture() {
-<a class="jxr_linenumber" name="L445" href="#L445">445</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = getReadyReadFutures();
-<a class="jxr_linenumber" name="L446" href="#L446">446</a>         
-<a class="jxr_linenumber" name="L447" href="#L447">447</a>         <strong 
class="jxr_keyword">synchronized</strong> (readyReadFutures) {
-<a class="jxr_linenumber" name="L448" href="#L448">448</a>             
newReadFuture().setClosed();
-<a class="jxr_linenumber" name="L449" href="#L449">449</a>         }
-<a class="jxr_linenumber" name="L450" href="#L450">450</a>     }
-<a class="jxr_linenumber" name="L451" href="#L451">451</a> 
-<a class="jxr_linenumber" name="L452" href="#L452">452</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L453" href="#L453">453</a> <em 
class="jxr_javadoccomment">     * @return a readFuture get from the waiting 
ReadFuture</em>
-<a class="jxr_linenumber" name="L454" href="#L454">454</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L455" href="#L455">455</a>     <strong 
class="jxr_keyword">private</strong> <a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 newReadFuture() {
-<a class="jxr_linenumber" name="L456" href="#L456">456</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = getReadyReadFutures();
-<a class="jxr_linenumber" name="L457" href="#L457">457</a>         
Queue&lt;ReadFuture&gt; waitingReadFutures = getWaitingReadFutures();
-<a class="jxr_linenumber" name="L458" href="#L458">458</a>         <a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 future;
-<a class="jxr_linenumber" name="L459" href="#L459">459</a>         
-<a class="jxr_linenumber" name="L460" href="#L460">460</a>         <strong 
class="jxr_keyword">synchronized</strong> (readyReadFutures) {
-<a class="jxr_linenumber" name="L461" href="#L461">461</a>             future 
= waitingReadFutures.poll();
-<a class="jxr_linenumber" name="L462" href="#L462">462</a>             
-<a class="jxr_linenumber" name="L463" href="#L463">463</a>             <strong 
class="jxr_keyword">if</strong> (future == <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L464" href="#L464">464</a>                 
future = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultReadFuture.html">DefaultReadFuture</a>(<strong
 class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L465" href="#L465">465</a>                 
readyReadFutures.offer(future);
-<a class="jxr_linenumber" name="L466" href="#L466">466</a>             }
-<a class="jxr_linenumber" name="L467" href="#L467">467</a>         }
-<a class="jxr_linenumber" name="L468" href="#L468">468</a>         
-<a class="jxr_linenumber" name="L469" href="#L469">469</a>         <strong 
class="jxr_keyword">return</strong> future;
-<a class="jxr_linenumber" name="L470" href="#L470">470</a>     }
-<a class="jxr_linenumber" name="L471" href="#L471">471</a> 
-<a class="jxr_linenumber" name="L472" href="#L472">472</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L473" href="#L473">473</a> <em 
class="jxr_javadoccomment">     * @return a queue of ReadFuture</em>
-<a class="jxr_linenumber" name="L474" href="#L474">474</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L475" href="#L475">475</a>     <strong 
class="jxr_keyword">private</strong> Queue&lt;ReadFuture&gt; 
getReadyReadFutures() {
-<a class="jxr_linenumber" name="L476" href="#L476">476</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = (Queue&lt;ReadFuture&gt;) 
getAttribute(READY_READ_FUTURES_KEY);
-<a class="jxr_linenumber" name="L477" href="#L477">477</a>         
-<a class="jxr_linenumber" name="L478" href="#L478">478</a>         <strong 
class="jxr_keyword">if</strong> (readyReadFutures == <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L479" href="#L479">479</a>             
readyReadFutures = <strong class="jxr_keyword">new</strong> 
ConcurrentLinkedQueue&lt;ReadFuture&gt;();
-<a class="jxr_linenumber" name="L480" href="#L480">480</a> 
-<a class="jxr_linenumber" name="L481" href="#L481">481</a>             
Queue&lt;ReadFuture&gt; oldReadyReadFutures = (Queue&lt;ReadFuture&gt;) 
setAttributeIfAbsent(READY_READ_FUTURES_KEY,
-<a class="jxr_linenumber" name="L482" href="#L482">482</a>                     
readyReadFutures);
-<a class="jxr_linenumber" name="L483" href="#L483">483</a>             
-<a class="jxr_linenumber" name="L484" href="#L484">484</a>             <strong 
class="jxr_keyword">if</strong> (oldReadyReadFutures != <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L485" href="#L485">485</a>                 
readyReadFutures = oldReadyReadFutures;
-<a class="jxr_linenumber" name="L486" href="#L486">486</a>             }
-<a class="jxr_linenumber" name="L487" href="#L487">487</a>         }
-<a class="jxr_linenumber" name="L488" href="#L488">488</a>         
-<a class="jxr_linenumber" name="L489" href="#L489">489</a>         <strong 
class="jxr_keyword">return</strong> readyReadFutures;
-<a class="jxr_linenumber" name="L490" href="#L490">490</a>     }
-<a class="jxr_linenumber" name="L491" href="#L491">491</a> 
-<a class="jxr_linenumber" name="L492" href="#L492">492</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L493" href="#L493">493</a> <em 
class="jxr_javadoccomment">     * @return the queue of waiting ReadFuture</em>
-<a class="jxr_linenumber" name="L494" href="#L494">494</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L495" href="#L495">495</a>     <strong 
class="jxr_keyword">private</strong> Queue&lt;ReadFuture&gt; 
getWaitingReadFutures() {
-<a class="jxr_linenumber" name="L496" href="#L496">496</a>         
Queue&lt;ReadFuture&gt; waitingReadyReadFutures = (Queue&lt;ReadFuture&gt;) 
getAttribute(WAITING_READ_FUTURES_KEY);
-<a class="jxr_linenumber" name="L497" href="#L497">497</a>         
-<a class="jxr_linenumber" name="L498" href="#L498">498</a>         <strong 
class="jxr_keyword">if</strong> (waitingReadyReadFutures == <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L499" href="#L499">499</a>             
waitingReadyReadFutures = <strong class="jxr_keyword">new</strong> 
ConcurrentLinkedQueue&lt;ReadFuture&gt;();
-<a class="jxr_linenumber" name="L500" href="#L500">500</a> 
-<a class="jxr_linenumber" name="L501" href="#L501">501</a>             
Queue&lt;ReadFuture&gt; oldWaitingReadyReadFutures = (Queue&lt;ReadFuture&gt;) 
setAttributeIfAbsent(
-<a class="jxr_linenumber" name="L502" href="#L502">502</a>                     
WAITING_READ_FUTURES_KEY, waitingReadyReadFutures);
-<a class="jxr_linenumber" name="L503" href="#L503">503</a>             
-<a class="jxr_linenumber" name="L504" href="#L504">504</a>             <strong 
class="jxr_keyword">if</strong> (oldWaitingReadyReadFutures != <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L505" href="#L505">505</a>                 
waitingReadyReadFutures = oldWaitingReadyReadFutures;
-<a class="jxr_linenumber" name="L506" href="#L506">506</a>             }
-<a class="jxr_linenumber" name="L507" href="#L507">507</a>         }
-<a class="jxr_linenumber" name="L508" href="#L508">508</a>         
-<a class="jxr_linenumber" name="L509" href="#L509">509</a>         <strong 
class="jxr_keyword">return</strong> waitingReadyReadFutures;
-<a class="jxr_linenumber" name="L510" href="#L510">510</a>     }
-<a class="jxr_linenumber" name="L511" href="#L511">511</a> 
-<a class="jxr_linenumber" name="L512" href="#L512">512</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L513" href="#L513">513</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L514" href="#L514">514</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L515" href="#L515">515</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 write(Object message) {
-<a class="jxr_linenumber" name="L516" href="#L516">516</a>         <strong 
class="jxr_keyword">return</strong> write(message, <strong 
class="jxr_keyword">null</strong>);
-<a class="jxr_linenumber" name="L517" href="#L517">517</a>     }
-<a class="jxr_linenumber" name="L518" href="#L518">518</a> 
-<a class="jxr_linenumber" name="L519" href="#L519">519</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L520" href="#L520">520</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L521" href="#L521">521</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L522" href="#L522">522</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 write(Object message, SocketAddress remoteAddress) {
-<a class="jxr_linenumber" name="L523" href="#L523">523</a>         <strong 
class="jxr_keyword">if</strong> (message == <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L524" href="#L524">524</a>             <strong 
class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> 
IllegalArgumentException(<span class="jxr_string">"Trying to write a null 
message : not allowed"</span>);
-<a class="jxr_linenumber" name="L525" href="#L525">525</a>         }
-<a class="jxr_linenumber" name="L526" href="#L526">526</a> 
-<a class="jxr_linenumber" name="L527" href="#L527">527</a>         <em 
class="jxr_comment">// We can't send a message to a connected session if we 
don't have</em>
-<a class="jxr_linenumber" name="L528" href="#L528">528</a>         <em 
class="jxr_comment">// the remote address</em>
-<a class="jxr_linenumber" name="L529" href="#L529">529</a>         <strong 
class="jxr_keyword">if</strong> (!getTransportMetadata().isConnectionless() 
&amp;&amp; (remoteAddress != <strong class="jxr_keyword">null</strong>)) {
-<a class="jxr_linenumber" name="L530" href="#L530">530</a>             <strong 
class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> 
UnsupportedOperationException();
-<a class="jxr_linenumber" name="L531" href="#L531">531</a>         }
-<a class="jxr_linenumber" name="L532" href="#L532">532</a> 
-<a class="jxr_linenumber" name="L533" href="#L533">533</a>         <em 
class="jxr_comment">// If the session has been closed or is closing, we can't 
either</em>
-<a class="jxr_linenumber" name="L534" href="#L534">534</a>         <em 
class="jxr_comment">// send a message to the remote side. We generate a 
future</em>
-<a class="jxr_linenumber" name="L535" href="#L535">535</a>         <em 
class="jxr_comment">// containing an exception.</em>
-<a class="jxr_linenumber" name="L536" href="#L536">536</a>         <strong 
class="jxr_keyword">if</strong> (isClosing() || !isConnected()) {
-<a class="jxr_linenumber" name="L537" href="#L537">537</a>             <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 future = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultWriteFuture.html">DefaultWriteFuture</a>(<strong
 class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L538" href="#L538">538</a>             <a 
href="../../../../../org/apache/mina/core/write/WriteRequest.html">WriteRequest</a>
 request = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/write/DefaultWriteRequest.html">DefaultWriteRequest</a>(message,
 future, remoteAddress);
-<a class="jxr_linenumber" name="L539" href="#L539">539</a>             <a 
href="../../../../../org/apache/mina/core/write/WriteException.html">WriteException</a>
 writeException = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/write/WriteToClosedSessionException.html">WriteToClosedSessionException</a>(request);
-<a class="jxr_linenumber" name="L540" href="#L540">540</a>             
future.setException(writeException);
-<a class="jxr_linenumber" name="L541" href="#L541">541</a>             <strong 
class="jxr_keyword">return</strong> future;
-<a class="jxr_linenumber" name="L542" href="#L542">542</a>         }
-<a class="jxr_linenumber" name="L543" href="#L543">543</a> 
-<a class="jxr_linenumber" name="L544" href="#L544">544</a>         FileChannel 
openedFileChannel = <strong class="jxr_keyword">null</strong>;
-<a class="jxr_linenumber" name="L545" href="#L545">545</a> 
-<a class="jxr_linenumber" name="L546" href="#L546">546</a>         <em 
class="jxr_comment">// TODO: remove this code as soon as we use InputStream</em>
-<a class="jxr_linenumber" name="L547" href="#L547">547</a>         <em 
class="jxr_comment">// instead of Object for the message.</em>
-<a class="jxr_linenumber" name="L548" href="#L548">548</a>         <strong 
class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="L549" href="#L549">549</a>             <strong 
class="jxr_keyword">if</strong> ((message instanceof IoBuffer) &amp;&amp; 
!((IoBuffer) message).hasRemaining()) {
-<a class="jxr_linenumber" name="L550" href="#L550">550</a>                 <em 
class="jxr_comment">// Nothing to write : probably an error in the user 
code</em>
-<a class="jxr_linenumber" name="L551" href="#L551">551</a>                 
<strong class="jxr_keyword">throw</strong> <strong 
class="jxr_keyword">new</strong> IllegalArgumentException(<span 
class="jxr_string">"message is empty. Forgot to call flip()?"</span>);
-<a class="jxr_linenumber" name="L552" href="#L552">552</a>             } 
<strong class="jxr_keyword">else</strong> <strong 
class="jxr_keyword">if</strong> (message instanceof FileChannel) {
-<a class="jxr_linenumber" name="L553" href="#L553">553</a>                 
FileChannel fileChannel = (FileChannel) message;
-<a class="jxr_linenumber" name="L554" href="#L554">554</a>                 
message = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/file/DefaultFileRegion.html">DefaultFileRegion</a>(fileChannel,
 0, fileChannel.size());
-<a class="jxr_linenumber" name="L555" href="#L555">555</a>             } 
<strong class="jxr_keyword">else</strong> <strong 
class="jxr_keyword">if</strong> (message instanceof File) {
-<a class="jxr_linenumber" name="L556" href="#L556">556</a>                 
File file = (File) message;
-<a class="jxr_linenumber" name="L557" href="#L557">557</a>                 
openedFileChannel = <strong class="jxr_keyword">new</strong> 
FileInputStream(file).getChannel();
-<a class="jxr_linenumber" name="L558" href="#L558">558</a>                 
message = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/file/FilenameFileRegion.html">FilenameFileRegion</a>(file,
 openedFileChannel, 0, openedFileChannel.size());
-<a class="jxr_linenumber" name="L559" href="#L559">559</a>             }
-<a class="jxr_linenumber" name="L560" href="#L560">560</a>         } <strong 
class="jxr_keyword">catch</strong> (IOException e) {
-<a class="jxr_linenumber" name="L561" href="#L561">561</a>             
ExceptionMonitor.getInstance().exceptionCaught(e);
-<a class="jxr_linenumber" name="L562" href="#L562">562</a>             <strong 
class="jxr_keyword">return</strong> 
DefaultWriteFuture.newNotWrittenFuture(<strong 
class="jxr_keyword">this</strong>, e);
-<a class="jxr_linenumber" name="L563" href="#L563">563</a>         }
-<a class="jxr_linenumber" name="L564" href="#L564">564</a> 
-<a class="jxr_linenumber" name="L565" href="#L565">565</a>         <em 
class="jxr_comment">// Now, we can write the message. First, create a 
future</em>
-<a class="jxr_linenumber" name="L566" href="#L566">566</a>         <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 writeFuture = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultWriteFuture.html">DefaultWriteFuture</a>(<strong
 class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L567" href="#L567">567</a>         <a 
href="../../../../../org/apache/mina/core/write/WriteRequest.html">WriteRequest</a>
 writeRequest = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/write/DefaultWriteRequest.html">DefaultWriteRequest</a>(message,
 writeFuture, remoteAddress);
-<a class="jxr_linenumber" name="L568" href="#L568">568</a> 
-<a class="jxr_linenumber" name="L569" href="#L569">569</a>         <em 
class="jxr_comment">// Then, get the chain and inject the WriteRequest into 
it</em>
-<a class="jxr_linenumber" name="L570" href="#L570">570</a>         <a 
href="../../../../../org/apache/mina/core/filterchain/IoFilterChain.html">IoFilterChain</a>
 filterChain = getFilterChain();
-<a class="jxr_linenumber" name="L571" href="#L571">571</a>         
filterChain.fireFilterWrite(writeRequest);
-<a class="jxr_linenumber" name="L572" href="#L572">572</a> 
-<a class="jxr_linenumber" name="L573" href="#L573">573</a>         <em 
class="jxr_comment">// TODO : This is not our business ! The caller has created 
a</em>
-<a class="jxr_linenumber" name="L574" href="#L574">574</a>         <em 
class="jxr_comment">// FileChannel,</em>
-<a class="jxr_linenumber" name="L575" href="#L575">575</a>         <em 
class="jxr_comment">// he has to close it !</em>
-<a class="jxr_linenumber" name="L576" href="#L576">576</a>         <strong 
class="jxr_keyword">if</strong> (openedFileChannel != <strong 
class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="L577" href="#L577">577</a>             <em 
class="jxr_comment">// If we opened a FileChannel, it needs to be closed when 
the write</em>
-<a class="jxr_linenumber" name="L578" href="#L578">578</a>             <em 
class="jxr_comment">// has completed</em>
-<a class="jxr_linenumber" name="L579" href="#L579">579</a>             <strong 
class="jxr_keyword">final</strong> FileChannel finalChannel = openedFileChannel;
-<a class="jxr_linenumber" name="L580" href="#L580">580</a>             
writeFuture.addListener(<strong class="jxr_keyword">new</strong> 
IoFutureListener&lt;WriteFuture&gt;() {
-<a class="jxr_linenumber" name="L581" href="#L581">581</a>                 
<strong class="jxr_keyword">public</strong> <strong 
class="jxr_keyword">void</strong> operationComplete(<a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 future) {
-<a class="jxr_linenumber" name="L582" href="#L582">582</a>                     
<strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="L583" href="#L583">583</a>                     
    finalChannel.close();
-<a class="jxr_linenumber" name="L584" href="#L584">584</a>                     
} <strong class="jxr_keyword">catch</strong> (IOException e) {
-<a class="jxr_linenumber" name="L585" href="#L585">585</a>                     
    ExceptionMonitor.getInstance().exceptionCaught(e);
-<a class="jxr_linenumber" name="L586" href="#L586">586</a>                     
}
-<a class="jxr_linenumber" name="L587" href="#L587">587</a>                 }
-<a class="jxr_linenumber" name="L588" href="#L588">588</a>             });
-<a class="jxr_linenumber" name="L589" href="#L589">589</a>         }
-<a class="jxr_linenumber" name="L590" href="#L590">590</a> 
-<a class="jxr_linenumber" name="L591" href="#L591">591</a>         <em 
class="jxr_comment">// Return the WriteFuture.</em>
-<a class="jxr_linenumber" name="L592" href="#L592">592</a>         <strong 
class="jxr_keyword">return</strong> writeFuture;
-<a class="jxr_linenumber" name="L593" href="#L593">593</a>     }
-<a class="jxr_linenumber" name="L594" href="#L594">594</a> 
-<a class="jxr_linenumber" name="L595" href="#L595">595</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L596" href="#L596">596</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L597" href="#L597">597</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L598" href="#L598">598</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object getAttachment() {
-<a class="jxr_linenumber" name="L599" href="#L599">599</a>         <strong 
class="jxr_keyword">return</strong> getAttribute(<span 
class="jxr_string">""</span>);
-<a class="jxr_linenumber" name="L600" href="#L600">600</a>     }
-<a class="jxr_linenumber" name="L601" href="#L601">601</a> 
-<a class="jxr_linenumber" name="L602" href="#L602">602</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L603" href="#L603">603</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L604" href="#L604">604</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L605" href="#L605">605</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object setAttachment(Object attachment) {
-<a class="jxr_linenumber" name="L606" href="#L606">606</a>         <strong 
class="jxr_keyword">return</strong> setAttribute(<span 
class="jxr_string">""</span>, attachment);
-<a class="jxr_linenumber" name="L607" href="#L607">607</a>     }
-<a class="jxr_linenumber" name="L608" href="#L608">608</a> 
-<a class="jxr_linenumber" name="L609" href="#L609">609</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L610" href="#L610">610</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L611" href="#L611">611</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L612" href="#L612">612</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object getAttribute(Object key) {
-<a class="jxr_linenumber" name="L613" href="#L613">613</a>         <strong 
class="jxr_keyword">return</strong> getAttribute(key, <strong 
class="jxr_keyword">null</strong>);
-<a class="jxr_linenumber" name="L614" href="#L614">614</a>     }
-<a class="jxr_linenumber" name="L615" href="#L615">615</a> 
-<a class="jxr_linenumber" name="L616" href="#L616">616</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L617" href="#L617">617</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L618" href="#L618">618</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L619" href="#L619">619</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object getAttribute(Object key, Object defaultValue) {
-<a class="jxr_linenumber" name="L620" href="#L620">620</a>         <strong 
class="jxr_keyword">return</strong> attributes.getAttribute(<strong 
class="jxr_keyword">this</strong>, key, defaultValue);
-<a class="jxr_linenumber" name="L621" href="#L621">621</a>     }
-<a class="jxr_linenumber" name="L622" href="#L622">622</a> 
-<a class="jxr_linenumber" name="L623" href="#L623">623</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L624" href="#L624">624</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L625" href="#L625">625</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L626" href="#L626">626</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object setAttribute(Object key, Object value) {
-<a class="jxr_linenumber" name="L627" href="#L627">627</a>         <strong 
class="jxr_keyword">return</strong> attributes.setAttribute(<strong 
class="jxr_keyword">this</strong>, key, value);
-<a class="jxr_linenumber" name="L628" href="#L628">628</a>     }
-<a class="jxr_linenumber" name="L629" href="#L629">629</a> 
-<a class="jxr_linenumber" name="L630" href="#L630">630</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L631" href="#L631">631</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L632" href="#L632">632</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L633" href="#L633">633</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object setAttribute(Object key) {
-<a class="jxr_linenumber" name="L634" href="#L634">634</a>         <strong 
class="jxr_keyword">return</strong> setAttribute(key, Boolean.TRUE);
-<a class="jxr_linenumber" name="L635" href="#L635">635</a>     }
-<a class="jxr_linenumber" name="L636" href="#L636">636</a> 
-<a class="jxr_linenumber" name="L637" href="#L637">637</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L638" href="#L638">638</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L639" href="#L639">639</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L640" href="#L640">640</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object setAttributeIfAbsent(Object key, Object value) {
-<a class="jxr_linenumber" name="L641" href="#L641">641</a>         <strong 
class="jxr_keyword">return</strong> attributes.setAttributeIfAbsent(<strong 
class="jxr_keyword">this</strong>, key, value);
-<a class="jxr_linenumber" name="L642" href="#L642">642</a>     }
-<a class="jxr_linenumber" name="L643" href="#L643">643</a> 
-<a class="jxr_linenumber" name="L644" href="#L644">644</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L645" href="#L645">645</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L646" href="#L646">646</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L647" href="#L647">647</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object setAttributeIfAbsent(Object key) {
-<a class="jxr_linenumber" name="L648" href="#L648">648</a>         <strong 
class="jxr_keyword">return</strong> setAttributeIfAbsent(key, Boolean.TRUE);
-<a class="jxr_linenumber" name="L649" href="#L649">649</a>     }
-<a class="jxr_linenumber" name="L650" href="#L650">650</a> 
-<a class="jxr_linenumber" name="L651" href="#L651">651</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L652" href="#L652">652</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L653" href="#L653">653</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L654" href="#L654">654</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object removeAttribute(Object key) {
-<a class="jxr_linenumber" name="L655" href="#L655">655</a>         <strong 
class="jxr_keyword">return</strong> attributes.removeAttribute(<strong 
class="jxr_keyword">this</strong>, key);
-<a class="jxr_linenumber" name="L656" href="#L656">656</a>     }
-<a class="jxr_linenumber" name="L657" href="#L657">657</a> 
-<a class="jxr_linenumber" name="L658" href="#L658">658</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L659" href="#L659">659</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L660" href="#L660">660</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L661" href="#L661">661</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">boolean</strong> removeAttribute(Object key, Object 
value) {
-<a class="jxr_linenumber" name="L662" href="#L662">662</a>         <strong 
class="jxr_keyword">return</strong> attributes.removeAttribute(<strong 
class="jxr_keyword">this</strong>, key, value);
-<a class="jxr_linenumber" name="L663" href="#L663">663</a>     }
-<a class="jxr_linenumber" name="L664" href="#L664">664</a> 
-<a class="jxr_linenumber" name="L665" href="#L665">665</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L666" href="#L666">666</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L667" href="#L667">667</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L668" href="#L668">668</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">boolean</strong> replaceAttribute(Object key, 
Object oldValue, Object newValue) {
-<a class="jxr_linenumber" name="L669" href="#L669">669</a>         <strong 
class="jxr_keyword">return</strong> attributes.replaceAttribute(<strong 
class="jxr_keyword">this</strong>, key, oldValue, newValue);
-<a class="jxr_linenumber" name="L670" href="#L670">670</a>     }
-<a class="jxr_linenumber" name="L671" href="#L671">671</a> 
-<a class="jxr_linenumber" name="L672" href="#L672">672</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L673" href="#L673">673</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L674" href="#L674">674</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L675" href="#L675">675</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">boolean</strong> containsAttribute(Object key) {
-<a class="jxr_linenumber" name="L676" href="#L676">676</a>         <strong 
class="jxr_keyword">return</strong> attributes.containsAttribute(<strong 
class="jxr_keyword">this</strong>, key);
-<a class="jxr_linenumber" name="L677" href="#L677">677</a>     }
-<a class="jxr_linenumber" name="L678" href="#L678">678</a> 
-<a class="jxr_linenumber" name="L679" href="#L679">679</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L680" href="#L680">680</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L681" href="#L681">681</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L682" href="#L682">682</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Set&lt;Object&gt; getAttributeKeys() {
-<a class="jxr_linenumber" name="L683" href="#L683">683</a>         <strong 
class="jxr_keyword">return</strong> attributes.getAttributeKeys(<strong 
class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L684" href="#L684">684</a>     }
-<a class="jxr_linenumber" name="L685" href="#L685">685</a> 
-<a class="jxr_linenumber" name="L686" href="#L686">686</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L687" href="#L687">687</a> <em 
class="jxr_javadoccomment">     * @return The map of attributes associated with 
the session</em>
-<a class="jxr_linenumber" name="L688" href="#L688">688</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L689" href="#L689">689</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<a 
href="../../../../../org/apache/mina/core/session/IoSessionAttributeMap.html">IoSessionAttributeMap</a>
 getAttributeMap() {
-<a class="jxr_linenumber" name="L690" href="#L690">690</a>         <strong 
class="jxr_keyword">return</strong> attributes;
-<a class="jxr_linenumber" name="L691" href="#L691">691</a>     }
-<a class="jxr_linenumber" name="L692" href="#L692">692</a> 
-<a class="jxr_linenumber" name="L693" href="#L693">693</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L694" href="#L694">694</a> <em 
class="jxr_javadoccomment">     * Set the map of attributes associated with the 
session</em>
-<a class="jxr_linenumber" name="L695" href="#L695">695</a> <em 
class="jxr_javadoccomment">     * </em>
-<a class="jxr_linenumber" name="L696" href="#L696">696</a> <em 
class="jxr_javadoccomment">     * @param attributes The Map of attributes</em>
-<a class="jxr_linenumber" name="L697" href="#L697">697</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L698" href="#L698">698</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> setAttributeMap(<a 
href="../../../../../org/apache/mina/core/session/IoSessionAttributeMap.html">IoSessionAttributeMap</a>
 attributes) {
-<a class="jxr_linenumber" name="L699" href="#L699">699</a>         <strong 
class="jxr_keyword">this</strong>.attributes = attributes;
-<a class="jxr_linenumber" name="L700" href="#L700">700</a>     }
-<a class="jxr_linenumber" name="L701" href="#L701">701</a> 
-<a class="jxr_linenumber" name="L702" href="#L702">702</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L703" href="#L703">703</a> <em 
class="jxr_javadoccomment">     * Create a new close aware write queue, based 
on the given write queue.</em>
-<a class="jxr_linenumber" name="L704" href="#L704">704</a> <em 
class="jxr_javadoccomment">     * </em>
-<a class="jxr_linenumber" name="L705" href="#L705">705</a> <em 
class="jxr_javadoccomment">     * @param writeRequestQueue The write request 
queue</em>
-<a class="jxr_linenumber" name="L706" href="#L706">706</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L707" href="#L707">707</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> setWriteRequestQueue(<a 
href="../../../../../org/apache/mina/core/write/WriteRequestQueue.html">WriteRequestQueue</a>
 writeRequestQueue) {
-<a class="jxr_linenumber" name="L708" href="#L708">708</a>         <strong 
class="jxr_keyword">this</strong>.writeRequestQueue = writeRequestQueue;
-<a class="jxr_linenumber" name="L709" href="#L709">709</a>     }
-<a class="jxr_linenumber" name="L710" href="#L710">710</a> 
-<a class="jxr_linenumber" name="L711" href="#L711">711</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L712" href="#L712">712</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L713" href="#L713">713</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L714" href="#L714">714</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> suspendRead() {
-<a class="jxr_linenumber" name="L715" href="#L715">715</a>         
readSuspended = <strong class="jxr_keyword">true</strong>;
-<a class="jxr_linenumber" name="L716" href="#L716">716</a>         <strong 
class="jxr_keyword">if</strong> (isClosing() || !isConnected()) {
-<a class="jxr_linenumber" name="L717" href="#L717">717</a>             <strong 
class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="L718" href="#L718">718</a>         }
-<a class="jxr_linenumber" name="L719" href="#L719">719</a>         
getProcessor().updateTrafficControl(<strong class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L720" href="#L720">720</a>     }
-<a class="jxr_linenumber" name="L721" href="#L721">721</a> 
-<a class="jxr_linenumber" name="L722" href="#L722">722</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L723" href="#L723">723</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L724" href="#L724">724</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L725" href="#L725">725</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> suspendWrite() {
-<a class="jxr_linenumber" name="L726" href="#L726">726</a>         
writeSuspended = <strong class="jxr_keyword">true</strong>;
-<a class="jxr_linenumber" name="L727" href="#L727">727</a>         <strong 
class="jxr_keyword">if</strong> (isClosing() || !isConnected()) {
-<a class="jxr_linenumber" name="L728" href="#L728">728</a>             <strong 
class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="L729" href="#L729">729</a>         }
-<a class="jxr_linenumber" name="L730" href="#L730">730</a>         
getProcessor().updateTrafficControl(<strong class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L731" href="#L731">731</a>     }
-<a class="jxr_linenumber" name="L732" href="#L732">732</a> 
-<a class="jxr_linenumber" name="L733" href="#L733">733</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L734" href="#L734">734</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L735" href="#L735">735</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L736" href="#L736">736</a>     
@SuppressWarnings(<span class="jxr_string">"unchecked"</span>)
-<a class="jxr_linenumber" name="L737" href="#L737">737</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> resumeRead() {
-<a class="jxr_linenumber" name="L738" href="#L738">738</a>         
readSuspended = false;
-<a class="jxr_linenumber" name="L739" href="#L739">739</a>         <strong 
class="jxr_keyword">if</strong> (isClosing() || !isConnected()) {
-<a class="jxr_linenumber" name="L740" href="#L740">740</a>             <strong 
class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="L741" href="#L741">741</a>         }
-<a class="jxr_linenumber" name="L742" href="#L742">742</a>         
getProcessor().updateTrafficControl(<strong class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L743" href="#L743">743</a>     }
-<a class="jxr_linenumber" name="L744" href="#L744">744</a> 
-<a class="jxr_linenumber" name="L745" href="#L745">745</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L746" href="#L746">746</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L747" href="#L747">747</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L748" href="#L748">748</a>     
@SuppressWarnings(<span class="jxr_string">"unchecked"</span>)
-<a class="jxr_linenumber" name="L749" href="#L749">749</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> resumeWrite() {
-<a class="jxr_linenumber" name="L750" href="#L750">750</a>         
writeSuspended = false;
-<a class="jxr_linenumber" name="L751" href="#L751">751</a>         <strong 
class="jxr_keyword">if</strong> (isClosing() || !isConnected()) {
-<a class="jxr_linenumber" name="L752" href="#L752">752</a>             <strong 
class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="L753" href="#L753">753</a>         }
-<a class="jxr_linenumber" name="L754" href="#L754">754</a>         
getProcessor().updateTrafficControl(<strong class="jxr_keyword">this</strong>);
-<a class="jxr_linenumber" name="L755" href="#L755">755</a>     }
-<a class="jxr_linenumber" name="L756" href="#L756">756</a> 
-<a class="jxr_linenumber" name="L757" href="#L757">757</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L758" href="#L758">758</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L759" href="#L759">759</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L760" href="#L760">760</a>     <strong 
class="jxr_keyword">public</strong> <strong 
class="jxr_keyword">boolean</strong> isReadSuspended() {
-<a class="jxr_linenumber" name="L761" href="#L761">761</a>         <strong 
class="jxr_keyword">return</strong> readSuspended;
-<a class="jxr_linenumber" name="L762" href="#L762">762</a>     }
-<a class="jxr_linenumber" name="L763" href="#L763">763</a> 
-<a class="jxr_linenumber" name="L764" href="#L764">764</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L765" href="#L765">765</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L766" href="#L766">766</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L767" href="#L767">767</a>     <strong 
class="jxr_keyword">public</strong> <strong 
class="jxr_keyword">boolean</strong> isWriteSuspended() {
-<a class="jxr_linenumber" name="L768" href="#L768">768</a>         <strong 
class="jxr_keyword">return</strong> writeSuspended;
-<a class="jxr_linenumber" name="L769" href="#L769">769</a>     }
-<a class="jxr_linenumber" name="L770" href="#L770">770</a> 
-<a class="jxr_linenumber" name="L771" href="#L771">771</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L772" href="#L772">772</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L773" href="#L773">773</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L774" href="#L774">774</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">long</strong> getReadBytes() {
-<a class="jxr_linenumber" name="L775" href="#L775">775</a>         <strong 
class="jxr_keyword">return</strong> readBytes;
-<a class="jxr_linenumber" name="L776" href="#L776">776</a>     }
-<a class="jxr_linenumber" name="L777" href="#L777">777</a> 
-<a class="jxr_linenumber" name="L778" href="#L778">778</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L779" href="#L779">779</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L780" href="#L780">780</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L781" href="#L781">781</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">long</strong> getWrittenBytes() {
-<a class="jxr_linenumber" name="L782" href="#L782">782</a>         <strong 
class="jxr_keyword">return</strong> writtenBytes;
-<a class="jxr_linenumber" name="L783" href="#L783">783</a>     }
-<a class="jxr_linenumber" name="L784" href="#L784">784</a> 
-<a class="jxr_linenumber" name="L785" href="#L785">785</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L786" href="#L786">786</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L787" href="#L787">787</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L788" href="#L788">788</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">long</strong> getReadMessages() {
-<a class="jxr_linenumber" name="L789" href="#L789">789</a>         <strong 
class="jxr_keyword">return</strong> readMessages;
-<a class="jxr_linenumber" name="L790" href="#L790">790</a>     }
-<a class="jxr_linenumber" name="L791" href="#L791">791</a> 
-<a class="jxr_linenumber" name="L792" href="#L792">792</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L793" href="#L793">793</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L794" href="#L794">794</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L795" href="#L795">795</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">long</strong> getWrittenMessages() {
-<a class="jxr_linenumber" name="L796" href="#L796">796</a>         <strong 
class="jxr_keyword">return</strong> writtenMessages;
-<a class="jxr_linenumber" name="L797" href="#L797">797</a>     }
-<a class="jxr_linenumber" name="L798" href="#L798">798</a> 
-<a class="jxr_linenumber" name="L799" href="#L799">799</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L800" href="#L800">800</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L801" href="#L801">801</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L802" href="#L802">802</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">double</strong> getReadBytesThroughput() {
-<a class="jxr_linenumber" name="L803" href="#L803">803</a>         <strong 
class="jxr_keyword">return</strong> readBytesThroughput;
-<a class="jxr_linenumber" name="L804" href="#L804">804</a>     }
-<a class="jxr_linenumber" name="L805" href="#L805">805</a> 
-<a class="jxr_linenumber" name="L806" href="#L806">806</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L807" href="#L807">807</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L808" href="#L808">808</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L809" href="#L809">809</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">double</strong> getWrittenBytesThroughput() {
-<a class="jxr_linenumber" name="L810" href="#L810">810</a>         <strong 
class="jxr_keyword">return</strong> writtenBytesThroughput;
-<a class="jxr_linenumber" name="L811" href="#L811">811</a>     }
-<a class="jxr_linenumber" name="L812" href="#L812">812</a> 
-<a class="jxr_linenumber" name="L813" href="#L813">813</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L814" href="#L814">814</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L815" href="#L815">815</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L816" href="#L816">816</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">double</strong> getReadMessagesThroughput() {
-<a class="jxr_linenumber" name="L817" href="#L817">817</a>         <strong 
class="jxr_keyword">return</strong> readMessagesThroughput;
-<a class="jxr_linenumber" name="L818" href="#L818">818</a>     }
-<a class="jxr_linenumber" name="L819" href="#L819">819</a> 
-<a class="jxr_linenumber" name="L820" href="#L820">820</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L821" href="#L821">821</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L822" href="#L822">822</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L823" href="#L823">823</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">double</strong> getWrittenMessagesThroughput() {
-<a class="jxr_linenumber" name="L824" href="#L824">824</a>         <strong 
class="jxr_keyword">return</strong> writtenMessagesThroughput;
-<a class="jxr_linenumber" name="L825" href="#L825">825</a>     }
-<a class="jxr_linenumber" name="L826" href="#L826">826</a> 
-<a class="jxr_linenumber" name="L827" href="#L827">827</a>     <em 
class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="L828" href="#L828">828</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
-<a class="jxr_linenumber" name="L829" href="#L829">829</a> <em 
class="jxr_javadoccomment">     */</em>
-<a class="jxr_linenumber" name="L830" href="#L830">830</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> updateThroughput(<strong 
class="jxr_keyword">long</strong> currentTime, <strong 
class="jxr_keyword">boolean</strong> force) {
-<a class="jxr_linenumber" name="L831" href="#L831">831</a>         <strong 
class="jxr_keyword">int</strong> interval = (<strong 
class="jxr_keyword">int</strong>) (currentTime - lastThroughputCalculationTime);
-<a class="jxr_linenumber" name="L832" href="#L832">832</a> 
-<a class="jxr_linenumber" name="L833" href="#L833">833</a>         <strong 
class="jxr_keyword">long</strong> minInterval = 
getConfig().getThroughputCalculationIntervalInMillis();
-<a class="jxr_linenumber" name="L834" href="#L834">834</a> 
-<a class="jxr_linenumber" name="L835" href="#L835">835</a>         <strong 
class="jxr_keyword">if</strong> (((minInterval == 0) || (interval &lt; 
minInterval)) &amp;&amp; !force) {
-<a class="jxr_linenumber" name="L836" href="#L836">836</a>             <strong 
class="jxr_keyword">return</strong>;
-<a class="jxr_linenumber" name="L837" href="#L837">837</a>         }
-<a class="jxr_linenumber" name="L838" href="#L838">838</a> 
-<a class="jxr_linenumber" name="L839" href="#L839">839</a>         
readBytesThroughput = (readBytes - lastReadBytes) * 1000.0 / interval;
-<a class="jxr_linenumber" name="L840" href="#L840">840</a>         
writtenBytesThroughput = (writtenBytes - lastWrittenBytes) * 1000.0 / interval;
-<a class="jxr_linenumber" name="L841" href="#L841">841</a>         
readMessagesThroughput = (readMessages - lastReadMessages) * 1000.0 / interval;
-<a class="jxr_linenumber" name="L842" href="#L842">842</a>         
writtenMessagesThroughput = (writtenMessages - lastWrittenMessages) * 1000.0 / 
interval;
-<a class="jxr_linenumber" name="L843" href="#L843">843</a> 
-<a class="jxr_linenumber" name="L844" href="#L844">844</a>         
lastReadBytes = readBytes;
-<a class="jxr_linenumber" name="L845" href="#L845">845</a>         
lastWrittenBytes = writtenBytes;
-<a class="jxr_linenumber" name="L846" href="#L846">846</a>         
lastReadMessages = readMessages;
-<a class="jxr_linenumber" name="L847" href="#L847">847</a>         
lastWrittenMessages = writtenMessages;
-<a class="jxr_linenumber" name="L848" href="#L848">848</a> 
-<a class="jxr_linenumber" name="L849" href="#L849">849</a>         
lastThroughputCalculationTime = currentTime;
-<a class="jxr_linenumber" name="L850" href="#L850">850</a>     }
+<a class="jxr_linenumber" name="L422" href="#L422">422</a>         <strong 
class="jxr_keyword">return</strong> future;
+<a class="jxr_linenumber" name="L423" href="#L423">423</a>     }
+<a class="jxr_linenumber" name="L424" href="#L424">424</a> 
+<a class="jxr_linenumber" name="L425" href="#L425">425</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L426" href="#L426">426</a> <em 
class="jxr_javadoccomment">     * Associates a message to a ReadFuture</em>
+<a class="jxr_linenumber" name="L427" href="#L427">427</a> <em 
class="jxr_javadoccomment">     * </em>
+<a class="jxr_linenumber" name="L428" href="#L428">428</a> <em 
class="jxr_javadoccomment">     * @param message the message to associate to 
the ReadFuture</em>
+<a class="jxr_linenumber" name="L429" href="#L429">429</a> <em 
class="jxr_javadoccomment">     * </em>
+<a class="jxr_linenumber" name="L430" href="#L430">430</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L431" href="#L431">431</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> offerReadFuture(Object message) {
+<a class="jxr_linenumber" name="L432" href="#L432">432</a>         
newReadFuture().setRead(message);
+<a class="jxr_linenumber" name="L433" href="#L433">433</a>     }
+<a class="jxr_linenumber" name="L434" href="#L434">434</a> 
+<a class="jxr_linenumber" name="L435" href="#L435">435</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L436" href="#L436">436</a> <em 
class="jxr_javadoccomment">     * Associates a failure to a ReadFuture</em>
+<a class="jxr_linenumber" name="L437" href="#L437">437</a> <em 
class="jxr_javadoccomment">     * </em>
+<a class="jxr_linenumber" name="L438" href="#L438">438</a> <em 
class="jxr_javadoccomment">     * @param exception the exception to associate 
to the ReadFuture</em>
+<a class="jxr_linenumber" name="L439" href="#L439">439</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L440" href="#L440">440</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> offerFailedReadFuture(Throwable 
exception) {
+<a class="jxr_linenumber" name="L441" href="#L441">441</a>         
newReadFuture().setException(exception);
+<a class="jxr_linenumber" name="L442" href="#L442">442</a>     }
+<a class="jxr_linenumber" name="L443" href="#L443">443</a> 
+<a class="jxr_linenumber" name="L444" href="#L444">444</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L445" href="#L445">445</a> <em 
class="jxr_javadoccomment">     * Inform the ReadFuture that the session has 
been closed</em>
+<a class="jxr_linenumber" name="L446" href="#L446">446</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L447" href="#L447">447</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
<strong class="jxr_keyword">void</strong> offerClosedReadFuture() {
+<a class="jxr_linenumber" name="L448" href="#L448">448</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = getReadyReadFutures();
+<a class="jxr_linenumber" name="L449" href="#L449">449</a>         
+<a class="jxr_linenumber" name="L450" href="#L450">450</a>         <strong 
class="jxr_keyword">synchronized</strong> (readyReadFutures) {
+<a class="jxr_linenumber" name="L451" href="#L451">451</a>             
newReadFuture().setClosed();
+<a class="jxr_linenumber" name="L452" href="#L452">452</a>         }
+<a class="jxr_linenumber" name="L453" href="#L453">453</a>     }
+<a class="jxr_linenumber" name="L454" href="#L454">454</a> 
+<a class="jxr_linenumber" name="L455" href="#L455">455</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L456" href="#L456">456</a> <em 
class="jxr_javadoccomment">     * @return a readFuture get from the waiting 
ReadFuture</em>
+<a class="jxr_linenumber" name="L457" href="#L457">457</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L458" href="#L458">458</a>     <strong 
class="jxr_keyword">private</strong> <a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 newReadFuture() {
+<a class="jxr_linenumber" name="L459" href="#L459">459</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = getReadyReadFutures();
+<a class="jxr_linenumber" name="L460" href="#L460">460</a>         
Queue&lt;ReadFuture&gt; waitingReadFutures = getWaitingReadFutures();
+<a class="jxr_linenumber" name="L461" href="#L461">461</a>         <a 
href="../../../../../org/apache/mina/core/future/ReadFuture.html">ReadFuture</a>
 future;
+<a class="jxr_linenumber" name="L462" href="#L462">462</a>         
+<a class="jxr_linenumber" name="L463" href="#L463">463</a>         <strong 
class="jxr_keyword">synchronized</strong> (readyReadFutures) {
+<a class="jxr_linenumber" name="L464" href="#L464">464</a>             future 
= waitingReadFutures.poll();
+<a class="jxr_linenumber" name="L465" href="#L465">465</a>             
+<a class="jxr_linenumber" name="L466" href="#L466">466</a>             <strong 
class="jxr_keyword">if</strong> (future == <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L467" href="#L467">467</a>                 
future = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultReadFuture.html">DefaultReadFuture</a>(<strong
 class="jxr_keyword">this</strong>);
+<a class="jxr_linenumber" name="L468" href="#L468">468</a>                 
readyReadFutures.offer(future);
+<a class="jxr_linenumber" name="L469" href="#L469">469</a>             }
+<a class="jxr_linenumber" name="L470" href="#L470">470</a>         }
+<a class="jxr_linenumber" name="L471" href="#L471">471</a>         
+<a class="jxr_linenumber" name="L472" href="#L472">472</a>         <strong 
class="jxr_keyword">return</strong> future;
+<a class="jxr_linenumber" name="L473" href="#L473">473</a>     }
+<a class="jxr_linenumber" name="L474" href="#L474">474</a> 
+<a class="jxr_linenumber" name="L475" href="#L475">475</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L476" href="#L476">476</a> <em 
class="jxr_javadoccomment">     * @return a queue of ReadFuture</em>
+<a class="jxr_linenumber" name="L477" href="#L477">477</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L478" href="#L478">478</a>     <strong 
class="jxr_keyword">private</strong> Queue&lt;ReadFuture&gt; 
getReadyReadFutures() {
+<a class="jxr_linenumber" name="L479" href="#L479">479</a>         
Queue&lt;ReadFuture&gt; readyReadFutures = (Queue&lt;ReadFuture&gt;) 
getAttribute(READY_READ_FUTURES_KEY);
+<a class="jxr_linenumber" name="L480" href="#L480">480</a>         
+<a class="jxr_linenumber" name="L481" href="#L481">481</a>         <strong 
class="jxr_keyword">if</strong> (readyReadFutures == <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L482" href="#L482">482</a>             
readyReadFutures = <strong class="jxr_keyword">new</strong> 
ConcurrentLinkedQueue&lt;ReadFuture&gt;();
+<a class="jxr_linenumber" name="L483" href="#L483">483</a> 
+<a class="jxr_linenumber" name="L484" href="#L484">484</a>             
Queue&lt;ReadFuture&gt; oldReadyReadFutures = (Queue&lt;ReadFuture&gt;) 
setAttributeIfAbsent(READY_READ_FUTURES_KEY,
+<a class="jxr_linenumber" name="L485" href="#L485">485</a>                     
readyReadFutures);
+<a class="jxr_linenumber" name="L486" href="#L486">486</a>             
+<a class="jxr_linenumber" name="L487" href="#L487">487</a>             <strong 
class="jxr_keyword">if</strong> (oldReadyReadFutures != <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L488" href="#L488">488</a>                 
readyReadFutures = oldReadyReadFutures;
+<a class="jxr_linenumber" name="L489" href="#L489">489</a>             }
+<a class="jxr_linenumber" name="L490" href="#L490">490</a>         }
+<a class="jxr_linenumber" name="L491" href="#L491">491</a>         
+<a class="jxr_linenumber" name="L492" href="#L492">492</a>         <strong 
class="jxr_keyword">return</strong> readyReadFutures;
+<a class="jxr_linenumber" name="L493" href="#L493">493</a>     }
+<a class="jxr_linenumber" name="L494" href="#L494">494</a> 
+<a class="jxr_linenumber" name="L495" href="#L495">495</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L496" href="#L496">496</a> <em 
class="jxr_javadoccomment">     * @return the queue of waiting ReadFuture</em>
+<a class="jxr_linenumber" name="L497" href="#L497">497</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L498" href="#L498">498</a>     <strong 
class="jxr_keyword">private</strong> Queue&lt;ReadFuture&gt; 
getWaitingReadFutures() {
+<a class="jxr_linenumber" name="L499" href="#L499">499</a>         
Queue&lt;ReadFuture&gt; waitingReadyReadFutures = (Queue&lt;ReadFuture&gt;) 
getAttribute(WAITING_READ_FUTURES_KEY);
+<a class="jxr_linenumber" name="L500" href="#L500">500</a>         
+<a class="jxr_linenumber" name="L501" href="#L501">501</a>         <strong 
class="jxr_keyword">if</strong> (waitingReadyReadFutures == <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L502" href="#L502">502</a>             
waitingReadyReadFutures = <strong class="jxr_keyword">new</strong> 
ConcurrentLinkedQueue&lt;ReadFuture&gt;();
+<a class="jxr_linenumber" name="L503" href="#L503">503</a> 
+<a class="jxr_linenumber" name="L504" href="#L504">504</a>             
Queue&lt;ReadFuture&gt; oldWaitingReadyReadFutures = (Queue&lt;ReadFuture&gt;) 
setAttributeIfAbsent(
+<a class="jxr_linenumber" name="L505" href="#L505">505</a>                     
WAITING_READ_FUTURES_KEY, waitingReadyReadFutures);
+<a class="jxr_linenumber" name="L506" href="#L506">506</a>             
+<a class="jxr_linenumber" name="L507" href="#L507">507</a>             <strong 
class="jxr_keyword">if</strong> (oldWaitingReadyReadFutures != <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L508" href="#L508">508</a>                 
waitingReadyReadFutures = oldWaitingReadyReadFutures;
+<a class="jxr_linenumber" name="L509" href="#L509">509</a>             }
+<a class="jxr_linenumber" name="L510" href="#L510">510</a>         }
+<a class="jxr_linenumber" name="L511" href="#L511">511</a>         
+<a class="jxr_linenumber" name="L512" href="#L512">512</a>         <strong 
class="jxr_keyword">return</strong> waitingReadyReadFutures;
+<a class="jxr_linenumber" name="L513" href="#L513">513</a>     }
+<a class="jxr_linenumber" name="L514" href="#L514">514</a> 
+<a class="jxr_linenumber" name="L515" href="#L515">515</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L516" href="#L516">516</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
+<a class="jxr_linenumber" name="L517" href="#L517">517</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L518" href="#L518">518</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 write(Object message) {
+<a class="jxr_linenumber" name="L519" href="#L519">519</a>         <strong 
class="jxr_keyword">return</strong> write(message, <strong 
class="jxr_keyword">null</strong>);
+<a class="jxr_linenumber" name="L520" href="#L520">520</a>     }
+<a class="jxr_linenumber" name="L521" href="#L521">521</a> 
+<a class="jxr_linenumber" name="L522" href="#L522">522</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L523" href="#L523">523</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
+<a class="jxr_linenumber" name="L524" href="#L524">524</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L525" href="#L525">525</a>     <strong 
class="jxr_keyword">public</strong> <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 write(Object message, SocketAddress remoteAddress) {
+<a class="jxr_linenumber" name="L526" href="#L526">526</a>         <strong 
class="jxr_keyword">if</strong> (message == <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L527" href="#L527">527</a>             <strong 
class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> 
IllegalArgumentException(<span class="jxr_string">"Trying to write a null 
message : not allowed"</span>);
+<a class="jxr_linenumber" name="L528" href="#L528">528</a>         }
+<a class="jxr_linenumber" name="L529" href="#L529">529</a> 
+<a class="jxr_linenumber" name="L530" href="#L530">530</a>         <em 
class="jxr_comment">// We can't send a message to a connected session if we 
don't have</em>
+<a class="jxr_linenumber" name="L531" href="#L531">531</a>         <em 
class="jxr_comment">// the remote address</em>
+<a class="jxr_linenumber" name="L532" href="#L532">532</a>         <strong 
class="jxr_keyword">if</strong> (!getTransportMetadata().isConnectionless() 
&amp;&amp; (remoteAddress != <strong class="jxr_keyword">null</strong>)) {
+<a class="jxr_linenumber" name="L533" href="#L533">533</a>             <strong 
class="jxr_keyword">throw</strong> <strong class="jxr_keyword">new</strong> 
UnsupportedOperationException();
+<a class="jxr_linenumber" name="L534" href="#L534">534</a>         }
+<a class="jxr_linenumber" name="L535" href="#L535">535</a> 
+<a class="jxr_linenumber" name="L536" href="#L536">536</a>         <em 
class="jxr_comment">// If the session has been closed or is closing, we can't 
either</em>
+<a class="jxr_linenumber" name="L537" href="#L537">537</a>         <em 
class="jxr_comment">// send a message to the remote side. We generate a 
future</em>
+<a class="jxr_linenumber" name="L538" href="#L538">538</a>         <em 
class="jxr_comment">// containing an exception.</em>
+<a class="jxr_linenumber" name="L539" href="#L539">539</a>         <strong 
class="jxr_keyword">if</strong> (isClosing() || !isConnected()) {
+<a class="jxr_linenumber" name="L540" href="#L540">540</a>             <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 future = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultWriteFuture.html">DefaultWriteFuture</a>(<strong
 class="jxr_keyword">this</strong>);
+<a class="jxr_linenumber" name="L541" href="#L541">541</a>             <a 
href="../../../../../org/apache/mina/core/write/WriteRequest.html">WriteRequest</a>
 request = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/write/DefaultWriteRequest.html">DefaultWriteRequest</a>(message,
 future, remoteAddress);
+<a class="jxr_linenumber" name="L542" href="#L542">542</a>             <a 
href="../../../../../org/apache/mina/core/write/WriteException.html">WriteException</a>
 writeException = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/write/WriteToClosedSessionException.html">WriteToClosedSessionException</a>(request);
+<a class="jxr_linenumber" name="L543" href="#L543">543</a>             
future.setException(writeException);
+<a class="jxr_linenumber" name="L544" href="#L544">544</a>             <strong 
class="jxr_keyword">return</strong> future;
+<a class="jxr_linenumber" name="L545" href="#L545">545</a>         }
+<a class="jxr_linenumber" name="L546" href="#L546">546</a> 
+<a class="jxr_linenumber" name="L547" href="#L547">547</a>         FileChannel 
openedFileChannel = <strong class="jxr_keyword">null</strong>;
+<a class="jxr_linenumber" name="L548" href="#L548">548</a> 
+<a class="jxr_linenumber" name="L549" href="#L549">549</a>         <em 
class="jxr_comment">// TODO: remove this code as soon as we use InputStream</em>
+<a class="jxr_linenumber" name="L550" href="#L550">550</a>         <em 
class="jxr_comment">// instead of Object for the message.</em>
+<a class="jxr_linenumber" name="L551" href="#L551">551</a>         <strong 
class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="L552" href="#L552">552</a>             <strong 
class="jxr_keyword">if</strong> ((message instanceof IoBuffer) &amp;&amp; 
!((IoBuffer) message).hasRemaining()) {
+<a class="jxr_linenumber" name="L553" href="#L553">553</a>                 <em 
class="jxr_comment">// Nothing to write : probably an error in the user 
code</em>
+<a class="jxr_linenumber" name="L554" href="#L554">554</a>                 
<strong class="jxr_keyword">throw</strong> <strong 
class="jxr_keyword">new</strong> IllegalArgumentException(<span 
class="jxr_string">"message is empty. Forgot to call flip()?"</span>);
+<a class="jxr_linenumber" name="L555" href="#L555">555</a>             } 
<strong class="jxr_keyword">else</strong> <strong 
class="jxr_keyword">if</strong> (message instanceof FileChannel) {
+<a class="jxr_linenumber" name="L556" href="#L556">556</a>                 
FileChannel fileChannel = (FileChannel) message;
+<a class="jxr_linenumber" name="L557" href="#L557">557</a>                 
message = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/file/DefaultFileRegion.html">DefaultFileRegion</a>(fileChannel,
 0, fileChannel.size());
+<a class="jxr_linenumber" name="L558" href="#L558">558</a>             } 
<strong class="jxr_keyword">else</strong> <strong 
class="jxr_keyword">if</strong> (message instanceof File) {
+<a class="jxr_linenumber" name="L559" href="#L559">559</a>                 
File file = (File) message;
+<a class="jxr_linenumber" name="L560" href="#L560">560</a>                 
openedFileChannel = <strong class="jxr_keyword">new</strong> 
FileInputStream(file).getChannel();
+<a class="jxr_linenumber" name="L561" href="#L561">561</a>                 
message = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/file/FilenameFileRegion.html">FilenameFileRegion</a>(file,
 openedFileChannel, 0, openedFileChannel.size());
+<a class="jxr_linenumber" name="L562" href="#L562">562</a>             }
+<a class="jxr_linenumber" name="L563" href="#L563">563</a>         } <strong 
class="jxr_keyword">catch</strong> (IOException e) {
+<a class="jxr_linenumber" name="L564" href="#L564">564</a>             
ExceptionMonitor.getInstance().exceptionCaught(e);
+<a class="jxr_linenumber" name="L565" href="#L565">565</a>             <strong 
class="jxr_keyword">return</strong> 
DefaultWriteFuture.newNotWrittenFuture(<strong 
class="jxr_keyword">this</strong>, e);
+<a class="jxr_linenumber" name="L566" href="#L566">566</a>         }
+<a class="jxr_linenumber" name="L567" href="#L567">567</a> 
+<a class="jxr_linenumber" name="L568" href="#L568">568</a>         <em 
class="jxr_comment">// Now, we can write the message. First, create a 
future</em>
+<a class="jxr_linenumber" name="L569" href="#L569">569</a>         <a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 writeFuture = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/future/DefaultWriteFuture.html">DefaultWriteFuture</a>(<strong
 class="jxr_keyword">this</strong>);
+<a class="jxr_linenumber" name="L570" href="#L570">570</a>         <a 
href="../../../../../org/apache/mina/core/write/WriteRequest.html">WriteRequest</a>
 writeRequest = <strong class="jxr_keyword">new</strong> <a 
href="../../../../../org/apache/mina/core/write/DefaultWriteRequest.html">DefaultWriteRequest</a>(message,
 writeFuture, remoteAddress);
+<a class="jxr_linenumber" name="L571" href="#L571">571</a> 
+<a class="jxr_linenumber" name="L572" href="#L572">572</a>         <em 
class="jxr_comment">// Then, get the chain and inject the WriteRequest into 
it</em>
+<a class="jxr_linenumber" name="L573" href="#L573">573</a>         <a 
href="../../../../../org/apache/mina/core/filterchain/IoFilterChain.html">IoFilterChain</a>
 filterChain = getFilterChain();
+<a class="jxr_linenumber" name="L574" href="#L574">574</a>         
filterChain.fireFilterWrite(writeRequest);
+<a class="jxr_linenumber" name="L575" href="#L575">575</a> 
+<a class="jxr_linenumber" name="L576" href="#L576">576</a>         <em 
class="jxr_comment">// TODO : This is not our business ! The caller has created 
a</em>
+<a class="jxr_linenumber" name="L577" href="#L577">577</a>         <em 
class="jxr_comment">// FileChannel,</em>
+<a class="jxr_linenumber" name="L578" href="#L578">578</a>         <em 
class="jxr_comment">// he has to close it !</em>
+<a class="jxr_linenumber" name="L579" href="#L579">579</a>         <strong 
class="jxr_keyword">if</strong> (openedFileChannel != <strong 
class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="L580" href="#L580">580</a>             <em 
class="jxr_comment">// If we opened a FileChannel, it needs to be closed when 
the write</em>
+<a class="jxr_linenumber" name="L581" href="#L581">581</a>             <em 
class="jxr_comment">// has completed</em>
+<a class="jxr_linenumber" name="L582" href="#L582">582</a>             <strong 
class="jxr_keyword">final</strong> FileChannel finalChannel = openedFileChannel;
+<a class="jxr_linenumber" name="L583" href="#L583">583</a>             
writeFuture.addListener(<strong class="jxr_keyword">new</strong> 
IoFutureListener&lt;WriteFuture&gt;() {
+<a class="jxr_linenumber" name="L584" href="#L584">584</a>                 
<strong class="jxr_keyword">public</strong> <strong 
class="jxr_keyword">void</strong> operationComplete(<a 
href="../../../../../org/apache/mina/core/future/WriteFuture.html">WriteFuture</a>
 future) {
+<a class="jxr_linenumber" name="L585" href="#L585">585</a>                     
<strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="L586" href="#L586">586</a>                     
    finalChannel.close();
+<a class="jxr_linenumber" name="L587" href="#L587">587</a>                     
} <strong class="jxr_keyword">catch</strong> (IOException e) {
+<a class="jxr_linenumber" name="L588" href="#L588">588</a>                     
    ExceptionMonitor.getInstance().exceptionCaught(e);
+<a class="jxr_linenumber" name="L589" href="#L589">589</a>                     
}
+<a class="jxr_linenumber" name="L590" href="#L590">590</a>                 }
+<a class="jxr_linenumber" name="L591" href="#L591">591</a>             });
+<a class="jxr_linenumber" name="L592" href="#L592">592</a>         }
+<a class="jxr_linenumber" name="L593" href="#L593">593</a> 
+<a class="jxr_linenumber" name="L594" href="#L594">594</a>         <em 
class="jxr_comment">// Return the WriteFuture.</em>
+<a class="jxr_linenumber" name="L595" href="#L595">595</a>         <strong 
class="jxr_keyword">return</strong> writeFuture;
+<a class="jxr_linenumber" name="L596" href="#L596">596</a>     }
+<a class="jxr_linenumber" name="L597" href="#L597">597</a> 
+<a class="jxr_linenumber" name="L598" href="#L598">598</a>     <em 
class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="L599" href="#L599">599</a> <em 
class="jxr_javadoccomment">     * {@inheritDoc}</em>
+<a class="jxr_linenumber" name="L600" href="#L600">600</a> <em 
class="jxr_javadoccomment">     */</em>
+<a class="jxr_linenumber" name="L601" href="#L601">601</a>     <strong 
class="jxr_keyword">public</strong> <strong class="jxr_keyword">final</strong> 
Object getAttachment() {

[... 1397 lines stripped ...]