diff options
Diffstat (limited to 'lib/java/src/main/java/org/apache/thrift/transport/TServerSocket.java')
-rw-r--r-- | lib/java/src/main/java/org/apache/thrift/transport/TServerSocket.java | 40 |
1 files changed, 13 insertions, 27 deletions
diff --git a/lib/java/src/main/java/org/apache/thrift/transport/TServerSocket.java b/lib/java/src/main/java/org/apache/thrift/transport/TServerSocket.java index eb302fd26..e1056623e 100644 --- a/lib/java/src/main/java/org/apache/thrift/transport/TServerSocket.java +++ b/lib/java/src/main/java/org/apache/thrift/transport/TServerSocket.java @@ -19,34 +19,27 @@ package org.apache.thrift.transport; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import java.io.IOException; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; -/** - * Wrapper around ServerSocket for Thrift. - * - */ +/** Wrapper around ServerSocket for Thrift. */ public class TServerSocket extends TServerTransport { private static final Logger LOGGER = LoggerFactory.getLogger(TServerSocket.class.getName()); - /** - * Underlying ServerSocket object - */ + /** Underlying ServerSocket object */ private ServerSocket serverSocket_ = null; - /** - * Timeout for client sockets from accept - */ + /** Timeout for client sockets from accept */ private int clientTimeout_ = 0; - public static class ServerSocketTransportArgs extends AbstractServerTransportArgs<ServerSocketTransportArgs> { + public static class ServerSocketTransportArgs + extends AbstractServerTransportArgs<ServerSocketTransportArgs> { ServerSocket serverSocket; public ServerSocketTransportArgs serverSocket(ServerSocket serverSocket) { @@ -55,30 +48,22 @@ public class TServerSocket extends TServerTransport { } } - /** - * Creates a server socket from underlying socket object - */ + /** Creates a server socket from underlying socket object */ public TServerSocket(ServerSocket serverSocket) throws TTransportException { this(serverSocket, 0); } - /** - * Creates a server socket from underlying socket object - */ + /** Creates a server socket from underlying socket object */ public TServerSocket(ServerSocket serverSocket, int clientTimeout) throws TTransportException { this(new ServerSocketTransportArgs().serverSocket(serverSocket).clientTimeout(clientTimeout)); } - /** - * Creates just a port listening server socket - */ + /** Creates just a port listening server socket */ public TServerSocket(int port) throws TTransportException { this(port, 0); } - /** - * Creates just a port listening server socket - */ + /** Creates just a port listening server socket */ public TServerSocket(int port, int clientTimeout) throws TTransportException { this(new InetSocketAddress(port), clientTimeout); } @@ -106,7 +91,8 @@ public class TServerSocket extends TServerTransport { serverSocket_.bind(args.bindAddr, args.backlog); } catch (IOException ioe) { close(); - throw new TTransportException("Could not create ServerSocket on address " + args.bindAddr.toString() + ".", ioe); + throw new TTransportException( + "Could not create ServerSocket on address " + args.bindAddr.toString() + ".", ioe); } } |