# HG changeset patch # User sugi # Date 1405680424 -32400 # Node ID 01c4240c2ff0873f39d1e6a60a810682004bdf4c # Parent aefbe41fcf1240141b8f40b08978cac397112dad forget add class diff -r aefbe41fcf12 -r 01c4240c2ff0 src/main/java/alice/daemon/ConnectionInfo.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/alice/daemon/ConnectionInfo.java Fri Jul 18 19:47:04 2014 +0900 @@ -0,0 +1,16 @@ +package alice.daemon; + +import org.msgpack.annotation.Message; + +@Message +public class ConnectionInfo { + public String addr; + public int port; + + public ConnectionInfo(){} + + public ConnectionInfo(String addr, int port) { + this.addr = addr; + this.port = port; + } +} diff -r aefbe41fcf12 -r 01c4240c2ff0 src/main/java/alice/topology/manager/CloseEventCodeSegment.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/alice/topology/manager/CloseEventCodeSegment.java Fri Jul 18 19:47:04 2014 +0900 @@ -0,0 +1,20 @@ +package alice.topology.manager; + +import alice.codesegment.CodeSegment; +import alice.daemon.ConnectionInfo; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public abstract class CloseEventCodeSegment extends CodeSegment { + + private Receiver metaInfo = ids.create(CommandType.PEEK); + + public CloseEventCodeSegment(){ + metaInfo.setKey("disconnect"); + } + + public ConnectionInfo getConnectionInfo() { + return metaInfo.asClass(ConnectionInfo.class); + } + +} diff -r aefbe41fcf12 -r 01c4240c2ff0 src/main/java/alice/topology/manager/keeparive/StartKeepAlive.java --- a/src/main/java/alice/topology/manager/keeparive/StartKeepAlive.java Tue Jul 15 16:00:22 2014 +0900 +++ b/src/main/java/alice/topology/manager/keeparive/StartKeepAlive.java Fri Jul 18 19:47:04 2014 +0900 @@ -7,7 +7,6 @@ @Override public void run() { new CreateTask(); - } }