Mercurial > hg > Database > Alice
diff src/main/java/alice/datasegment/RemoteDataSegmentManager.java @ 557:1a860019b2fe dispose
add ip to HostMessage.class
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Fri, 20 Nov 2015 17:57:55 +0900 |
parents | 5a9b83c64ddf |
children |
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/RemoteDataSegmentManager.java Thu Nov 19 21:30:12 2015 +0900 +++ b/src/main/java/alice/datasegment/RemoteDataSegmentManager.java Fri Nov 20 17:57:55 2015 +0900 @@ -1,6 +1,7 @@ package alice.datasegment; import java.io.IOException; +import java.net.InetAddress; import java.net.InetSocketAddress; import java.nio.channels.SocketChannel; import java.util.concurrent.LinkedBlockingQueue; @@ -18,7 +19,7 @@ public RemoteDataSegmentManager(){} - public RemoteDataSegmentManager(final String connectionKey, final String reverseKey, final String hostName, final int port) { + public RemoteDataSegmentManager(final String connectionKey, final String reverseKey, final InetAddress ip, final int port) { logger = Logger.getLogger(connectionKey); connection = new Connection(); connection.name = connectionKey; @@ -30,7 +31,7 @@ do { try { //System.out.println("RemoteDSM connect hostname:" + hostName + " port:" + port); - SocketChannel sc = SocketChannel.open(new InetSocketAddress(hostName, port)); + SocketChannel sc = SocketChannel.open(new InetSocketAddress(ip, port)); connection.socket = sc.socket(); connection.socket.setTcpNoDelay(true); connect = false;