Mercurial > hg > Database > Christie

changeset 175:ca455fdefdcb

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add finish
author akahori
date Fri, 25 Jan 2019 19:24:29 +0900
parents 9b0c4774f355
children 6eb548c188e5
files src/main/java/christie/test/topology/paxos/learner/AggregateProposalCodeGear.java
diffstat 1 files changed, 7 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/christie/test/topology/paxos/learner/AggregateProposalCodeGear.java	Fri Jan 25 19:23:59 2019 +0900
+++ b/src/main/java/christie/test/topology/paxos/learner/AggregateProposalCodeGear.java	Fri Jan 25 19:24:29 2019 +0900
@@ -5,11 +5,15 @@
 import christie.codegear.CodeGear;
 import christie.codegear.CodeGearManager;
 import christie.test.topology.paxos.Proposal;
+import christie.topology.node.TopologyNodeConfig;
 
 import java.util.HashMap;
 
 public class AggregateProposalCodeGear extends CodeGear {
 
+    @Peek
+    TopologyNodeConfig topologyNodeConfig;
+
     @Take
     HashMap<String, Proposal> acceptedMap;
 
@@ -22,8 +26,9 @@
                 int count = proposalValueMap.get(value).intValue();
                 count++;
                 if(count > proposal.getAcceptorNum()/2) {
-                    System.out.println(proposal);
-                    break;
+                    System.out.println("finish " + proposal);
+                    //break;
+                    getDGM(topologyNodeConfig.getManagerKey()).put("finish", "");
                 }
                 proposalValueMap.replace(value, count);
             }else{