Mercurial > hg > Database > Alice
view src/main/java/alice/test/chat/ConnectRoot.java @ 601:30f2c04571c2 dispose
add chat, add Star topology to topology manager&node
author | Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 27 Apr 2016 16:28:10 +0900 |
parents | |
children |
line wrap: on
line source
package alice.test.chat; import alice.codesegment.CodeSegment; import alice.datasegment.CommandType; import alice.datasegment.DataSegment; import alice.datasegment.Receiver; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.ArrayList; /** * Created by e125769 on 3/29/16. */ public class ConnectRoot extends CodeSegment{ private Receiver info = ids.create(CommandType.PEEK); public ConnectRoot() { info.setKey("_CLIST"); info.setKey("host"); } @Override public void run() { ArrayList<String> clist = info.asClass(ArrayList.class); if (clist.contains("parent")){ } else { InetAddress addr; try { addr = InetAddress.getLocalHost(); ods.put("root", addr.getHostAddress()); DataSegment.connect("root", "root", addr.getHostAddress(), 20000); } catch (UnknownHostException e) { e.printStackTrace(); } } } }