accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [2/5] accumulo git commit: ACCUMULO-3394 Remove unused method.
Date Tue, 09 Dec 2014 03:11:55 GMT
ACCUMULO-3394 Remove unused method.


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/6e368edb
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/6e368edb
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/6e368edb

Branch: refs/heads/master
Commit: 6e368edb8cd5eb5a68e75f45352a8fdfacaedc1e
Parents: f25d850
Author: Josh Elser <elserj@apache.org>
Authored: Mon Dec 8 21:17:41 2014 -0500
Committer: Josh Elser <elserj@apache.org>
Committed: Mon Dec 8 22:04:17 2014 -0500

----------------------------------------------------------------------
 .../accumulo/server/thrift/TServerUtils.java    | 20 --------------------
 1 file changed, 20 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/6e368edb/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 ca182d4..4e6a758 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
@@ -16,14 +16,11 @@
  */
 package org.apache.accumulo.server.thrift;
 
-import java.io.IOException;
 import java.lang.reflect.Field;
 import java.net.BindException;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
-import java.net.ServerSocket;
 import java.net.UnknownHostException;
-import java.nio.channels.ServerSocketChannel;
 import java.util.Random;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ThreadPoolExecutor;
@@ -170,23 +167,6 @@ public class TServerUtils {
     return new ServerAddress(new CustomNonBlockingServer(options), address);
   }
 
-  public static ServerAddress createThreadPoolServer(HostAndPort address, TProcessor processor,
String serverName, String threadName, int numThreads)
-      throws TTransportException {
-
-    // if port is zero, then we must bind to get the port number
-    ServerSocket sock;
-    try {
-      sock = ServerSocketChannel.open().socket();
-      sock.setReuseAddress(true);
-      sock.bind(new InetSocketAddress(address.getHostText(), address.getPort()));
-      address = HostAndPort.fromParts(address.getHostText(), sock.getLocalPort());
-    } catch (IOException ex) {
-      throw new TTransportException(ex);
-    }
-    TServerTransport transport = new TBufferedServerSocket(sock, 32 * 1024);
-    return new ServerAddress(createThreadPoolServer(transport, processor), address);
-  }
-
   public static TServer createThreadPoolServer(TServerTransport transport, TProcessor processor)
{
     TThreadPoolServer.Args options = new TThreadPoolServer.Args(transport);
     options.protocolFactory(ThriftUtil.protocolFactory());


Mime
View raw message