Repository: accumulo Updated Branches: refs/heads/master ab4cc79ac -> b7927906f
ACCUMULO-3394 Update some documentation. Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/79fa912f Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/79fa912f Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/79fa912f Branch: refs/heads/master Commit: 79fa912fc1c9b2b4d255ab5d3d9f7ba9d9c3e971 Parents: 6e368ed Author: Josh Elser <els...@apache.org> Authored: Mon Dec 8 21:17:54 2014 -0500 Committer: Josh Elser <els...@apache.org> Committed: Mon Dec 8 22:04:17 2014 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/accumulo/server/thrift/TServerUtils.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/79fa912f/server/base/src/main/java/org/apache/accumulo/server/thrift/TServerUtils.java ---------------------------------------------------------------------- diff --git a/server/base/src/main/java/org/apache/accumulo/server/thrift/TServerUtils.java b/server/base/src/main/java/org/apache/accumulo/server/thrift/TServerUtils.java index 4e6a758..123caab 100644 --- a/server/base/src/main/java/org/apache/accumulo/server/thrift/TServerUtils.java +++ b/server/base/src/main/java/org/apache/accumulo/server/thrift/TServerUtils.java @@ -123,6 +123,9 @@ public class TServerUtils { throw new UnknownHostException("Unable to find a listen port"); } + /** + * Create a NonBlockingServer with a custom thread pool that can dynamically resize itself. + */ public static ServerAddress createNonBlockingServer(HostAndPort address, TProcessor processor, final String serverName, String threadName, final int numThreads, final int numSTThreads, long timeBetweenThreadChecks, long maxMessageSize) throws TTransportException { TNonblockingServerSocket transport = new TNonblockingServerSocket(new InetSocketAddress(address.getHostText(), address.getPort()));
