http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html index 5996aef..85f0adc 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.208">SimpleRpcServer.Listener</a> +<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.186">SimpleRpcServer.Listener</a> extends <a href="http://docs.oracle.com/javase/8/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> @@ -296,7 +296,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>acceptChannel</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.210">acceptChannel</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.188">acceptChannel</a></pre> </li> </ul> <a name="selector"> @@ -305,7 +305,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>selector</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.211">selector</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.189">selector</a></pre> </li> </ul> <a name="readers"> @@ -314,7 +314,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>readers</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Listener.Reader</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.212">readers</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Listener.Reader</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.190">readers</a></pre> </li> </ul> <a name="currentReader"> @@ -323,7 +323,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.213">currentReader</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.191">currentReader</a></pre> </li> </ul> <a name="readerPendingConnectionQueueLength"> @@ -332,7 +332,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>readerPendingConnectionQueueLength</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.214">readerPendingConnectionQueueLength</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.192">readerPendingConnectionQueueLength</a></pre> </li> </ul> <a name="readPool"> @@ -341,7 +341,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>readPool</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.216">readPool</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.194">readPool</a></pre> </li> </ul> </li> @@ -358,7 +358,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>Listener</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.218">Listener</a>(<a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.196">Listener</a>(<a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -380,7 +380,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.328">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.306">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -395,7 +395,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.392">closeCurrentConnection</a>(<a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.370">closeCurrentConnection</a>(<a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> e)</pre> </li> </ul> @@ -405,7 +405,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockList"> <li class="blockList"> <h4>getAddress</h4> -<pre><a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.402">getAddress</a>()</pre> +<pre><a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.380">getAddress</a>()</pre> </li> </ul> <a name="doAccept-java.nio.channels.SelectionKey-"> @@ -414,7 +414,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.406">doAccept</a>(<a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.384">doAccept</a>(<a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a>, <a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/OutOfMemoryError.html?is-external=true"; title="class or interface in java.lang">OutOfMemoryError</a></pre> @@ -432,7 +432,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.427">doRead</a>(<a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.405">doRead</a>(<a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -446,7 +446,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Listener.html#line.453">doStop</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.431">doStop</a>()</pre> </li> </ul> <a name="getReader--"> @@ -455,7 +455,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>getReader</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Listener.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.470">getReader</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Listener.Reader</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.448">getReader</a>()</pre> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html index 4dffd51..a2ea9f2 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>protected class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.477">SimpleRpcServer.Responder</a> +<pre>protected class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.455">SimpleRpcServer.Responder</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true"; title="class or interface in java.lang">Thread</a></pre> </li> </ul> @@ -287,7 +287,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/8/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/SimpleRpcServer.Responder.html#line.478">writeSelector</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.456">writeSelector</a></pre> </li> </ul> <a name="writingCons"> @@ -296,7 +296,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/8/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/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.479">writingCons</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.457">writingCons</a></pre> </li> </ul> </li> @@ -313,7 +313,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? <ul class="blockListLast"> <li class="blockList"> <h4>Responder</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.482">Responder</a>() +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.460">Responder</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -335,7 +335,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.490">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.468">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> @@ -350,7 +350,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.508">registerWrites</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.486">registerWrites</a>()</pre> <div class="block">Take the list of the connections that want to write, and register them in the selector.</div> </li> @@ -361,7 +361,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.535">registerForWrite</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> c)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.513">registerForWrite</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> c)</pre> <div class="block">Add a connection to the list that want to write,</div> </li> </ul> @@ -371,7 +371,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.541">doRunLoop</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.519">doRunLoop</a>()</pre> </li> </ul> <a name="purge-long-"> @@ -380,7 +380,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.600">purge</a>(long lastPurgeTime)</pre> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.578">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> @@ -395,7 +395,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.629">doAsyncWrite</a>(<a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.607">doAsyncWrite</a>(<a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -409,7 +409,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.662">processResponse</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Call</a> call) +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.640">processResponse</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Call</a> call) throws <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Connection.html#responseWriteLock"><code>SimpleRpcServer.Connection.responseWriteLock</code></a></div> @@ -429,7 +429,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.699">processAllResponses</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> connection) +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.677">processAllResponses</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> connection) throws <a href="http://docs.oracle.com/javase/8/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> @@ -448,7 +448,7 @@ extends <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.Responder.html#line.724">doRespond</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Call</a> call) +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html#line.702">doRespond</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Call</a> call) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html index fd7af09..a36c504 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":9,"i1":10,"i2":10,"i3":9,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10}; +var methods = {"i0":9,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -120,7 +120,7 @@ var activeTableTab = "activeTableTab"; <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.Private.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.Private</a> <a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceStability.Evolving.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceStability.Evolving</a> -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.141">SimpleRpcServer</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.116">SimpleRpcServer</a> extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer</a></pre> <div class="block">The RPC server with native java NIO implementation deriving from Hadoop to host protobuf described Services. It's the original one before HBASE-17262, @@ -224,29 +224,22 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#listener">listener</a></span></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>private static int</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#NIO_BUFFER_LIMIT">NIO_BUFFER_LIMIT</a></span></code> -<div class="block">When the read or write buffer size is larger than this limit, i/o will be - done in chunks of this size.</div> -</td> -</tr> -<tr class="altColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#port">port</a></span></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#purgeTimeout">purgeTimeout</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#readThreads">readThreads</a></span></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Responder</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#responder">responder</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#socketSendBufferSize">socketSendBufferSize</a></span></code> </td> </tr> @@ -256,7 +249,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <!-- --> </a> <h3>Fields inherited from class org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#allowFallbackToSimpleAuth">allowFallbackToSimpleAuth</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#AUDITLOG">AUDITLOG</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#AUTH_FAILED_FOR">AUTH_FAILED_FOR</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#AUTH_SUCCESSFUL_FOR">AUTH_SUCCESSFUL_FOR</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#authManager">authManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#authTokenSecretMgr">authTokenSecretMgr</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#bindAddress">bindAddress</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#CALL_QUEUE_TOO_BIG_EXCEPTION">CALL_QUEUE_TOO_BIG_EXCEPTION</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#callQueueSizeInBytes">callQueueSizeInBytes</a>, <a hre f="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#cellBlockBuilder">cellBlockBuilder</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#CurCall">CurCall</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#CURRENT_VERSION">CURRENT_VERSION</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER">DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_CALLQUEUE_SIZE">DEFAULT_MAX_CALLQUEUE_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_REQUEST_SIZE">DEFAULT_MAX_REQUEST_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT">DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFA ULT_WARN_RESPONSE_SIZE">DEFAULT_WARN_RESPONSE_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_WARN_RESPONSE_TIME">DEFAULT_WARN_RESPONSE_TIME</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#errorHandler">errorHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#FALLBACK_TO_INSECURE_CLIENT_AUTH">FALLBACK_TO_INSECURE_CLIENT_AUTH</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isSecurityEnabled">isSecurityEnabled</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#LOG">LOG</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MAPPER">MAPPER</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MAX_REQUEST_SIZE">MAX_REQUEST_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxQueueSizeInBytes">maxQueueSizeInBytes</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxRequestSi ze">maxRequestSize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#metrics">metrics</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MIN_CLIENT_REQUEST_TIMEOUT">MIN_CLIENT_REQUEST_TIMEOUT</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#minClientRequestTimeout">minClientRequestTimeout</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#minSizeForReservoirUse">minSizeForReservoirUse</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MONITORED_RPC">MONITORED_RPC</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#REQUEST_TOO_BIG_EXCEPTION">REQUEST_TOO_BIG_EXCEPTION</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#reservoir">reservoir</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#running">running</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#scheduler">scheduler</a>, <a href="../../. ./../../org/apache/hadoop/hbase/ipc/RpcServer.html#secretManager">secretManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#server">server</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#services">services</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#started">started</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#tcpKeepAlive">tcpKeepAlive</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#tcpNoDelay">tcpNoDelay</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#userProvider">userProvider</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#WARN_RESPONSE_SIZE">WARN_RESPONSE_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#WARN_RESPONSE_TIME">WARN_RESPONSE_TIME</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#warnResponseSize">warnResponseSize</a>, <a href="../../../../.. /org/apache/hadoop/hbase/ipc/RpcServer.html#warnResponseTime">warnResponseTime</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#allowFallbackToSimpleAuth">allowFallbackToSimpleAuth</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#AUDITLOG">AUDITLOG</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#AUTH_FAILED_FOR">AUTH_FAILED_FOR</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#AUTH_SUCCESSFUL_FOR">AUTH_SUCCESSFUL_FOR</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#authManager">authManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#authTokenSecretMgr">authTokenSecretMgr</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#bindAddress">bindAddress</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#CALL_QUEUE_TOO_BIG_EXCEPTION">CALL_QUEUE_TOO_BIG_EXCEPTION</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#callQueueSizeInBytes">callQueueSizeInBytes</a>, <a hre f="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#cellBlockBuilder">cellBlockBuilder</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#conf">conf</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#CurCall">CurCall</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#CURRENT_VERSION">CURRENT_VERSION</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER">DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_CALLQUEUE_SIZE">DEFAULT_MAX_CALLQUEUE_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_REQUEST_SIZE">DEFAULT_MAX_REQUEST_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT">DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFA ULT_WARN_RESPONSE_SIZE">DEFAULT_WARN_RESPONSE_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_WARN_RESPONSE_TIME">DEFAULT_WARN_RESPONSE_TIME</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#errorHandler">errorHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#FALLBACK_TO_INSECURE_CLIENT_AUTH">FALLBACK_TO_INSECURE_CLIENT_AUTH</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isSecurityEnabled">isSecurityEnabled</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#LOG">LOG</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MAPPER">MAPPER</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MAX_REQUEST_SIZE">MAX_REQUEST_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxQueueSizeInBytes">maxQueueSizeInBytes</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxRequestSi ze">maxRequestSize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#metrics">metrics</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MIN_CLIENT_REQUEST_TIMEOUT">MIN_CLIENT_REQUEST_TIMEOUT</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#minClientRequestTimeout">minClientRequestTimeout</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#minSizeForReservoirUse">minSizeForReservoirUse</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MONITORED_RPC">MONITORED_RPC</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#NIO_BUFFER_LIMIT">NIO_BUFFER_LIMIT</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#REQUEST_TOO_BIG_EXCEPTION">REQUEST_TOO_BIG_EXCEPTION</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#reservoir">reservoir</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#running">running</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#scheduler">scheduler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#secretManager">secretManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#server">server</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#services">services</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#started">started</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#tcpKeepAlive">tcpKeepAlive</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#tcpNoDelay">tcpNoDelay</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#userProvider">userProvider</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#WARN_RESPONSE_SIZE">WARN_RESPONSE_SIZE</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#WARN_RESPONSE_TIME">WARN_RESPONSE_TIME</a>, <a href="../../../../.. /org/apache/hadoop/hbase/ipc/RpcServer.html#warnResponseSize">warnResponseSize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#warnResponseTime">warnResponseTime</a></code></li> </ul> </li> </ul> @@ -326,33 +319,17 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl int timeout)</code> </td> </tr> <tr id="i3" class="rowColor"> -<td class="colFirst"><code>protected static int</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelIO-java.nio.channels.ReadableByteChannel-java.nio.channels.WritableByteChannel-java.nio.ByteBuffer-">channelIO</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">ReadableByteChannel</a> readCh, - <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/WritableByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">WritableByteChannel</a> writeCh, - <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> buf)</code> -<div class="block">Helper for <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelRead-java.nio.channels.ReadableByteChannel-java.nio.ByteBuffer-"><code>channelRead(java.nio.channels.ReadableByteChannel, java.nio.ByteBuffer)</code></a> - and <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelWrite-java.nio.channels.GatheringByteChannel-org.apache.hadoop.hbase.ipc.BufferChain-"><code>channelWrite(GatheringByteChannel, BufferChain)</code></a>.</div> -</td> -</tr> -<tr id="i4" class="altColor"> -<td class="colFirst"><code>protected int</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelRead-java.nio.channels.ReadableByteChannel-java.nio.ByteBuffer-">channelRead</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">ReadableByteChannel</a> channel, - <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> buffer)</code> -<div class="block">This is a wrapper around <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true#read-java.nio.ByteBuffer-"; title="class or interface in java.nio.channels"><code>ReadableByteChannel.read(java.nio.ByteBuffer)</code></a>.</div> -</td> -</tr> -<tr id="i5" class="rowColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelWrite-java.nio.channels.GatheringByteChannel-org.apache.hadoop.hbase.ipc.BufferChain-">channelWrite</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/GatheringByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">GatheringByteChannel</a> channel, <a href="../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a> bufferChain)</code> <div class="block">This is a wrapper around <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/WritableByteChannel.html?is-external=true#write-java.nio.ByteBuffer-"; title="class or interface in java.nio.channels"><code>WritableByteChannel.write(java.nio.ByteBuffer)</code></a>.</div> </td> </tr> -<tr id="i6" class="altColor"> +<tr id="i4" class="altColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#closeConnection-org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection-">closeConnection</a></span>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> connection)</code> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#getConnection-java.nio.channels.SocketChannel-long-">getConnection</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel, long time)</code> @@ -360,46 +337,37 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl Connection implementations.</div> </td> </tr> -<tr id="i8" class="altColor"> +<tr id="i6" class="altColor"> <td class="colFirst"><code><a href="http://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#getListenerAddress--">getListenerAddress</a></span>()</code> <div class="block">Return the socket (ip+port) on which the RPC server is listening to.</div> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i7" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#getNumOpenConnections--">getNumOpenConnections</a></span>()</code> <div class="block">The number of open RPC conections</div> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i8" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#join--">join</a></span>()</code> <div class="block">Wait for the server to be stopped.</div> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i9" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#setSocketSendBufSize-int-">setSocketSendBufSize</a></span>(int size)</code> <div class="block">Sets the socket buffer size used for responding to RPCs.</div> </td> </tr> -<tr id="i12" class="altColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#setupResponse-java.io.ByteArrayOutputStream-org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call-java.lang.Throwable-java.lang.String-">setupResponse</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/io/ByteArrayOutputStream.html?is-external=true"; title="class or interface in java.io">ByteArrayOutputStream</a> response, - <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Call</a> call, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> t, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> error)</code> -<div class="block">Setup response for the RPC Call.</div> -</td> -</tr> -<tr id="i13" class="rowColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#start--">start</a></span>()</code> <div class="block">Starts the service.</div> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#stop--">stop</a></span>()</code> <div class="block">Stops the service.</div> @@ -411,7 +379,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <!-- --> </a> <h3>Methods inherited from class org.apache.hadoop.hbase.ipc.<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#addCallSize-long-">addCallSize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#allocateByteBuffToReadInto-org.apache.hadoop.hbase.io.ByteBufferPool-int-int-">allocateByteBuffToReadInto</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#authorize-org.apache.hadoop.security.UserGroupInformation-org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader-java.net.InetAddress-">authorize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#call-org.apache.hadoop.hbase.ipc.RpcCall-org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler-">call</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#createSecretManager--">createSecretManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getConf--">getConf</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getCurrentCall--">getC urrentCall</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getErrorHandler--">getErrorHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getMetrics--">getMetrics</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getMinSizeForReservoirUse-org.apache.hadoop.hbase.io.ByteBufferPool-">getMinSizeForReservoirUse</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRemoteAddress--">getRemoteAddress</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRemoteIp--">getRemoteIp</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRequestUser--">getRequestUser</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRequestUserName--">getRequestUserName</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getScheduler--">getScheduler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getSecretManage r--">getSecretManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getService-java.util.List-java.lang.String-">getService</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getServiceAndInterface-java.util.List-java.lang.String-">getServiceAndInterface</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getServiceInterface-java.util.List-java.lang.String-">getServiceInterface</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getStatus--">getStatus</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#initReconfigurable-org.apache.hadoop.conf.Configuration-">initReconfigurable</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isInRpcCallContext--">isInRpcCallContext</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isStarted--">isStarted</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#logResponse-org.apache.ha doop.hbase.shaded.com.google.protobuf.Message-java.lang.String-java.lang.String-java.lang.String-java.lang.String-long-int-int-long-">logResponse</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#onConfigurationChange-org.apache.hadoop.conf.Configuration-">onConfigurationChange</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#refreshAuthManager-org.apache.hadoop.security.authorize.PolicyProvider-">refreshAuthManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setErrorHandler-org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler-">setErrorHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setRsRpcServices-org.apache.hadoop.hbase.regionserver.RSRpcServices-">setRsRpcServices</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setSecretManager-org.apache.hadoop.security.token.SecretManager-">setSecretManager</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#addCallSize-long-">addCallSize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#allocateByteBuffToReadInto-org.apache.hadoop.hbase.io.ByteBufferPool-int-int-">allocateByteBuffToReadInto</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#authorize-org.apache.hadoop.security.UserGroupInformation-org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader-java.net.InetAddress-">authorize</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#call-org.apache.hadoop.hbase.ipc.RpcCall-org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler-">call</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#channelRead-java.nio.channels.ReadableByteChannel-java.nio.ByteBuffer-">channelRead</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#createSecretManager--">createSecretManager</a>, <a href="../../../../../ org/apache/hadoop/hbase/ipc/RpcServer.html#getConf--">getConf</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getCurrentCall--">getCurrentCall</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getErrorHandler--">getErrorHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getMetrics--">getMetrics</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getMinSizeForReservoirUse-org.apache.hadoop.hbase.io.ByteBufferPool-">getMinSizeForReservoirUse</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRemoteAddress--">getRemoteAddress</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRemoteIp--">getRemoteIp</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRequestUser--">getRequestUser</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRequestUserName--">getRequestUserName</a>, <a href="../../../../../org /apache/hadoop/hbase/ipc/RpcServer.html#getScheduler--">getScheduler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getSecretManager--">getSecretManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getService-java.util.List-java.lang.String-">getService</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getServiceAndInterface-java.util.List-java.lang.String-">getServiceAndInterface</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getServiceInterface-java.util.List-java.lang.String-">getServiceInterface</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getStatus--">getStatus</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#initReconfigurable-org.apache.hadoop.conf.Configuration-">initReconfigurable</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isInRpcCallContext--">isInRpcCallContext</a>, <a href="../../../../../org/apa che/hadoop/hbase/ipc/RpcServer.html#isStarted--">isStarted</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#logResponse-org.apache.hadoop.hbase.shaded.com.google.protobuf.Message-java.lang.String-java.lang.String-java.lang.String-java.lang.String-long-int-int-long-">logResponse</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#onConfigurationChange-org.apache.hadoop.conf.Configuration-">onConfigurationChange</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#refreshAuthManager-org.apache.hadoop.security.authorize.PolicyProvider-">refreshAuthManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setErrorHandler-org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler-">setErrorHandler</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setRsRpcServices-org.apache.hadoop.hbase.regionserver.RSRpcServices-">setRsRpcServices</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcSe rver.html#setSecretManager-org.apache.hadoop.security.token.SecretManager-">setSecretManager</a>, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setupResponse-java.io.ByteArrayOutputStream-org.apache.hadoop.hbase.ipc.RpcServer.Call-java.lang.Throwable-java.lang.String-">setupResponse</a></code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> @@ -440,7 +408,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>port</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.143">port</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.118">port</a></pre> </li> </ul> <a name="address"> @@ -449,7 +417,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>address</h4> -<pre>protected <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.html#line.144">address</a></pre> +<pre>protected <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.html#line.119">address</a></pre> </li> </ul> <a name="readThreads"> @@ -458,7 +426,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>readThreads</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.145">readThreads</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.120">readThreads</a></pre> </li> </ul> <a name="socketSendBufferSize"> @@ -467,7 +435,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>socketSendBufferSize</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.147">socketSendBufferSize</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.122">socketSendBufferSize</a></pre> </li> </ul> <a name="purgeTimeout"> @@ -476,7 +444,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>purgeTimeout</h4> -<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.148">purgeTimeout</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.123">purgeTimeout</a></pre> </li> </ul> <a name="connectionManager"> @@ -485,7 +453,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>connectionManager</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.ConnectionManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.151">connectionManager</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.ConnectionManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.126">connectionManager</a></pre> </li> </ul> <a name="listener"> @@ -494,28 +462,16 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>listener</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Listener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.152">listener</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Listener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.127">listener</a></pre> </li> </ul> <a name="responder"> <!-- --> </a> -<ul class="blockList"> -<li class="blockList"> -<h4>responder</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Responder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.153">responder</a></pre> -</li> -</ul> -<a name="NIO_BUFFER_LIMIT"> -<!-- --> -</a> <ul class="blockListLast"> <li class="blockList"> -<h4>NIO_BUFFER_LIMIT</h4> -<pre>private static int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1728">NIO_BUFFER_LIMIT</a></pre> -<div class="block">When the read or write buffer size is larger than this limit, i/o will be - done in chunks of this size. Most RPC requests and responses would be - be smaller.</div> +<h4>responder</h4> +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Responder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.128">responder</a></pre> </li> </ul> </li> @@ -532,7 +488,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockListLast"> <li class="blockList"> <h4>SimpleRpcServer</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1593">SimpleRpcServer</a>(<a href="../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> server, +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1105">SimpleRpcServer</a>(<a href="../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> server, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> name, <a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.BlockingServiceAndInterface</a>> services, <a href="http://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> bindAddress, @@ -568,41 +524,19 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>getConnection</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1620">getConnection</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel, +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1132">getConnection</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel, long time)</pre> <div class="block">Subclasses of HBaseServer can override this to provide their own Connection implementations.</div> </li> </ul> -<a name="setupResponse-java.io.ByteArrayOutputStream-org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call-java.lang.Throwable-java.lang.String-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>setupResponse</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1632">setupResponse</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/io/ByteArrayOutputStream.html?is-external=true"; title="class or interface in java.io">ByteArrayOutputStream</a> response, - <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Call</a> call, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> t, - <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> error) - throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">Setup response for the RPC Call.</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>response</code> - buffer to serialize the response into</dd> -<dd><code>call</code> - <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc"><code>SimpleRpcServer.Call</code></a> to which we are setting up the response</dd> -<dd><code>error</code> - error message, if the call failed</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd> -</dl> -</li> -</ul> <a name="closeConnection-org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>closeConnection</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1638">closeConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> connection)</pre> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1136">closeConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServer.Connection</a> connection)</pre> </li> </ul> <a name="setSocketSendBufSize-int-"> @@ -611,7 +545,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>setSocketSendBufSize</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1646">setSocketSendBufSize</a>(int size)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1144">setSocketSendBufSize</a>(int size)</pre> <div class="block">Sets the socket buffer size used for responding to RPCs.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -625,7 +559,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>start</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1650">start</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1148">start</a>()</pre> <div class="block">Starts the service. Must be called before any calls will be handled.</div> </li> </ul> @@ -635,7 +569,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>stop</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1667">stop</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1165">stop</a>()</pre> <div class="block">Stops the service. No new calls will be handled after this is called.</div> </li> </ul> @@ -645,7 +579,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>join</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1687">join</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1185">join</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Wait for the server to be stopped. Does not wait for all subthreads to finish. @@ -662,7 +596,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>getListenerAddress</h4> -<pre>public <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.html#line.1700">getListenerAddress</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/8/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/SimpleRpcServer.html#line.1198">getListenerAddress</a>()</pre> <div class="block">Return the socket (ip+port) on which the RPC server is listening to. May return null if the listener channel is closed.</div> <dl> @@ -678,7 +612,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>call</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.hbase.shaded.com.google.protobuf.Message,<a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1707">call</a>(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service, +<pre>public <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.hbase.shaded.com.google.protobuf.Message,<a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1206">call</a>(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hadoop.hbase.shaded.com.google.protobuf.Message param, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, @@ -697,7 +631,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>call</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.hbase.shaded.com.google.protobuf.Message,<a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1713">call</a>(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service, +<pre>public <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><org.apache.hadoop.hbase.shaded.com.google.protobuf.Message,<a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1213">call</a>(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hadoop.hbase.shaded.com.google.protobuf.Message param, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, @@ -718,7 +652,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>channelWrite</h4> -<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1744">channelWrite</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/GatheringByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">GatheringByteChannel</a> channel, +<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1237">channelWrite</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/GatheringByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">GatheringByteChannel</a> channel, <a href="../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a> bufferChain) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">This is a wrapper around <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/WritableByteChannel.html?is-external=true#write-java.nio.ByteBuffer-"; title="class or interface in java.nio.channels"><code>WritableByteChannel.write(java.nio.ByteBuffer)</code></a>. @@ -740,67 +674,13 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl </dl> </li> </ul> -<a name="channelRead-java.nio.channels.ReadableByteChannel-java.nio.ByteBuffer-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>channelRead</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1763">channelRead</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">ReadableByteChannel</a> channel, - <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> buffer) - throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">This is a wrapper around <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true#read-java.nio.ByteBuffer-"; title="class or interface in java.nio.channels"><code>ReadableByteChannel.read(java.nio.ByteBuffer)</code></a>. - If the amount of data is large, it writes to channel in smaller chunks. - This is to avoid jdk from creating many direct buffers as the size of - ByteBuffer increases. There should not be any performance degredation.</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>channel</code> - writable byte channel to write on</dd> -<dd><code>buffer</code> - buffer to write</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>number of bytes written</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code> - e</dd> -<dt><span class="seeLabel">See Also:</span></dt> -<dd><a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true#read-java.nio.ByteBuffer-"; title="class or interface in java.nio.channels"><code>ReadableByteChannel.read(java.nio.ByteBuffer)</code></a></dd> -</dl> -</li> -</ul> -<a name="channelIO-java.nio.channels.ReadableByteChannel-java.nio.channels.WritableByteChannel-java.nio.ByteBuffer-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>channelIO</h4> -<pre>protected static int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1787">channelIO</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">ReadableByteChannel</a> readCh, - <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/channels/WritableByteChannel.html?is-external=true"; title="class or interface in java.nio.channels">WritableByteChannel</a> writeCh, - <a href="http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a> buf) - throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<div class="block">Helper for <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelRead-java.nio.channels.ReadableByteChannel-java.nio.ByteBuffer-"><code>channelRead(java.nio.channels.ReadableByteChannel, java.nio.ByteBuffer)</code></a> - and <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelWrite-java.nio.channels.GatheringByteChannel-org.apache.hadoop.hbase.ipc.BufferChain-"><code>channelWrite(GatheringByteChannel, BufferChain)</code></a>. Only - one of readCh or writeCh should be non-null.</div> -<dl> -<dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>readCh</code> - read channel</dd> -<dd><code>writeCh</code> - write channel</dd> -<dd><code>buf</code> - buffer to read or write into/out of</dd> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>bytes written</dd> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code> - e</dd> -<dt><span class="seeLabel">See Also:</span></dt> -<dd><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelRead-java.nio.channels.ReadableByteChannel-java.nio.ByteBuffer-"><code>channelRead(java.nio.channels.ReadableByteChannel, java.nio.ByteBuffer)</code></a>, -<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#channelWrite-java.nio.channels.GatheringByteChannel-org.apache.hadoop.hbase.ipc.BufferChain-"><code>channelWrite(GatheringByteChannel, BufferChain)</code></a></dd> -</dl> -</li> -</ul> <a name="bind-java.net.ServerSocket-java.net.InetSocketAddress-int-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>bind</h4> -<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1825">bind</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/net/ServerSocket.html?is-external=true"; title="class or interface in java.net">ServerSocket</a> socket, +<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1254">bind</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/net/ServerSocket.html?is-external=true"; title="class or interface in java.net">ServerSocket</a> socket, <a href="http://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> address, int backlog) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> @@ -824,7 +704,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockListLast"> <li class="blockList"> <h4>getNumOpenConnections</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1850">getNumOpenConnections</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.1279">getNumOpenConnections</a>()</pre> <div class="block">The number of open RPC conections</div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/BufferChain.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/BufferChain.html b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/BufferChain.html index b2ba761..627009f 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/BufferChain.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/BufferChain.html @@ -120,7 +120,7 @@ </tr> <tbody> <tr class="altColor"> -<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a></code></td> +<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a></code></td> <td class="colLast"><span class="typeNameLabel">RpcServer.Call.</span><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html#wrapWithSasl-org.apache.hadoop.hbase.ipc.BufferChain-">wrapWithSasl</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a> bc)</code> </td> </tr> </tbody> @@ -140,7 +140,7 @@ </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a></code></td> +<td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a></code></td> <td class="colLast"><span class="typeNameLabel">RpcServer.Call.</span><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html#wrapWithSasl-org.apache.hadoop.hbase.ipc.BufferChain-">wrapWithSasl</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/ipc/BufferChain.html" title="class in org.apache.hadoop.hbase.ipc">BufferChain</a> bc)</code> </td> </tr> </tbody> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/FatalConnectionException.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/FatalConnectionException.html b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/FatalConnectionException.html index 634c621..d8b2689 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/FatalConnectionException.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/FatalConnectionException.html @@ -143,7 +143,7 @@ <tbody> <tr class="altColor"> <td class="colFirst"><code>private void</code></td> -<td class="colLast"><span class="typeNameLabel">SimpleRpcServer.Connection.</span><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html#responseConnectionHeader-org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder-">responseConnectionHeader</a></span>(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder chrBuilder)</code> </td> +<td class="colLast"><span class="typeNameLabel">RpcServer.Connection.</span><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html#responseConnectionHeader-org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder-">responseConnectionHeader</a></span>(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder chrBuilder)</code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>protected void</code></td>
