diff src/topology/manager/IncomingHosts.java @ 23:54bf607118ae

change method to create RemoteDSM
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Tue, 17 Jan 2012 01:10:29 +0900
parents 2ca2d961a8d2
children ebd91e607b63
line wrap: on
line diff
--- a/src/topology/manager/IncomingHosts.java	Tue Jan 17 00:40:27 2012 +0900
+++ b/src/topology/manager/IncomingHosts.java	Tue Jan 17 01:10:29 2012 +0900
@@ -6,9 +6,12 @@
 
 import org.apache.log4j.Logger;
 import org.msgpack.MessagePack;
+import org.msgpack.type.ValueFactory;
 
 import alice.codesegment.CodeSegment;
 import alice.datasegment.CommandType;
+import alice.datasegment.DataSegment;
+import alice.datasegment.DataSegmentManager;
 import alice.datasegment.DataSegmentReceiver;
 import alice.topology.HostMessage;
 
@@ -30,9 +33,8 @@
 		try {
 			HostMessage host = msgpack.convert(this.host.val, HostMessage.class);
 			String nodeName = nodeNames.poll();
-			
-			// TODO: send nodeName to node
-			
+			DataSegmentManager manager = DataSegment.connect(nodeName, host.name, host.port);
+			manager.put("host", ValueFactory.createRawValue(nodeName));
 		} catch (IOException e) {
 			logger.error("HostMessage format error");
 			e.printStackTrace();