From 675d39342eeee15dda340557c88321edb431de98 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Mon, 23 Jan 2012 20:13:26 +0100
Subject: Add Paxos integration test.

---
 .../test/java/com/orbekk/paxos/PaxosServiceTest.java  | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

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

diff --git a/same/src/test/java/com/orbekk/paxos/PaxosServiceTest.java b/same/src/test/java/com/orbekk/paxos/PaxosServiceTest.java
index d09ff70..a6a1f0b 100644
--- a/same/src/test/java/com/orbekk/paxos/PaxosServiceTest.java
+++ b/same/src/test/java/com/orbekk/paxos/PaxosServiceTest.java
@@ -2,6 +2,8 @@ package com.orbekk.paxos;
 
 import static org.junit.Assert.*;
 
+import com.orbekk.same.TestConnectionManager;
+
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
@@ -9,6 +11,7 @@ import org.junit.Before;
 import org.junit.Test;
 
 public class PaxosServiceTest {
+    TestConnectionManager connections = new TestConnectionManager();
     private PaxosServiceImpl p1 = new PaxosServiceImpl("P1: "); 
     private PaxosServiceImpl p2 = new PaxosServiceImpl("P2: "); 
     private PaxosServiceImpl p3 = new PaxosServiceImpl("P3: "); 
@@ -25,6 +28,11 @@ public class PaxosServiceTest {
     @Before
     public void setUp() {
         Collections.addAll(servers, p1, p2, p3, p4, p5);    
+        connections.paxosMap.put("p1", p1);
+        connections.paxosMap.put("p2", p2);
+        connections.paxosMap.put("p3", p3);
+        connections.paxosMap.put("p4", p4);
+        connections.paxosMap.put("p5", p5);
     }
 
     @Test
@@ -59,4 +67,15 @@ public class PaxosServiceTest {
         assertFalse(p1.acceptRequest(client2, 4, 5));
         assertTrue(p1.propose(client1, 5, 1));
     }
+
+    public List<String> paxosUrls() {
+        return new ArrayList<String>(connections.paxosMap.keySet());
+    }
+
+    @Test
+    public void integrationTest() {
+        MasterProposer proposer = new MasterProposer("client1", paxosUrls(),
+                connections);
+        assertTrue(proposer.propose(1, 1));
+    }
 }
-- 
cgit v1.2.3