Mercurial > hg > Members > tatsuki > Alice

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

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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
comparison
equal deleted inserted replaced
22:2ca2d961a8d2 23:54bf607118ae
4 import java.util.HashMap; 4 import java.util.HashMap;
5 import java.util.LinkedList; 5 import java.util.LinkedList;
6 6
7 import org.apache.log4j.Logger; 7 import org.apache.log4j.Logger;
8 import org.msgpack.MessagePack; 8 import org.msgpack.MessagePack;
9 import org.msgpack.type.ValueFactory;
9 10
10 import alice.codesegment.CodeSegment; 11 import alice.codesegment.CodeSegment;
11 import alice.datasegment.CommandType; 12 import alice.datasegment.CommandType;
13 import alice.datasegment.DataSegment;
14 import alice.datasegment.DataSegmentManager;
12 import alice.datasegment.DataSegmentReceiver; 15 import alice.datasegment.DataSegmentReceiver;
13 import alice.topology.HostMessage; 16 import alice.topology.HostMessage;
14 17
15 public class IncomingHosts extends CodeSegment { 18 public class IncomingHosts extends CodeSegment {
16 19
28 public void run() { 31 public void run() {
29 MessagePack msgpack = new MessagePack(); 32 MessagePack msgpack = new MessagePack();
30 try { 33 try {
31 HostMessage host = msgpack.convert(this.host.val, HostMessage.class); 34 HostMessage host = msgpack.convert(this.host.val, HostMessage.class);
32 String nodeName = nodeNames.poll(); 35 String nodeName = nodeNames.poll();
33 36 DataSegmentManager manager = DataSegment.connect(nodeName, host.name, host.port);
34 // TODO: send nodeName to node 37 manager.put("host", ValueFactory.createRawValue(nodeName));
35
36 } catch (IOException e) { 38 } catch (IOException e) {
37 logger.error("HostMessage format error"); 39 logger.error("HostMessage format error");
38 e.printStackTrace(); 40 e.printStackTrace();
39 } 41 }
40 42