Asynchronous paxos client using the protobuf interface.

3 files changed, 19 insertions, 0 deletions

diff --git a/same/src/main/java/com/orbekk/same/ConnectionManager.java b/same/src/main/java/com/orbekk/same/ConnectionManager.java
index f1ca65f..e4c7832 100644
--- a/same/src/main/java/com/orbekk/same/ConnectionManager.java
+++ b/same/src/main/java/com/orbekk/same/ConnectionManager.java
@@ -15,4 +15,5 @@ public interface ConnectionManager {
     Services.Master getMaster0(String location);
     Services.Client getClient0(String location);
     Services.Directory getDirectory(String location);
+    Services.Paxos getPaxos0(String location);
 }
diff --git a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
index 34536a0..1bf697f 100644
--- a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
+++ b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
@@ -145,4 +145,14 @@ public class ConnectionManagerImpl implements ConnectionManager {
             return null;
         }
     }
+    
+    @Override
+    public Services.Paxos getPaxos0(String location) {
+        RpcChannel channel = getChannel(location);
+        if (channel != null) {
+            return Services.Paxos.newStub(channel);
+        } else {
+            return null;
+        }
+    }
 }
diff --git a/same/src/main/java/com/orbekk/same/TestConnectionManager.java b/same/src/main/java/com/orbekk/same/TestConnectionManager.java
index 2305311..b93e49b 100644
--- a/same/src/main/java/com/orbekk/same/TestConnectionManager.java
+++ b/same/src/main/java/com/orbekk/same/TestConnectionManager.java
@@ -6,6 +6,7 @@ import java.util.HashMap;
 import com.orbekk.paxos.PaxosService;
 import com.orbekk.same.Services.Directory;
 import com.orbekk.same.Services.Master;
+import com.orbekk.same.Services.Paxos;
 
 /**
  * This class is used in test.
@@ -23,6 +24,8 @@ public class TestConnectionManager implements ConnectionManager {
             new HashMap<String, Services.Master>();
     public Map<String, Services.Client> clientMap0 =
             new HashMap<String, Services.Client>();
+    public Map<String, Services.Paxos> paxosMap0 =
+            new HashMap<String, Services.Paxos>();
 
     public TestConnectionManager() {
     }
@@ -56,4 +59,9 @@ public class TestConnectionManager implements ConnectionManager {
     public Services.Client getClient0(String location) {
         return clientMap0.get(location);
     }
+    
+    @Override
+    public Services.Paxos getPaxos0(String location) {
+        return paxosMap0.get(location);
+    }
 }