Mercurial > hg > Database > Alice
diff src/main/java/alice/topology/node/ConfigurationFinish.java @ 621:4027e55df60d dispose current-release
add startKeepAlive
author | suruga |
---|---|
date | Sun, 06 Aug 2017 18:42:43 +0900 |
parents | 145c425db88d |
children | e321c5ec9b58 |
line wrap: on
line diff
--- a/src/main/java/alice/topology/node/ConfigurationFinish.java Thu Aug 03 20:02:55 2017 +0900 +++ b/src/main/java/alice/topology/node/ConfigurationFinish.java Sun Aug 06 18:42:43 2017 +0900 @@ -1,5 +1,6 @@ package alice.topology.node; +import alice.topology.manager.TopologyManagerConfig; import org.msgpack.type.ValueFactory; import alice.codesegment.CodeSegment; @@ -11,6 +12,7 @@ public Receiver reverseCount = ids.create(CommandType.PEEK); public Receiver configNodeNum = ids.create(CommandType.PEEK); + public Receiver config = ids.create(CommandType.PEEK); private CodeSegment startCS; public ConfigurationFinish(CodeSegment startCS) { @@ -21,12 +23,14 @@ public void run() { int rcount = reverseCount.asInteger(); int ncount = configNodeNum.asInteger(); + TopologyManagerConfig tconfig = config.asClass(TopologyManagerConfig.class); if (rcount == ncount) { ods.put("manager", "done", ValueFactory.createNilValue()); Start cs = new Start(startCS); cs.done.setKey("manager", "start"); - new StartKeepAlive().execute(); + if (tconfig.useKeepAlive) + new StartKeepAlive().execute(); new ReceiveCloseMessage(CommandType.PEEK); ClosedEventManager.getInstance().register(DeleteConnection.class); ClosedEventManager.getInstance().setKey();