Mercurial > hg > Members > tatsuki > Alice
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();