http://git-wip-us.apache.org/repos/asf/hbase-site/blob/c7469d69/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html index 4df8179..29254e4 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html @@ -101,7 +101,7 @@ <br> <pre><a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.LimitedPrivate.html" title="annotation in org.apache.hadoop.hbase.classification">@InterfaceAudience.LimitedPrivate</a>(<a href="../../../../../org/apache/hadoop/hbase/classification/InterfaceAudience.LimitedPrivate.html#value()">value</a>={"Coprocesssor","Phoenix"}) <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/RpcServer.html#line.164">RpcServer</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.167">RpcServer</a> extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterface.html" title="interface in org.apache.hadoop.hbase.ipc">RpcServerInterface</a>, <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationObserver.html" title="interface in org.apache.hadoop.hbase.conf">ConfigurationObserver</a></pre> <div class="block">An RPC server that hosts protobuf described Services. @@ -161,11 +161,15 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac </tr> <tr class="rowColor"> <td class="colFirst"><code>private class </code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.ConnectionManager.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.ConnectionManager</a></strong></code> </td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private class </code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener</a></strong></code> <div class="block">Listens on the socket.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected class </code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Responder</a></strong></code> </td> </tr> @@ -226,8 +230,9 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac </tr> <tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/util/Counter.html" title="class in org.apache.hadoop.hbase.util">Counter</a></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#callQueueSize">callQueueSize</a></strong></code> -<div class="block">This is a running count of the size of all outstanding calls by size.</div> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#callQueueSizeInBytes">callQueueSizeInBytes</a></strong></code> +<div class="block">This is a running count of the size in bytes of all outstanding calls whether currently + executing or queued waiting to be run.</div> </td> </tr> <tr class="rowColor"> @@ -235,8 +240,8 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#conf">conf</a></strong></code> </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/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.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a>></code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#connectionList">connectionList</a></strong></code> </td> +<td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.ConnectionManager.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.ConnectionManager</a></code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#connectionManager">connectionManager</a></strong></code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>protected static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/ThreadLocal.html?is-external=true"; title="class or interface in java.lang">ThreadLocal</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a>></code></td> @@ -257,9 +262,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac </tr> <tr class="altColor"> <td class="colFirst"><code>private static int</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_CALLQUEUE_SIZE">DEFAULT_MAX_CALLQUEUE_SIZE</a></strong></code> -<div class="block">The maximum size that we can hold in the RPC queue</div> -</td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#DEFAULT_MAX_CALLQUEUE_SIZE">DEFAULT_MAX_CALLQUEUE_SIZE</a></strong></code> </td> </tr> <tr class="rowColor"> <td class="colFirst"><code>private static int</code></td> @@ -314,16 +317,10 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#MAX_REQUEST_SIZE">MAX_REQUEST_SIZE</a></strong></code> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><code>(package private) int</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxConnectionsToNuke">maxConnectionsToNuke</a></strong></code> </td> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>protected int</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxIdleTime">maxIdleTime</a></strong></code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>private int</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxQueueSize">maxQueueSize</a></strong></code> </td> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#maxQueueSizeInBytes">maxQueueSizeInBytes</a></strong></code> +<div class="block">Maximum size in bytes of the currently queued and running Calls.</div> +</td> </tr> <tr class="altColor"> <td class="colFirst"><code>private int</code></td> @@ -358,73 +355,65 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac </tr> <tr class="altColor"> <td class="colFirst"><code>protected int</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#numConnections">numConnections</a></strong></code> </td> -</tr> -<tr class="rowColor"> -<td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#port">port</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#purgeTimeout">purgeTimeout</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#readThreads">readThreads</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/io/BoundedByteBufferPool.html" title="class in org.apache.hadoop.hbase.io">BoundedByteBufferPool</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#reservoir">reservoir</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Responder</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#responder">responder</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#running">running</a></strong></code> <div class="block">This flag is used to indicate to sub threads when they should go down.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#scheduler">scheduler</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected org.apache.hadoop.security.token.SecretManager<org.apache.hadoop.security.token.TokenIdentifier></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#secretManager">secretManager</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#server">server</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/7/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>></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#services">services</a></strong></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#socketSendBufferSize">socketSendBufferSize</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#started">started</a></strong></code> <div class="block">This flag is set to true after all threads are up and 'running' and the server is then opened for business by the call to <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#start()"><code>start()</code></a>.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>protected boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#tcpKeepAlive">tcpKeepAlive</a></strong></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#tcpNoDelay">tcpNoDelay</a></strong></code> </td> </tr> -<tr class="rowColor"> -<td class="colFirst"><code>protected int</code></td> -<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#thresholdIdleConnections">thresholdIdleConnections</a></strong></code> </td> -</tr> <tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/security/UserProvider.html" title="class in org.apache.hadoop.hbase.security">UserProvider</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#userProvider">userProvider</a></strong></code> </td> @@ -594,76 +583,82 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac </td> </tr> <tr class="altColor"> +<td class="colFirst"><code>int</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getNumOpenConnections()">getNumOpenConnections</a></strong>()</code> +<div class="block">The number of open RPC conections</div> +</td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetAddress.html?is-external=true"; title="class or interface in java.net">InetAddress</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRemoteAddress()">getRemoteAddress</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetAddress.html?is-external=true"; title="class or interface in java.net">InetAddress</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRemoteIp()">getRemoteIp</a></strong>()</code> <div class="block">Returns the remote side ip address when invoked inside an RPC Returns null incase of an error.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>static <a href="../../../../../org/apache/hadoop/hbase/security/User.html" title="class in org.apache.hadoop.hbase.security">User</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRequestUser()">getRequestUser</a></strong>()</code> <div class="block">Returns the user credentials associated with the current RPC request or <code>null</code> if no credentials were provided.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getRequestUserName()">getRequestUserName</a></strong>()</code> <div class="block">Returns the username for any user associated with the current RPC request or <code>null</code> if no user is set.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcScheduler.html" title="class in org.apache.hadoop.hbase.ipc">RpcScheduler</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getScheduler()">getScheduler</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getSecretManager()">getSecretManager</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) static com.google.protobuf.BlockingService</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getService(java.util.List,%20java.lang.String)">getService</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serviceName)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>(package private) static <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.BlockingServiceAndInterface</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getServiceAndInterface(java.util.List,%20java.lang.String)">getServiceAndInterface</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serviceName)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) static <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><?></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getServiceInterface(java.util.List,%20java.lang.String)">getServiceInterface</a></strong>(<a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> serviceName)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>(package private) static <a href="../../../../../org/apache/hadoop/hbase/monitoring/MonitoredRPCHandler.html" title="interface in org.apache.hadoop.hbase.monitoring">MonitoredRPCHandler</a></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#getStatus()">getStatus</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#initReconfigurable(org.apache.hadoop.conf.Configuration)">initReconfigurable</a></strong>(org.apache.hadoop.conf.Configuration confToLoad)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>static boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isInRpcCallContext()">isInRpcCallContext</a></strong>()</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#isStarted()">isStarted</a></strong>()</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#join()">join</a></strong>()</code> <div class="block">Wait for the server to be stopped.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>(package private) void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#logResponse(java.lang.Object[],%20java.lang.String,%20java.lang.String,%20java.lang.String,%20java.lang.String,%20long,%20int,%20int,%20long)">logResponse</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>[] params, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> methodName, @@ -678,36 +673,36 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac client Operations.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#onConfigurationChange(org.apache.hadoop.conf.Configuration)">onConfigurationChange</a></strong>(org.apache.hadoop.conf.Configuration newConf)</code> <div class="block">This method would be called by the <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationManager.html" title="class in org.apache.hadoop.hbase.conf"><code>ConfigurationManager</code></a> object when the <code>Configuration</code> object is reloaded from disk.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#refreshAuthManager(org.apache.hadoop.security.authorize.PolicyProvider)">refreshAuthManager</a></strong>(org.apache.hadoop.security.authorize.PolicyProvider pp)</code> <div class="block">Refresh authentication manager policy.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setErrorHandler(org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler)">setErrorHandler</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> handler)</code> <div class="block">Set the handler for calling out of RPC for error conditions.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setSecretManager(org.apache.hadoop.security.token.SecretManager)">setSecretManager</a></strong>(org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager)</code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setSocketSendBufSize(int)">setSocketSendBufSize</a></strong>(int size)</code> <div class="block">Sets the socket buffer size used for responding to RPCs.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#setupResponse(java.io.ByteArrayOutputStream,%20org.apache.hadoop.hbase.ipc.RpcServer.Call,%20java.lang.Throwable,%20java.lang.String)">setupResponse</a></strong>(<a href="http://docs.oracle.com/javase/7/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/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a> call, @@ -716,13 +711,13 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <div class="block">Setup response for the RPC Call.</div> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#start()">start</a></strong>()</code> <div class="block">Starts the service.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#stop()">stop</a></strong>()</code> <div class="block">Stops the service.</div> @@ -756,7 +751,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>public static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.166">LOG</a></pre> +<pre>public static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.169">LOG</a></pre> </li> </ul> <a name="CALL_QUEUE_TOO_BIG_EXCEPTION"> @@ -765,7 +760,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>CALL_QUEUE_TOO_BIG_EXCEPTION</h4> -<pre>private static final <a href="../../../../../org/apache/hadoop/hbase/CallQueueTooBigException.html" title="class in org.apache.hadoop.hbase">CallQueueTooBigException</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.167">CALL_QUEUE_TOO_BIG_EXCEPTION</a></pre> +<pre>private static final <a href="../../../../../org/apache/hadoop/hbase/CallQueueTooBigException.html" title="class in org.apache.hadoop.hbase">CallQueueTooBigException</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.170">CALL_QUEUE_TOO_BIG_EXCEPTION</a></pre> </li> </ul> <a name="authorize"> @@ -774,7 +769,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>authorize</h4> -<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.170">authorize</a></pre> +<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.173">authorize</a></pre> </li> </ul> <a name="isSecurityEnabled"> @@ -783,7 +778,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>isSecurityEnabled</h4> -<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.171">isSecurityEnabled</a></pre> +<pre>private boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.174">isSecurityEnabled</a></pre> </li> </ul> <a name="CURRENT_VERSION"> @@ -792,7 +787,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>CURRENT_VERSION</h4> -<pre>public static final byte <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.173">CURRENT_VERSION</a></pre> +<pre>public static final byte <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.176">CURRENT_VERSION</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.CURRENT_VERSION">Constant Field Values</a></dd></dl> </li> </ul> @@ -802,7 +797,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>FALLBACK_TO_INSECURE_CLIENT_AUTH</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.178">FALLBACK_TO_INSECURE_CLIENT_AUTH</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.181">FALLBACK_TO_INSECURE_CLIENT_AUTH</a></pre> <div class="block">Whether we allow a fallback to SIMPLE auth for insecure clients when security is enabled.</div> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.FALLBACK_TO_INSECURE_CLIENT_AUTH">Constant Field Values</a></dd></dl> </li> @@ -813,29 +808,18 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER</h4> -<pre>static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.184">DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER</a></pre> +<pre>static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.187">DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER</a></pre> <div class="block">How many calls/handler are allowed in the queue.</div> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER">Constant Field Values</a></dd></dl> </li> </ul> -<a name="DEFAULT_MAX_CALLQUEUE_SIZE"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>DEFAULT_MAX_CALLQUEUE_SIZE</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.189">DEFAULT_MAX_CALLQUEUE_SIZE</a></pre> -<div class="block">The maximum size that we can hold in the RPC queue</div> -<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_MAX_CALLQUEUE_SIZE">Constant Field Values</a></dd></dl> -</li> -</ul> <a name="ipcUtil"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>ipcUtil</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/IPCUtil.html" title="class in org.apache.hadoop.hbase.ipc">IPCUtil</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.191">ipcUtil</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/ipc/IPCUtil.html" title="class in org.apache.hadoop.hbase.ipc">IPCUtil</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.189">ipcUtil</a></pre> </li> </ul> <a name="AUTH_FAILED_FOR"> @@ -844,7 +828,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>AUTH_FAILED_FOR</h4> -<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.193">AUTH_FAILED_FOR</a></pre> +<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.191">AUTH_FAILED_FOR</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.AUTH_FAILED_FOR">Constant Field Values</a></dd></dl> </li> </ul> @@ -854,7 +838,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>AUTH_SUCCESSFUL_FOR</h4> -<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.194">AUTH_SUCCESSFUL_FOR</a></pre> +<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.192">AUTH_SUCCESSFUL_FOR</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.AUTH_SUCCESSFUL_FOR">Constant Field Values</a></dd></dl> </li> </ul> @@ -864,7 +848,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>AUDITLOG</h4> -<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.195">AUDITLOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.193">AUDITLOG</a></pre> </li> </ul> <a name="secretManager"> @@ -873,7 +857,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>secretManager</h4> -<pre>protected org.apache.hadoop.security.token.SecretManager<org.apache.hadoop.security.token.TokenIdentifier> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.197">secretManager</a></pre> +<pre>protected org.apache.hadoop.security.token.SecretManager<org.apache.hadoop.security.token.TokenIdentifier> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.195">secretManager</a></pre> </li> </ul> <a name="authManager"> @@ -882,7 +866,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>authManager</h4> -<pre>protected org.apache.hadoop.security.authorize.ServiceAuthorizationManager <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.198">authManager</a></pre> +<pre>protected org.apache.hadoop.security.authorize.ServiceAuthorizationManager <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.196">authManager</a></pre> </li> </ul> <a name="CurCall"> @@ -891,7 +875,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>CurCall</h4> -<pre>protected static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/ThreadLocal.html?is-external=true"; title="class or interface in java.lang">ThreadLocal</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.203">CurCall</a></pre> +<pre>protected static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/ThreadLocal.html?is-external=true"; title="class or interface in java.lang">ThreadLocal</a><<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.201">CurCall</a></pre> <div class="block">This is set to Call object before Handler invokes an RPC and ybdie after the call returns.</div> </li> @@ -902,7 +886,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>MONITORED_RPC</h4> -<pre>static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/ThreadLocal.html?is-external=true"; title="class or interface in java.lang">ThreadLocal</a><<a href="../../../../../org/apache/hadoop/hbase/monitoring/MonitoredRPCHandler.html" title="interface in org.apache.hadoop.hbase.monitoring">MonitoredRPCHandler</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.206">MONITORED_RPC</a></pre> +<pre>static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/ThreadLocal.html?is-external=true"; title="class or interface in java.lang">ThreadLocal</a><<a href="../../../../../org/apache/hadoop/hbase/monitoring/MonitoredRPCHandler.html" title="interface in org.apache.hadoop.hbase.monitoring">MonitoredRPCHandler</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.204">MONITORED_RPC</a></pre> <div class="block">Keeps MonitoredRPCHandler per handler thread.</div> </li> </ul> @@ -912,7 +896,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>bindAddress</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.209">bindAddress</a></pre> +<pre>protected final <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.207">bindAddress</a></pre> </li> </ul> <a name="port"> @@ -921,7 +905,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>port</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.210">port</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.208">port</a></pre> </li> </ul> <a name="address"> @@ -930,7 +914,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>address</h4> -<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.211">address</a></pre> +<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.209">address</a></pre> </li> </ul> <a name="readThreads"> @@ -939,61 +923,64 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>readThreads</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.212">readThreads</a></pre> -</li> -</ul> -<a name="maxIdleTime"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>maxIdleTime</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.213">maxIdleTime</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.210">readThreads</a></pre> </li> </ul> -<a name="thresholdIdleConnections"> +<a name="metrics"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>thresholdIdleConnections</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.216">thresholdIdleConnections</a></pre> +<h4>metrics</h4> +<pre>protected <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/RpcServer.html#line.211">metrics</a></pre> </li> </ul> -<a name="maxConnectionsToNuke"> +<a name="conf"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>maxConnectionsToNuke</h4> -<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.220">maxConnectionsToNuke</a></pre> +<h4>conf</h4> +<pre>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.213">conf</a></pre> </li> </ul> -<a name="metrics"> +<a name="maxQueueSizeInBytes"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>metrics</h4> -<pre>protected <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/RpcServer.html#line.224">metrics</a></pre> +<h4>maxQueueSizeInBytes</h4> +<pre>private final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.226">maxQueueSizeInBytes</a></pre> +<div class="block">Maximum size in bytes of the currently queued and running Calls. If a new Call puts us over + this size, then we will reject the call (after parsing it though). It will go back to the + client and client will retry. Set this size with "hbase.ipc.server.max.callqueue.size". The + call queue size gets incremented after we parse a call and before we add it to the queue of + calls for the scheduler to use. It get decremented after we have 'run' the Call. The current + size is kept in <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#callQueueSizeInBytes"><code>callQueueSizeInBytes</code></a>.</div> +<dl><dt><span class="strong">See Also:</span></dt><dd><code>#callQueueSizeInBytes}</code>, +<code>#DEFAULT_MAX_CALLQUEUE_SIZE}</code>, +<code>#callQueueSizeInBytes}</code></dd></dl> </li> </ul> -<a name="conf"> +<a name="DEFAULT_MAX_CALLQUEUE_SIZE"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>conf</h4> -<pre>protected final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.226">conf</a></pre> +<h4>DEFAULT_MAX_CALLQUEUE_SIZE</h4> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.227">DEFAULT_MAX_CALLQUEUE_SIZE</a></pre> +<dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_MAX_CALLQUEUE_SIZE">Constant Field Values</a></dd></dl> </li> </ul> -<a name="maxQueueSize"> +<a name="callQueueSizeInBytes"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>maxQueueSize</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.228">maxQueueSize</a></pre> +<h4>callQueueSizeInBytes</h4> +<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/util/Counter.html" title="class in org.apache.hadoop.hbase.util">Counter</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.233">callQueueSizeInBytes</a></pre> +<div class="block">This is a running count of the size in bytes of all outstanding calls whether currently + executing or queued waiting to be run.</div> </li> </ul> <a name="socketSendBufferSize"> @@ -1002,7 +989,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>socketSendBufferSize</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.229">socketSendBufferSize</a></pre> +<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.235">socketSendBufferSize</a></pre> </li> </ul> <a name="tcpNoDelay"> @@ -1011,7 +998,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>tcpNoDelay</h4> -<pre>protected final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.230">tcpNoDelay</a></pre> +<pre>protected final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.236">tcpNoDelay</a></pre> </li> </ul> <a name="tcpKeepAlive"> @@ -1020,7 +1007,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>tcpKeepAlive</h4> -<pre>protected final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.231">tcpKeepAlive</a></pre> +<pre>protected final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.237">tcpKeepAlive</a></pre> </li> </ul> <a name="purgeTimeout"> @@ -1029,7 +1016,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>purgeTimeout</h4> -<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.232">purgeTimeout</a></pre> +<pre>protected final long <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.238">purgeTimeout</a></pre> </li> </ul> <a name="running"> @@ -1038,7 +1025,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>running</h4> -<pre>volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.239">running</a></pre> +<pre>volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.245">running</a></pre> <div class="block">This flag is used to indicate to sub threads when they should go down. When we call <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#start()"><code>start()</code></a>, all threads started will consult this flag on whether they should keep going. It is set to false when <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#stop()"><code>stop()</code></a> is called.</div> @@ -1050,28 +1037,18 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>started</h4> -<pre>volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.245">started</a></pre> +<pre>volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.251">started</a></pre> <div class="block">This flag is set to true after all threads are up and 'running' and the server is then opened for business by the call to <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.html#start()"><code>start()</code></a>.</div> </li> </ul> -<a name="callQueueSize"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>callQueueSize</h4> -<pre>protected final <a href="../../../../../org/apache/hadoop/hbase/util/Counter.html" title="class in org.apache.hadoop.hbase.util">Counter</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.250">callQueueSize</a></pre> -<div class="block">This is a running count of the size of all outstanding calls by size.</div> -</li> -</ul> -<a name="connectionList"> +<a name="connectionManager"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>connectionList</h4> -<pre>protected final <a href="http://docs.oracle.com/javase/7/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.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.252">connectionList</a></pre> +<h4>connectionManager</h4> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.ConnectionManager.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.ConnectionManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.254">connectionManager</a></pre> </li> </ul> <a name="listener"> @@ -1080,7 +1057,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>listener</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.256">listener</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Listener.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Listener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.255">listener</a></pre> </li> </ul> <a name="responder"> @@ -1089,7 +1066,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>responder</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Responder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.257">responder</a></pre> +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Responder.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Responder</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.256">responder</a></pre> </li> </ul> <a name="authTokenSecretMgr"> @@ -1098,16 +1075,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>authTokenSecretMgr</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/security/token/AuthenticationTokenSecretManager.html" title="class in org.apache.hadoop.hbase.security.token">AuthenticationTokenSecretManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.258">authTokenSecretMgr</a></pre> -</li> -</ul> -<a name="numConnections"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>numConnections</h4> -<pre>protected int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.259">numConnections</a></pre> +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/security/token/AuthenticationTokenSecretManager.html" title="class in org.apache.hadoop.hbase.security.token">AuthenticationTokenSecretManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.257">authTokenSecretMgr</a></pre> </li> </ul> <a name="errorHandler"> @@ -1116,7 +1084,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>errorHandler</h4> -<pre>protected <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/RpcServer.html#line.261">errorHandler</a></pre> +<pre>protected <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/RpcServer.html#line.259">errorHandler</a></pre> </li> </ul> <a name="MAX_REQUEST_SIZE"> @@ -1125,7 +1093,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>MAX_REQUEST_SIZE</h4> -<pre>static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.263">MAX_REQUEST_SIZE</a></pre> +<pre>static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.261">MAX_REQUEST_SIZE</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.MAX_REQUEST_SIZE">Constant Field Values</a></dd></dl> </li> </ul> @@ -1135,7 +1103,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>WARN_RESPONSE_TIME</h4> -<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.264">WARN_RESPONSE_TIME</a></pre> +<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.262">WARN_RESPONSE_TIME</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.WARN_RESPONSE_TIME">Constant Field Values</a></dd></dl> </li> </ul> @@ -1145,7 +1113,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>WARN_RESPONSE_SIZE</h4> -<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.265">WARN_RESPONSE_SIZE</a></pre> +<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.263">WARN_RESPONSE_SIZE</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.WARN_RESPONSE_SIZE">Constant Field Values</a></dd></dl> </li> </ul> @@ -1155,7 +1123,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>MIN_CLIENT_REQUEST_TIMEOUT</h4> -<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.271">MIN_CLIENT_REQUEST_TIMEOUT</a></pre> +<pre>private static final <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.269">MIN_CLIENT_REQUEST_TIMEOUT</a></pre> <div class="block">Minimum allowable timeout (in milliseconds) in rpc request's header. This configuration exists to prevent the rpc service regarding this request as timeout immediately.</div> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.MIN_CLIENT_REQUEST_TIMEOUT">Constant Field Values</a></dd></dl> @@ -1167,7 +1135,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.272">DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.270">DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT">Constant Field Values</a></dd></dl> </li> </ul> @@ -1177,7 +1145,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_MAX_REQUEST_SIZE</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.275">DEFAULT_MAX_REQUEST_SIZE</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.273">DEFAULT_MAX_REQUEST_SIZE</a></pre> <div class="block">Default value for above params</div> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_MAX_REQUEST_SIZE">Constant Field Values</a></dd></dl> </li> @@ -1188,7 +1156,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_WARN_RESPONSE_TIME</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.276">DEFAULT_WARN_RESPONSE_TIME</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.274">DEFAULT_WARN_RESPONSE_TIME</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_WARN_RESPONSE_TIME">Constant Field Values</a></dd></dl> </li> </ul> @@ -1198,7 +1166,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>DEFAULT_WARN_RESPONSE_SIZE</h4> -<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.277">DEFAULT_WARN_RESPONSE_SIZE</a></pre> +<pre>private static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.275">DEFAULT_WARN_RESPONSE_SIZE</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.ipc.RpcServer.DEFAULT_WARN_RESPONSE_SIZE">Constant Field Values</a></dd></dl> </li> </ul> @@ -1208,7 +1176,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>MAPPER</h4> -<pre>private static final org.codehaus.jackson.map.ObjectMapper <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.279">MAPPER</a></pre> +<pre>private static final org.codehaus.jackson.map.ObjectMapper <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.277">MAPPER</a></pre> </li> </ul> <a name="maxRequestSize"> @@ -1217,7 +1185,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>maxRequestSize</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.281">maxRequestSize</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.279">maxRequestSize</a></pre> </li> </ul> <a name="warnResponseTime"> @@ -1226,7 +1194,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>warnResponseTime</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.282">warnResponseTime</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.280">warnResponseTime</a></pre> </li> </ul> <a name="warnResponseSize"> @@ -1235,7 +1203,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>warnResponseSize</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.283">warnResponseSize</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.281">warnResponseSize</a></pre> </li> </ul> <a name="minClientRequestTimeout"> @@ -1244,7 +1212,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>minClientRequestTimeout</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.285">minClientRequestTimeout</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.283">minClientRequestTimeout</a></pre> </li> </ul> <a name="server"> @@ -1253,7 +1221,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>server</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.287">server</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/Server.html" title="interface in org.apache.hadoop.hbase">Server</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.285">server</a></pre> </li> </ul> <a name="services"> @@ -1262,7 +1230,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>services</h4> -<pre>private final <a href="http://docs.oracle.com/javase/7/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>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.288">services</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/7/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>> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.286">services</a></pre> </li> </ul> <a name="scheduler"> @@ -1271,7 +1239,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>scheduler</h4> -<pre>private final <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/RpcServer.html#line.290">scheduler</a></pre> +<pre>private final <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/RpcServer.html#line.288">scheduler</a></pre> </li> </ul> <a name="userProvider"> @@ -1280,7 +1248,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>userProvider</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/security/UserProvider.html" title="class in org.apache.hadoop.hbase.security">UserProvider</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.292">userProvider</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/security/UserProvider.html" title="class in org.apache.hadoop.hbase.security">UserProvider</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.290">userProvider</a></pre> </li> </ul> <a name="reservoir"> @@ -1289,7 +1257,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>reservoir</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/io/BoundedByteBufferPool.html" title="class in org.apache.hadoop.hbase.io">BoundedByteBufferPool</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.294">reservoir</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/io/BoundedByteBufferPool.html" title="class in org.apache.hadoop.hbase.io">BoundedByteBufferPool</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.292">reservoir</a></pre> </li> </ul> <a name="allowFallbackToSimpleAuth"> @@ -1298,7 +1266,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>allowFallbackToSimpleAuth</h4> -<pre>private volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.296">allowFallbackToSimpleAuth</a></pre> +<pre>private volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.294">allowFallbackToSimpleAuth</a></pre> </li> </ul> <a name="NIO_BUFFER_LIMIT"> @@ -1307,7 +1275,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockListLast"> <li class="blockList"> <h4>NIO_BUFFER_LIMIT</h4> -<pre>private static int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2469">NIO_BUFFER_LIMIT</a></pre> +<pre>private static int <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2383">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> @@ -1327,7 +1295,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockListLast"> <li class="blockList"> <h4>RpcServer</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2075">RpcServer</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/RpcServer.html#line.1995">RpcServer</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/7/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/7/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/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> bindAddress, @@ -1355,7 +1323,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>onConfigurationChange</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2136">onConfigurationChange</a>(org.apache.hadoop.conf.Configuration newConf)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2055">onConfigurationChange</a>(org.apache.hadoop.conf.Configuration newConf)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationObserver.html#onConfigurationChange(org.apache.hadoop.conf.Configuration)">ConfigurationObserver</a></code></strong></div> <div class="block">This method would be called by the <a href="../../../../../org/apache/hadoop/hbase/conf/ConfigurationManager.html" title="class in org.apache.hadoop.hbase.conf"><code>ConfigurationManager</code></a> object when the <code>Configuration</code> object is reloaded from disk.</div> @@ -1371,7 +1339,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>initReconfigurable</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2143">initReconfigurable</a>(org.apache.hadoop.conf.Configuration confToLoad)</pre> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2062">initReconfigurable</a>(org.apache.hadoop.conf.Configuration confToLoad)</pre> </li> </ul> <a name="getConnection(java.nio.channels.SocketChannel, long)"> @@ -1380,7 +1348,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>getConnection</h4> -<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2161">getConnection</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel, +<pre>protected <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2080">getConnection</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/channels/SocketChannel.html?is-external=true"; title="class or interface in java.nio.channels">SocketChannel</a> channel, long time)</pre> <div class="block">Subclasses of HBaseServer can override this to provide their own Connection implementations.</div> @@ -1392,7 +1360,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>setupResponse</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2173">setupResponse</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/io/ByteArrayOutputStream.html?is-external=true"; title="class or interface in java.io">ByteArrayOutputStream</a> response, +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2092">setupResponse</a>(<a href="http://docs.oracle.com/javase/7/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/RpcServer.Call.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Call</a> call, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> t, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> error) @@ -1409,7 +1377,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>closeConnection</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2179">closeConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> connection)</pre> +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2098">closeConnection</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServer.Connection.html" title="class in org.apache.hadoop.hbase.ipc">RpcServer.Connection</a> connection)</pre> </li> </ul> <a name="getConf()"> @@ -1418,7 +1386,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>getConf</h4> -<pre>org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2188">getConf</a>()</pre> +<pre>org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2102">getConf</a>()</pre> </li> </ul> <a name="setSocketSendBufSize(int)"> @@ -1427,7 +1395,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>setSocketSendBufSize</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2196">setSocketSendBufSize</a>(int size)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2110">setSocketSendBufSize</a>(int size)</pre> <div class="block">Sets the socket buffer size used for responding to RPCs.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -1441,7 +1409,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>isStarted</h4> -<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2199">isStarted</a>()</pre> +<pre>public boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2113">isStarted</a>()</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterface.html#isStarted()">isStarted</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterface.html" title="interface in org.apache.hadoop.hbase.ipc">RpcServerInterface</a></code></dd> @@ -1454,7 +1422,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>start</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2205">start</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2119">start</a>()</pre> <div class="block">Starts the service. Must be called before any calls will be handled.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -1468,7 +1436,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>refreshAuthManager</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2221">refreshAuthManager</a>(org.apache.hadoop.security.authorize.PolicyProvider pp)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2135">refreshAuthManager</a>(org.apache.hadoop.security.authorize.PolicyProvider pp)</pre> <div class="block"><strong>Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterface.html#refreshAuthManager(org.apache.hadoop.security.authorize.PolicyProvider)">RpcServerInterface</a></code></strong></div> <div class="block">Refresh authentication manager policy.</div> <dl> @@ -1483,7 +1451,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>createSecretManager</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/security/token/AuthenticationTokenSecretManager.html" title="class in org.apache.hadoop.hbase.security.token">AuthenticationTokenSecretManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2227">createSecretManager</a>()</pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/security/token/AuthenticationTokenSecretManager.html" title="class in org.apache.hadoop.hbase.security.token">AuthenticationTokenSecretManager</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2141">createSecretManager</a>()</pre> </li> </ul> <a name="getSecretManager()"> @@ -1492,7 +1460,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>getSecretManager</h4> -<pre>public org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2239">getSecretManager</a>()</pre> +<pre>public org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2153">getSecretManager</a>()</pre> </li> </ul> <a name="setSecretManager(org.apache.hadoop.security.token.SecretManager)"> @@ -1501,7 +1469,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>setSecretManager</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2244">setSecretManager</a>(org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2158">setSecretManager</a>(org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> secretManager)</pre> </li> </ul> <a name="call(com.google.protobuf.BlockingService, com.google.protobuf.Descriptors.MethodDescriptor, com.google.protobuf.Message, org.apache.hadoop.hbase.CellScanner, long, org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler)"> @@ -1510,7 +1478,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <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><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/RpcServer.html#line.2248">call</a>(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><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/RpcServer.html#line.2162">call</a>(com.google.protobuf.BlockingService service, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, @@ -1530,7 +1498,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <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><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/RpcServer.html#line.2260">call</a>(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><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/RpcServer.html#line.2174">call</a>(com.google.protobuf.BlockingService service, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, <a href="../../../../../org/apache/hadoop/hbase/CellScanner.html" title="interface in org.apache.hadoop.hbase">CellScanner</a> cellScanner, @@ -1554,7 +1522,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>logResponse</h4> -<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2336">logResponse</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>[] params, +<pre>void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2250">logResponse</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a>[] params, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> methodName, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> call, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tag, @@ -1578,7 +1546,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>stop</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2379">stop</a>()</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2293">stop</a>()</pre> <div class="block">Stops the service. No new calls will be handled after this is called.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -1592,7 +1560,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>join</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2399">join</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2313">join</a>() throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Wait for the server to be stopped. Does not wait for all subthreads to finish. @@ -1610,7 +1578,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>getListenerAddress</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2412">getListenerAddress</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/net/InetSocketAddress.html?is-external=true"; title="class or interface in java.net">InetSocketAddress</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2326">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> @@ -1626,7 +1594,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>setErrorHandler</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2424">setErrorHandler</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> handler)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/ipc/RpcServer.html#line.2338">setErrorHandler</a>(<a href="../../../../../org/apache/hadoop/hbase/ipc/HBaseRPCErrorHandler.html" title="interface in org.apache.hadoop.hbase.ipc">HBaseRPCErrorHandler</a> handler)</pre> <div class="block">Set the handler for calling out of RPC for error conditions.</div> <dl> <dt><strong>Specified by:</strong></dt> @@ -1640,7 +1608,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterfac <ul class="blockList"> <li class="blockList"> <h4>getErrorHandler</h4> -<pre>public <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/RpcServer.html#line.2429">getErrorHandler</a>()</pre> +<pre>public <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/RpcServer.html#line.2343">getErrorHandler</a>()</pre> <dl> <dt><strong>Specified by:</strong></dt> <dd><code><a href="../../../../../org/apache/hadoop/hbase/ipc/RpcServerInterface.html#getErrorHandler()">getErrorHandler</a></code> in interface <code><a href="../../../../../org/apache/hadoo
<TRUNCATED>
