From 808e9f8c51b32cd052254d25cb6f4c27d353de2b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Tue, 24 Apr 2012 12:18:31 +0200 Subject: Asynchronous paxos client using the protobuf interface. --- same/src/test/java/com/orbekk/paxos/MasterProposerTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'same/src/test/java/com/orbekk/paxos/MasterProposerTest.java') diff --git a/same/src/test/java/com/orbekk/paxos/MasterProposerTest.java b/same/src/test/java/com/orbekk/paxos/MasterProposerTest.java index bab2005..e753d6e 100644 --- a/same/src/test/java/com/orbekk/paxos/MasterProposerTest.java +++ b/same/src/test/java/com/orbekk/paxos/MasterProposerTest.java @@ -6,6 +6,7 @@ import java.util.List; import org.junit.Before; import org.junit.Test; +import com.orbekk.same.Services.ClientState; import com.orbekk.same.TestConnectionManager; import static org.junit.Assert.*; @@ -13,6 +14,9 @@ import static org.mockito.Mockito.*; public class MasterProposerTest { TestConnectionManager connections = new TestConnectionManager(); + ClientState client = ClientState.newBuilder() + .setLocation("client1Location") + .build(); PaxosService p1 = mock(PaxosService.class); PaxosService p2 = mock(PaxosService.class); PaxosService p3 = mock(PaxosService.class); @@ -34,7 +38,7 @@ public class MasterProposerTest { when(p1.acceptRequest("client1", 1)).thenReturn(1); MasterProposer c1 = new MasterProposer( - "client1", + client, paxosUrls(), connections); assertTrue(c1.propose(1)); @@ -46,7 +50,7 @@ public class MasterProposerTest { when(p1.acceptRequest("client1", 1)).thenReturn(-1); MasterProposer c1 = new MasterProposer( - "client1", + client, paxosUrls(), connections); assertFalse(c1.propose(1)); -- cgit v1.2.3