Database/Christie: src/main/java/christie/test/topology/paxos/acceptor/PromiseProposal.java comparison

add PromiseProposal and refactor acceptor

comparison

equal deleted inserted replaced

-:9b0a7f8dde81
+:2d0d41b648fa
+package christie.test.topology.paxos.acceptor;
+import christie.test.topology.paxos.Proposal;
+// singleton
+public class PromiseProposal {
+Proposal promiseProposal = null;
+private static PromiseProposal instance = new PromiseProposal();
+private Object _lock = new Object();
+private boolean sync = false;
+public void setPromiseProposal(Proposal promiseProposal){
+this.promiseProposal = promiseProposal;
+}
+public Proposal getPromiseProposal() {
+return promiseProposal;
+}
+public synchronized static PromiseProposal getInstance(){
+return instance;
+}
+public void lock(){
+synchronized (_lock){
+while(sync){
+try {
+_lock.wait();
+} catch (InterruptedException e) {
+}
+}
+}
+sync = true;
+}
+public void unLock(){
+synchronized (_lock){
+_lock.notify();
+sync = false;
+}
+}
+}

Mercurial > hg > Database > Christie