diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-22 14:55:11 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-05-22 14:55:11 +0200 |
commit | 757fdedcb0256929bab8fc1c45a3f3c47cee0750 (patch) | |
tree | bfd239421833b5924b5677de10ad9df94320b69c /same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java | |
parent | 2a751ab6932c96cbe5960fe3607955a8a1fc44c3 (diff) |
Add Experiment 2: Master recovery time.
Diffstat (limited to 'same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java')
-rw-r--r-- | same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java | 16 |
1 files changed, 0 insertions, 16 deletions
diff --git a/same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java b/same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java index 99991c5..c6a5fec 100644 --- a/same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java +++ b/same/src/main/java/com/orbekk/paxos/PaxosServiceImpl.java @@ -38,8 +38,6 @@ public class PaxosServiceImpl { @Override public void propose(RpcController controller, PaxosRequest request, RpcCallback<PaxosResponse> done) { - logger.info("propose({}). Highest promise: {}, Highest accepted: {}", - new Object[]{request, highestPromise, highestAcceptedValue}); String clientUrl = request.getClient().getLocation(); int proposalNumber = request.getProposalNumber(); int response = @@ -53,8 +51,6 @@ public class PaxosServiceImpl { @Override public void acceptRequest(RpcController controller, PaxosRequest request, RpcCallback<PaxosResponse> done) { - logger.info("acceptRequest({}). Highest promise: {}, Highest accepted: {}", - new Object[]{request, highestPromise, highestAcceptedValue}); String clientUrl = request.getClient().getLocation(); int proposalNumber = request.getProposalNumber(); int response = @@ -78,15 +74,9 @@ public class PaxosServiceImpl { private synchronized int propose(String clientUrl, int proposalNumber) { if (proposalNumber > highestPromise) { - logger.info(tag + "propose({}, {}) = accepted", - new Object[]{clientUrl, proposalNumber}); highestPromise = proposalNumber; return highestPromise; } else { - logger.info(tag + "propose({}, {}) = rejected " + - "(promised: {})", - new Object[]{clientUrl, proposalNumber, - highestPromise}); return -highestPromise; } } @@ -94,15 +84,9 @@ public class PaxosServiceImpl { private synchronized int acceptRequest(String clientUrl, int proposalNumber) { if (proposalNumber == highestPromise) { - logger.info(tag + "acceptRequest({}, {}) = accepted", - new Object[]{clientUrl, proposalNumber}); highestAcceptedValue = proposalNumber; return highestAcceptedValue; } else { - logger.info(tag + "acceptRequest({}, {}) = rejected " + - "(promise={})", - new Object[]{clientUrl, proposalNumber, - highestPromise}); return -highestPromise; } } |