From: Bryan Duxbury <bryanduxbury@apache.org>
Date: Thu, 21 Jan 2010 03:20:01 +0000 (+0000)
Subject: THRIFT-684. java: Add constructor to TNonblockingServerSocket to accept InetSocketAddress
X-Git-Tag: 0.3.0~133
X-Git-Url: https://source.supwisdom.com/gerrit/gitweb?a=commitdiff_plain;h=c771944644247f5ae31c37ffe937fe93c147b327;p=common%2Fthrift.git

THRIFT-684. java: Add constructor to TNonblockingServerSocket to accept InetSocketAddress

git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@901513 13f79535-47bb-0310-9956-ffa450edef68
---

diff --git a/lib/java/src/org/apache/thrift/transport/TNonblockingServerSocket.java b/lib/java/src/org/apache/thrift/transport/TNonblockingServerSocket.java
index 571adbff..e26b9cfc 100644
--- a/lib/java/src/org/apache/thrift/transport/TNonblockingServerSocket.java
+++ b/lib/java/src/org/apache/thrift/transport/TNonblockingServerSocket.java
@@ -81,7 +81,15 @@ public class TNonblockingServerSocket extends TNonblockingServerTransport {
    * Creates just a port listening server socket
    */
   public TNonblockingServerSocket(int port, int clientTimeout) throws TTransportException {
+    this(new InetSocketAddress(port), clientTimeout);
     port_ = port;
+  }  
+
+  public TNonblockingServerSocket(InetSocketAddress bindAddr) throws TTransportException {
+    this(bindAddr, 0);
+  }
+
+  public TNonblockingServerSocket(InetSocketAddress bindAddr, int clientTimeout) throws TTransportException {
     clientTimeout_ = clientTimeout;
     try {
       serverSocketChannel = ServerSocketChannel.open();
@@ -92,10 +100,10 @@ public class TNonblockingServerSocket extends TNonblockingServerTransport {
       // Prevent 2MSL delay problem on server restarts
       serverSocket_.setReuseAddress(true);
       // Bind to listening port
-      serverSocket_.bind(new InetSocketAddress(port_));
+      serverSocket_.bind(bindAddr);
     } catch (IOException ioe) {
       serverSocket_ = null;
-      throw new TTransportException("Could not create ServerSocket on port " + port + ".");
+      throw new TTransportException("Could not create ServerSocket on address " + bindAddr.toString() + ".");
     }
   }