Mercurial > hg > Database > Alice
view src/alice/topology/node/IncomingConnectionInfo.java @ 25:50c75cb3de60
implements TopologyNode
author | kazz <kazz@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Tue, 17 Jan 2012 02:40:27 +0900 |
parents | |
children | 9c6b9e032338 |
line wrap: on
line source
package alice.topology.node; import java.io.IOException; import org.msgpack.MessagePack; import alice.codesegment.CodeSegment; import alice.datasegment.CommandType; import alice.datasegment.DataSegment; import alice.datasegment.DataSegmentReceiver; import alice.topology.HostMessage; public class IncomingConnectionInfo extends CodeSegment { public DataSegmentReceiver hostInfo = new DataSegmentReceiver(ids, CommandType.TAKE); public String absName; public IncomingConnectionInfo(String absName) { this.absName = absName; } @Override public void run() { MessagePack msgpack = new MessagePack(); try { HostMessage hostInfo = msgpack.convert(this.hostInfo.val, HostMessage.class); DataSegment.connect(hostInfo.connectionName, hostInfo.name, hostInfo.port); } catch (IOException e) { e.printStackTrace(); } } }