Mercurial > hg > Database > Christie
changeset 84:c0c29f989af3
update comment add
author | akahori |
---|---|
date | Sat, 15 Sep 2018 09:25:55 +0900 |
parents | 2314c55534ef |
children | 331ad549e764 |
files | src/main/java/christie/topology/manager/CreateHash.java src/main/java/christie/topology/manager/RecordTopology.java src/main/java/christie/topology/node/ConfigurationFinish.java src/main/java/christie/topology/node/IncomingReverseKey.java |
diffstat | 4 files changed, 2 insertions(+), 8 deletions(-) [+] |
line wrap: on
line diff
--- a/src/main/java/christie/topology/manager/CreateHash.java Sat Sep 15 09:24:36 2018 +0900 +++ b/src/main/java/christie/topology/manager/CreateHash.java Sat Sep 15 09:25:55 2018 +0900 @@ -13,9 +13,7 @@ import java.util.LinkedList; public class CreateHash extends CodeGear{ - // this CodeSegment change raw string to MD5 - // Question: orderHashどこで使われているかわかんない. たぶんcheckcominghostでhostが来た時に使う? @Take String orderHash;
--- a/src/main/java/christie/topology/manager/RecordTopology.java Sat Sep 15 09:24:36 2018 +0900 +++ b/src/main/java/christie/topology/manager/RecordTopology.java Sat Sep 15 09:25:55 2018 +0900 @@ -8,7 +8,6 @@ import christie.topology.HostMessage; import java.util.HashMap; -import java.util.LinkedList; // Recordだけじゃなく, sendも担っているので名前変えたほうがいいかも
--- a/src/main/java/christie/topology/node/ConfigurationFinish.java Sat Sep 15 09:24:36 2018 +0900 +++ b/src/main/java/christie/topology/node/ConfigurationFinish.java Sat Sep 15 09:25:55 2018 +0900 @@ -20,12 +20,10 @@ TopologyNodeConfig topologyNodeConfig; public ConfigurationFinish() { - // System.err.println("config finish ...") ; } @Override protected void run(CodeGearManager cgm) { - // System.err.println(" rcount = " + Integer.toString(rcount) + " " + Integer.toString(ncount)); if (reverseCount == connectNodeNum) { getDGM(topologyNodeConfig.getManagerKey()).put("nodePrepareDone", "done"); cgm.setup(new Start());
--- a/src/main/java/christie/topology/node/IncomingReverseKey.java Sat Sep 15 09:24:36 2018 +0900 +++ b/src/main/java/christie/topology/node/IncomingReverseKey.java Sat Sep 15 09:25:55 2018 +0900 @@ -1,12 +1,12 @@ package christie.topology.node; -import christie.annotation.Peek; import christie.annotation.Take; import christie.codegear.CodeGear; import christie.codegear.CodeGearManager; -import christie.daemon.IncomingTcpConnection; + +// pingを受け取るみたいなクラス. 相手がreverseNodeNameを送ってきたらreverseCountをプラスする public class IncomingReverseKey extends CodeGear { @Take @@ -17,7 +17,6 @@ @Override protected void run(CodeGearManager cgm) { - reverseCount++; getLocalDGM().put( "reverseCount", reverseCount); cgm.setup(new IncomingReverseKey());