Mercurial > hg > Database > Christie
changeset 174:9b0c4774f355
fix accepted proposal
author | akahori |
---|---|
date | Fri, 25 Jan 2019 19:23:59 +0900 |
parents | 6ea1f8958d1a |
children | ca455fdefdcb |
files | src/main/java/christie/test/topology/paxos/acceptor/AcceptCodeGear.java |
diffstat | 1 files changed, 3 insertions(+), 1 deletions(-) [+] |
line wrap: on
line diff
--- a/src/main/java/christie/test/topology/paxos/acceptor/AcceptCodeGear.java Fri Jan 25 17:14:51 2019 +0900 +++ b/src/main/java/christie/test/topology/paxos/acceptor/AcceptCodeGear.java Fri Jan 25 19:23:59 2019 +0900 @@ -29,6 +29,7 @@ protected void run(CodeGearManager cgm) { List<String> _CLIST = topoDG.getConnectionList(); + if(acceptProposal.getNumber() >= promisedProposal.getNumber()) { acceptProposal.setAccepted(true); acceptProposal.setAcceptorName(topoDG.getNodeName()); @@ -40,10 +41,11 @@ put(connectionNodeName, "acceptedProposal", acceptProposal); } } - put(acceptProposal.getProposerName(), acceptProposal); + put(acceptProposal.getProposerName(), "acceptedProposal", acceptProposal); put("promisedProposal", acceptProposal); }else{ + put(acceptProposal.getProposerName(), "acceptedProposal", promisedProposal); put("promisedProposal", promisedProposal); }