From 55beb6df753604996ae61f8a099db40f0906804e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Tue, 24 Jan 2012 11:48:19 +0100
Subject: Basic Paxos working.

---
 .../main/java/com/orbekk/paxos/MasterProposer.java | 24 ++++++++++++++++++++--
 1 file changed, 22 insertions(+), 2 deletions(-)

(limited to 'same/src/main/java')

diff --git a/same/src/main/java/com/orbekk/paxos/MasterProposer.java b/same/src/main/java/com/orbekk/paxos/MasterProposer.java
index 7bc4350..f216ff5 100644
--- a/same/src/main/java/com/orbekk/paxos/MasterProposer.java
+++ b/same/src/main/java/com/orbekk/paxos/MasterProposer.java
@@ -1,11 +1,13 @@
 package com.orbekk.paxos;
 
+import com.orbekk.same.ConnectionManager;
 import java.util.ArrayList;
 import java.util.List;
-
-import com.orbekk.same.ConnectionManager;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class MasterProposer {
+    private Logger logger = LoggerFactory.getLogger(getClass());
     private String myUrl;
     private List<String> paxosUrls = new ArrayList<String>();
     private ConnectionManager connections;
@@ -64,4 +66,22 @@ public class MasterProposer {
             return false;
         }
     }
+    
+    public boolean proposeRetry(int proposalNumber) {
+        int nextProposal = proposalNumber;
+        int result = 0;
+        
+        while (result != nextProposal) {
+            result = internalPropose(nextProposal);
+            if (result == nextProposal) {
+                result = internalAcceptRequest(nextProposal);
+            }
+            logger.info("Proposed value {}, result {}", nextProposal, result);
+            if (result < 0) {
+                nextProposal = -result + 1;
+            }
+        }
+        
+        return true;
+    }
 }
-- 
cgit v1.2.3