http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a7e5a8ce/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html index 357130d..557bcf7 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html @@ -103,7 +103,7 @@ </dl> <hr> <br> -<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.605">RpcServer.Listener.Reader</a> +<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.604">RpcServer.Listener.Reader</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></pre> </li> @@ -215,7 +215,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockList"> <li class="blockList"> <h4>adding</h4> -<pre>private volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.606">adding</a></pre> +<pre>private volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.605">adding</a></pre> </li> </ul> <a name="readSelector"> @@ -224,7 +224,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockListLast"> <li class="blockList"> <h4>readSelector</h4> -<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/Selector.html?is-external=true"; title="class or interface in java.nio.channels">Selector</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.607">readSelector</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/Selector.html?is-external=true"; title="class or interface in java.nio.channels">Selector</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.606">readSelector</a></pre> </li> </ul> </li> @@ -241,7 +241,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockListLast"> <li class="blockList"> <h4>RpcServer.Listener.Reader</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.609">RpcServer.Listener.Reader</a>() +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.608">RpcServer.Listener.Reader</a>() throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> @@ -261,7 +261,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.613">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.612">run</a>()</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true#run()" title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -274,7 +274,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockList"> <li class="blockList"> <h4>doRunLoop</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.625">doRunLoop</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.624">doRunLoop</a>()</pre> </li> </ul> <a name="startAdd()"> @@ -283,7 +283,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockList"> <li class="blockList"> <h4>startAdd</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.659">startAdd</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.658">startAdd</a>()</pre> <div class="block">This gets reader into the state that waits for the new channel to be registered with readSelector. If it was waiting in select() the thread will be woken up, otherwise whenever select() is called @@ -297,7 +297,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockList"> <li class="blockList"> <h4>registerChannel</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.664">registerChannel</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel) +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.663">registerChannel</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> @@ -309,7 +309,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable. <ul class="blockListLast"> <li class="blockList"> <h4>finishAdd</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.669">finishAdd</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html#line.668">finishAdd</a>()</pre> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a7e5a8ce/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html index 207ec91..7fef12a 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html @@ -108,7 +108,7 @@ </dl> <hr> <br> -<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.557">RpcServer.Listener</a> +<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.556">RpcServer.Listener</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?is-external=true"; title="class or interface in java.lang">Thread</a></pre> <div class="block">Listens on the socket. Creates jobs for the handler threads</div> </li> @@ -300,7 +300,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>acceptChannel</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/ServerSocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">ServerSocketChannel</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.559">acceptChannel</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/ServerSocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">ServerSocketChannel</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.558">acceptChannel</a></pre> </li> </ul> <a name="selector"> @@ -309,7 +309,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>selector</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/Selector.html?is-external=true"; title="class or interface in java.nio.channels">Selector</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.560">selector</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/Selector.html?is-external=true"; title="class or interface in java.nio.channels">Selector</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.559">selector</a></pre> </li> </ul> <a name="readers"> @@ -318,7 +318,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>readers</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener.Reader</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.561">readers</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener.Reader</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.560">readers</a></pre> </li> </ul> <a name="currentReader"> @@ -327,7 +327,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>currentReader</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.562">currentReader</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.561">currentReader</a></pre> </li> </ul> <a name="rand"> @@ -336,7 +336,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>rand</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Random.html?is-external=true"; title="class or interface in java.util">Random</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.563">rand</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Random.html?is-external=true"; title="class or interface in java.util">Random</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.562">rand</a></pre> </li> </ul> <a name="lastCleanupRunTime"> @@ -345,7 +345,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>lastCleanupRunTime</h4> -<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.564">lastCleanupRunTime</a></pre> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.563">lastCleanupRunTime</a></pre> </li> </ul> <a name="cleanupInterval"> @@ -354,7 +354,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>cleanupInterval</h4> -<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.566">cleanupInterval</a></pre> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.565">cleanupInterval</a></pre> </li> </ul> <a name="backlogLength"> @@ -363,7 +363,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>backlogLength</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.568">backlogLength</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.567">backlogLength</a></pre> </li> </ul> <a name="readPool"> @@ -372,7 +372,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>readPool</h4> -<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.570">readPool</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.569">readPool</a></pre> </li> </ul> </li> @@ -389,7 +389,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>RpcServer.Listener</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.572">RpcServer.Listener</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name) +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.571">RpcServer.Listener</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> @@ -409,7 +409,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>cleanupConnections</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.682">cleanupConnections</a>(boolean force)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.681">cleanupConnections</a>(boolean force)</pre> <div class="block">cleanup connections from connectionList. Choose a random range to scan and also have a limit on the number of the connections that will be cleanedup per run. The criteria for cleanup is the time @@ -424,7 +424,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.729">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.728">run</a>()</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true#run()" title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -439,7 +439,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>closeCurrentConnection</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.797">closeCurrentConnection</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.796">closeCurrentConnection</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> e)</pre> </li> </ul> @@ -449,7 +449,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>getAddress</h4> -<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.811">getAddress</a>()</pre> +<pre><a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.810">getAddress</a>()</pre> </li> </ul> <a name="doAccept(java.nio.channels.SelectionKey)"> @@ -458,7 +458,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>doAccept</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.815">doAccept</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key) +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.814">doAccept</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/OutOfMemoryError.html?is-external=true"; title="class or interface in java.lang">OutOfMemoryError</a></pre> <dl><dt><span class="strong">Throws:</span></dt> @@ -472,7 +472,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>doRead</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.849">doRead</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key) +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.848">doRead</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></code></dd></dl> @@ -484,7 +484,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>doStop</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.881">doStop</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.880">doStop</a>()</pre> </li> </ul> <a name="getReader()"> @@ -493,7 +493,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>getReader</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.898">getReader</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.html#line.897">getReader</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a7e5a8ce/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html index f4573ad..de847e1 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html @@ -108,7 +108,7 @@ </dl> <hr> <br> -<pre>protected class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.905">RpcServer.Responder</a> +<pre>protected class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.904">RpcServer.Responder</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html?is-external=true"; title="class or interface in java.lang">Thread</a></pre> </li> </ul> @@ -273,7 +273,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>writeSelector</h4> -<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/Selector.html?is-external=true"; title="class or interface in java.nio.channels">Selector</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.906">writeSelector</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/Selector.html?is-external=true"; title="class or interface in java.nio.channels">Selector</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.905">writeSelector</a></pre> </li> </ul> <a name="writingCons"> @@ -282,7 +282,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>writingCons</h4> -<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.907">writingCons</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Set.html?is-external=true"; title="class or interface in java.util">Set</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.906">writingCons</a></pre> </li> </ul> </li> @@ -299,7 +299,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>RpcServer.Responder</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.910">RpcServer.Responder</a>() +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.909">RpcServer.Responder</a>() throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> @@ -319,7 +319,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.917">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.916">run</a>()</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true#run()" title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -334,7 +334,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>registerWrites</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.935">registerWrites</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.934">registerWrites</a>()</pre> <div class="block">Take the list of the connections that want to write, and register them in the selector.</div> </li> @@ -345,7 +345,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>registerForWrite</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.962">registerForWrite</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> c)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.961">registerForWrite</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> c)</pre> <div class="block">Add a connection to the list that want to write,</div> </li> </ul> @@ -355,7 +355,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>doRunLoop</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.968">doRunLoop</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.967">doRunLoop</a>()</pre> </li> </ul> <a name="purge(long)"> @@ -364,7 +364,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>purge</h4> -<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1027">purge</a>(long lastPurgeTime)</pre> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1026">purge</a>(long lastPurgeTime)</pre> <div class="block">If there were some calls that have not been sent out for a long time, we close the connection.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>the time of the purge.</dd></dl> @@ -376,7 +376,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>doAsyncWrite</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1056">doAsyncWrite</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key) +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1055">doAsyncWrite</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SelectionKey.html?is-external=true"; title="class or interface in java.nio.channels">SelectionKey</a> key) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> @@ -388,7 +388,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>processResponse</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1089">processResponse</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a> call) +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1088">processResponse</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a> call) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Process the response for this call. You need to have the lock on <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html#responseWriteLock"><code>RpcServer.Connection.responseWriteLock</code></a></div> @@ -404,7 +404,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>processAllResponses</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1122">processAllResponses</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> connection) +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1121">processAllResponses</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> connection) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Process all the responses for this connection</div> <dl><dt><span class="strong">Returns:</span></dt><dd>true if all the calls were processed or that someone else is doing it. @@ -420,7 +420,7 @@ extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>doRespond</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1147">doRespond</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a> call) +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.Responder.html#line.1146">doRespond</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a> call) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl>
