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;