From c771944644247f5ae31c37ffe937fe93c147b327 Mon Sep 17 00:00:00 2001 From: Bryan Duxbury Date: Thu, 21 Jan 2010 03:20:01 +0000 Subject: [PATCH] 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 --- .../thrift/transport/TNonblockingServerSocket.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) 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() + "."); } } -- 2.17.1