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();