http://git-wip-us.apache.org/repos/asf/hbase-site/blob/071f974b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html index e9c58c6..804b43d 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html @@ -105,9 +105,8 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) - @InterfaceStability.Evolving -public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.42">RpcServerInterface</a></pre> +<pre>@InterfaceAudience.Private +public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.38">RpcServerInterface</a></pre> </li> </ul> </div> @@ -238,7 +237,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>start</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.43">start</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.39">start</a>()</pre> </li> </ul> <a name="isStarted--"> @@ -247,7 +246,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>isStarted</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.44">isStarted</a>()</pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.40">isStarted</a>()</pre> </li> </ul> <a name="stop--"> @@ -256,7 +255,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>stop</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.46">stop</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.42">stop</a>()</pre> </li> </ul> <a name="join--"> @@ -265,7 +264,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>join</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.47">join</a>() +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.43">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> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -279,7 +278,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>setSocketSendBufSize</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.49">setSocketSendBufSize</a>(int size)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.45">setSocketSendBufSize</a>(int size)</pre> </li> </ul> <a name="getListenerAddress--"> @@ -288,7 +287,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>getListenerAddress</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/RpcServerInterface.html#line.50">getListenerAddress</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/RpcServerInterface.html#line.46">getListenerAddress</a>()</pre> </li> </ul> <a name="call-org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService-org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptor-org.apache.hadoop.hbase.shaded.com.google.protobuf.Message-org.apache.hadoop.hbase.CellScanner-long-org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler-"> @@ -298,7 +297,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <li class="blockList"> <h4>call</h4> <pre><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -<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/RpcServerInterface.html#line.56">call</a>(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service, +<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/RpcServerInterface.html#line.52">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, @@ -319,7 +318,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <li class="blockList"> <h4>call</h4> <pre><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -<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/RpcServerInterface.html#line.64">call</a>(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service, +<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/RpcServerInterface.html#line.60">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, @@ -341,7 +340,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>call</h4> -<pre><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/RpcServerInterface.html#line.68">call</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcCall.html" title="interface in org.apache.hadoop.hbase.ipc">RpcCall</a> call, +<pre><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/RpcServerInterface.html#line.64">call</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcCall.html" title="interface in org.apache.hadoop.hbase.ipc">RpcCall</a> call, <a href="../../../../../org/apache/hadoop/hbase/monitoring/MonitoredRPCHandler.html" title="interface in org.apache.hadoop.hbase.monitoring">MonitoredRPCHandler</a> status) 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> @@ -356,7 +355,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>setErrorHandler</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.71">setErrorHandler</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> handler)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.67">setErrorHandler</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> handler)</pre> </li> </ul> <a name="getErrorHandler--"> @@ -365,7 +364,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>getErrorHandler</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.72">getErrorHandler</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.68">getErrorHandler</a>()</pre> </li> </ul> <a name="getMetrics--"> @@ -374,7 +373,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>getMetrics</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/MetricsHBaseServer.html" title="class in org.apache.hadoop.hbase.ipc">MetricsHBaseServer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.77">getMetrics</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/MetricsHBaseServer.html" title="class in org.apache.hadoop.hbase.ipc">MetricsHBaseServer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.73">getMetrics</a>()</pre> <div class="block">Returns the metrics instance for reporting RPC call statistics</div> </li> </ul> @@ -384,7 +383,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>addCallSize</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.84">addCallSize</a>(long diff)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.80">addCallSize</a>(long diff)</pre> <div class="block">Add/subtract from the current size of all outstanding calls. Called on setup of a call to add call total size and then again at end of a call to remove the call size.</div> <dl> @@ -399,7 +398,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>refreshAuthManager</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.91">refreshAuthManager</a>(org.apache.hadoop.security.authorize.PolicyProvider pp)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.87">refreshAuthManager</a>(org.apache.hadoop.security.authorize.PolicyProvider pp)</pre> <div class="block">Refresh authentication manager policy.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -413,7 +412,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockList"> <li class="blockList"> <h4>getScheduler</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.93">getScheduler</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.89">getScheduler</a>()</pre> </li> </ul> <a name="setRsRpcServices-org.apache.hadoop.hbase.regionserver.RSRpcServices-"> @@ -422,7 +421,7 @@ public interface <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/Rp <ul class="blockListLast"> <li class="blockList"> <h4>setRsRpcServices</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.95">setRsRpcServices</a>(<a href="../../../../../org/apache/hadoop/hbase/regionserver/RSRpcServices.html" title="class in org.apache.hadoop.hbase.regionserver">RSRpcServices</a> rsRpcServices)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServerInterface.html#line.91">setRsRpcServices</a>(<a href="../../../../../org/apache/hadoop/hbase/regionserver/RSRpcServices.html" title="class in org.apache.hadoop.hbase.regionserver">RSRpcServices</a> rsRpcServices)</pre> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/071f974b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html index 1df5093..04a810e 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.556">SimpleRpcServer.ConnectionManager</a> +<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.555">SimpleRpcServer.ConnectionManager</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> </li> </ul> @@ -265,7 +265,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>count</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.557">count</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.556">count</a></pre> </li> </ul> <a name="connections"> @@ -274,7 +274,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>connections</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/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.558">connections</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/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.557">connections</a></pre> </li> </ul> <a name="idleScanTimer"> @@ -283,7 +283,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>idleScanTimer</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Timer.html?is-external=true"; title="class or interface in java.util">Timer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.560">idleScanTimer</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Timer.html?is-external=true"; title="class or interface in java.util">Timer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.559">idleScanTimer</a></pre> </li> </ul> <a name="idleScanThreshold"> @@ -292,7 +292,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>idleScanThreshold</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.561">idleScanThreshold</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.560">idleScanThreshold</a></pre> </li> </ul> <a name="idleScanInterval"> @@ -301,7 +301,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>idleScanInterval</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.562">idleScanInterval</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.561">idleScanInterval</a></pre> </li> </ul> <a name="maxIdleTime"> @@ -310,7 +310,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>maxIdleTime</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.563">maxIdleTime</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.562">maxIdleTime</a></pre> </li> </ul> <a name="maxIdleToClose"> @@ -319,7 +319,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>maxIdleToClose</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.564">maxIdleToClose</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.563">maxIdleToClose</a></pre> </li> </ul> </li> @@ -336,7 +336,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>ConnectionManager</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.566">ConnectionManager</a>()</pre> +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.565">ConnectionManager</a>()</pre> </li> </ul> </li> @@ -353,7 +353,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>add</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.584">add</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.583">add</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> </li> </ul> <a name="remove-org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection-"> @@ -362,7 +362,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>remove</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.592">remove</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.591">remove</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> </li> </ul> <a name="size--"> @@ -371,7 +371,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>size</h4> -<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.600">size</a>()</pre> +<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.599">size</a>()</pre> </li> </ul> <a name="toArray--"> @@ -380,7 +380,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>toArray</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.604">toArray</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a>[] <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.603">toArray</a>()</pre> </li> </ul> <a name="register-java.nio.channels.SocketChannel-"> @@ -389,7 +389,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>register</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.608">register</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> +<pre><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.607">register</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> </li> </ul> <a name="close-org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection-"> @@ -398,7 +398,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.621">close</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> +<pre>boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.620">close</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> </li> </ul> <a name="closeIdle-boolean-"> @@ -407,7 +407,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>closeIdle</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.638">closeIdle</a>(boolean scanAll)</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.637">closeIdle</a>(boolean scanAll)</pre> </li> </ul> <a name="closeAll--"> @@ -416,7 +416,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>closeAll</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.659">closeAll</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.658">closeAll</a>()</pre> </li> </ul> <a name="startIdleScan--"> @@ -425,7 +425,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>startIdleScan</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.667">startIdleScan</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.666">startIdleScan</a>()</pre> </li> </ul> <a name="stopIdleScan--"> @@ -434,7 +434,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>stopIdleScan</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.671">stopIdleScan</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.670">stopIdleScan</a>()</pre> </li> </ul> <a name="scheduleIdleScanTask--"> @@ -443,7 +443,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>scheduleIdleScanTask</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.675">scheduleIdleScanTask</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.ConnectionManager.html#line.674">scheduleIdleScanTask</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/071f974b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html index c7e0fa0..9686918 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.150">SimpleRpcServer.Listener.Reader</a> +<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.149">SimpleRpcServer.Listener.Reader</a> extends <a href="http://docs.oracle.com/javase/8/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/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></pre> </li> @@ -221,7 +221,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable. <ul class="blockList"> <li class="blockList"> <h4>pendingConnections</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/LinkedBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">LinkedBlockingQueue</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.151">pendingConnections</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/LinkedBlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">LinkedBlockingQueue</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.150">pendingConnections</a></pre> </li> </ul> <a name="readSelector"> @@ -230,7 +230,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable. <ul class="blockListLast"> <li class="blockList"> <h4>readSelector</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.Listener.Reader.html#line.152">readSelector</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.Listener.Reader.html#line.151">readSelector</a></pre> </li> </ul> </li> @@ -247,7 +247,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable. <ul class="blockListLast"> <li class="blockList"> <h4>Reader</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.154">Reader</a>() +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.153">Reader</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> @@ -269,7 +269,7 @@ throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.htm <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.160">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.159">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> @@ -282,7 +282,7 @@ throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.htm <ul class="blockList"> <li class="blockList"> <h4>doRunLoop</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.172">doRunLoop</a>()</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.171">doRunLoop</a>()</pre> </li> </ul> <a name="addConnection-org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection-"> @@ -291,7 +291,7 @@ throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.htm <ul class="blockListLast"> <li class="blockList"> <h4>addConnection</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.211">addConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> conn) +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.Reader.html#line.210">addConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> conn) 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">Updating the readSelector while it's being used is not thread-safe, so the connection must be queued. The reader will drain the queue http://git-wip-us.apache.org/repos/asf/hbase-site/blob/071f974b/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 0268be0..bfca768 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.101">SimpleRpcServer.Listener</a> +<pre>private class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.100">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.103">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.102">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.104">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.103">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.105">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.104">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.106">currentReader</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.105">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.107">readerPendingConnectionQueueLength</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.106">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.109">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.108">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.111">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.110">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.221">run</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.220">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.285">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.284">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.295">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.294">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.299">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.298">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.320">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.319">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.346">doStop</a>()</pre> +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html#line.345">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.363">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.362">getReader</a>()</pre> </li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/071f974b/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 4d6d110..dab22e7 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html @@ -118,9 +118,8 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>@InterfaceAudience.Private - @InterfaceStability.Evolving -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.86">SimpleRpcServer</a> +<pre>@InterfaceAudience.LimitedPrivate(value="Configuration") +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.85">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, @@ -248,12 +247,13 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <th class="colOne" scope="col">Constructor and Description</th> </tr> <tr class="altColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#SimpleRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-">SimpleRpcServer</a></span>(<a href="../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> server, +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#SimpleRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-boolean-">SimpleRpcServer</a></span>(<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, org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler)</code> + <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler, + boolean reservoirEnabled)</code> <div class="block">Constructs a server listening on the named port and address.</div> </td> </tr> @@ -391,7 +391,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.88">port</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.87">port</a></pre> </li> </ul> <a name="address"> @@ -400,7 +400,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.89">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.88">address</a></pre> </li> </ul> <a name="readThreads"> @@ -409,7 +409,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.90">readThreads</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.89">readThreads</a></pre> </li> </ul> <a name="socketSendBufferSize"> @@ -418,7 +418,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.92">socketSendBufferSize</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.91">socketSendBufferSize</a></pre> </li> </ul> <a name="purgeTimeout"> @@ -427,7 +427,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.93">purgeTimeout</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.92">purgeTimeout</a></pre> </li> </ul> <a name="connectionManager"> @@ -436,7 +436,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.96">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.95">connectionManager</a></pre> </li> </ul> <a name="listener"> @@ -445,7 +445,7 @@ 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.97">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.96">listener</a></pre> </li> </ul> <a name="responder"> @@ -454,7 +454,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockListLast"> <li class="blockList"> <h4>responder</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServerResponder.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServerResponder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.98">responder</a></pre> +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServerResponder.html" title="class in org.apache.hadoop.hbase.ipc">SimpleRpcServerResponder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.97">responder</a></pre> </li> </ul> </li> @@ -465,7 +465,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <!-- --> </a> <h3>Constructor Detail</h3> -<a name="SimpleRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-"> +<a name="SimpleRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-boolean-"> <!-- --> </a> <ul class="blockListLast"> @@ -476,7 +476,8 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <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, org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler) + <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler, + boolean reservoirEnabled) 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">Constructs a server listening on the named port and address.</div> <dl> @@ -488,6 +489,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <dd><code>bindAddress</code> - Where to listen</dd> <dd><code>conf</code> - </dd> <dd><code>scheduler</code> - </dd> +<dd><code>reservoirEnabled</code> - Enable ByteBufferPool or not.</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> @@ -507,7 +509,7 @@ 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/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.406">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/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.405">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> @@ -519,7 +521,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <ul class="blockList"> <li class="blockList"> <h4>closeConnection</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.410">closeConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.409">closeConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/SimpleServerRpcConnection.html" title="class in org.apache.hadoop.hbase.ipc">SimpleServerRpcConnection</a> connection)</pre> </li> </ul> <a name="setSocketSendBufSize-int-"> @@ -528,7 +530,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.418">setSocketSendBufSize</a>(int size)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.417">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> @@ -542,7 +544,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.422">start</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.421">start</a>()</pre> <div class="block">Starts the service. Must be called before any calls will be handled.</div> </li> </ul> @@ -552,7 +554,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.439">stop</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.438">stop</a>()</pre> <div class="block">Stops the service. No new calls will be handled after this is called.</div> </li> </ul> @@ -562,7 +564,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.459">join</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.458">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. @@ -579,7 +581,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.472">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.471">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> @@ -595,7 +597,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.480">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.479">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, @@ -614,7 +616,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.488">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.487">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, @@ -635,7 +637,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.510">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.509">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>. @@ -663,7 +665,7 @@ extends <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" titl <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.527">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.526">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> @@ -687,7 +689,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.552">getNumOpenConnections</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#line.551">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/071f974b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcScheduler.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcScheduler.html b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcScheduler.html index 91bc68e..b57c17e 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcScheduler.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcScheduler.html @@ -172,6 +172,16 @@ org.apache.hadoop.conf.Configuration conf, <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler)</code> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>static <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer</a></code></td> +<td class="colLast"><span class="typeNameLabel">RpcServerFactory.</span><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServerFactory.html#createRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-boolean-">createRpcServer</a></span>(<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, + org.apache.hadoop.conf.Configuration conf, + <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler, + boolean reservoirEnabled)</code> </td> +</tr> </tbody> </table> <table class="useSummary" border="0" cellpadding="3" cellspacing="0" summary="Use table, listing constructors, and an explanation"> @@ -181,30 +191,33 @@ </tr> <tbody> <tr class="altColor"> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/NettyRpcServer.html#NettyRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-">NettyRpcServer</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> server, +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/NettyRpcServer.html#NettyRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-boolean-">NettyRpcServer</a></span>(<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, org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler)</code> </td> + <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler, + boolean reservoirEnabled)</code> </td> </tr> <tr class="rowColor"> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#RpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-">RpcServer</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> server, +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#RpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-boolean-">RpcServer</a></span>(<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, org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler)</code> + <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler, + boolean reservoirEnabled)</code> <div class="block">Constructs a server listening on the named port and address.</div> </td> </tr> <tr class="altColor"> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#SimpleRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-">SimpleRpcServer</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> server, +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/ipc/SimpleRpcServer.html#SimpleRpcServer-org.apache.hadoop.hbase.Server-java.lang.String-java.util.List-java.net.InetSocketAddress-org.apache.hadoop.conf.Configuration-org.apache.hadoop.hbase.ipc.RpcScheduler-boolean-">SimpleRpcServer</a></span>(<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, org.apache.hadoop.conf.Configuration conf, - <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler)</code> + <a href="../../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a> scheduler, + boolean reservoirEnabled)</code> <div class="block">Constructs a server listening on the named port and address.</div> </td> </tr>
