diff src/main/java/christie/test/topology/paxos/learner/RecieveAcceptProposalCodeGear.java @ 192:149d7fb0cfa6

refactor learner
author akahori
date Tue, 12 Feb 2019 16:11:16 +0900
parents 1bffd8151c6a
children
line wrap: on
line diff
--- a/src/main/java/christie/test/topology/paxos/learner/RecieveAcceptProposalCodeGear.java	Tue Feb 12 16:10:57 2019 +0900
+++ b/src/main/java/christie/test/topology/paxos/learner/RecieveAcceptProposalCodeGear.java	Tue Feb 12 16:11:16 2019 +0900
@@ -13,17 +13,24 @@
     @Take
     Proposal acceptedProposal;
 
-    @Take
+    //@Peek
     HashMap<String, Proposal> acceptedMap;
 
+    public RecieveAcceptProposalCodeGear(HashMap<String, Proposal> acceptedMap){
+        this.acceptedMap=acceptedMap;
+    }
+
 
     @Override
     protected void run(CodeGearManager cgm) {
         System.out.println("accepted : " + acceptedProposal);
         acceptedMap.put(acceptedProposal.getAcceptorName(),
                         acceptedProposal);
-        put("acceptedMap", acceptedMap);
-        if(acceptedMap.size() > acceptedProposal.getAcceptorNum()/2) cgm.setup(new AggregateProposalCodeGear());
-        else cgm.setup(new RecieveAcceptProposalCodeGear());
+        //put("acceptedMap", acceptedMap);
+
+        if(acceptedMap.size() > acceptedProposal.getAcceptorNum()/2)
+            cgm.setup(new AggregateProposalCodeGear(acceptedMap));
+        else
+            cgm.setup(new RecieveAcceptProposalCodeGear(acceptedMap));
     }
 }