From 768938fa1e2bfaa5a246e28badefc7d8fe7cadd3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Wed, 25 Apr 2012 12:10:57 +0200
Subject: Add debug messages in Paxos service.
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

– Remove old PaxosService.
---
 same/src/main/java/com/orbekk/paxos/MasterProposer.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

(limited to 'same/src/main/java/com/orbekk/paxos/MasterProposer.java')

diff --git a/same/src/main/java/com/orbekk/paxos/MasterProposer.java b/same/src/main/java/com/orbekk/paxos/MasterProposer.java
index e2723a3..eaca410 100644
--- a/same/src/main/java/com/orbekk/paxos/MasterProposer.java
+++ b/same/src/main/java/com/orbekk/paxos/MasterProposer.java
@@ -81,6 +81,8 @@ public class MasterProposer extends Thread {
         
         public int getResult() throws InterruptedException {
             done.await();
+            logger.info("ResponseHandler: {} / {} successes.",
+                    numPromises.get(), numRequests);
             return result.get();
         }
     }
@@ -117,6 +119,8 @@ public class MasterProposer extends Thread {
                     .setProposalNumber(proposalNumber)
                     .build();
             paxos.acceptRequest(rpc, request, handler);
+            rpc.await();
+            logger.info("Rpc result from paxos.acceptRequest: " + rpc.errorText());
         }
         return handler.getResult();
     }
@@ -139,6 +143,7 @@ public class MasterProposer extends Thread {
     
     Integer proposeRetry(int proposalNumber, Runnable retryAction)
             throws InterruptedException {
+        logger.info("Paxos services: {}.", paxosLocations);
         assert proposalNumber > 0;
         int nextProposal = proposalNumber;
         int result = nextProposal - 1;
@@ -148,7 +153,8 @@ public class MasterProposer extends Thread {
             if (result == nextProposal) {
                 result = internalAcceptRequest(nextProposal);
             }
-            logger.info("Proposed value {}, result {}", nextProposal, result);
+            logger.info("Proposed value {}, result {}.",
+                    nextProposal, result);
             if (result < 0) {
                 nextProposal = -result + 1;
                 if (retryAction != null) {
-- 
cgit v1.2.3