summaryrefslogtreecommitdiff
path: root/same/src/test/java/com/orbekk
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-02-16 15:10:34 +0100
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-02-16 15:10:34 +0100
commit9444d8b16c93581bbab7928304cb14622050f691 (patch)
treeedb35293ed0880dfdb8a8b7639b76383f97c8fe7 /same/src/test/java/com/orbekk
parent9742d69c56ef0866ca8b22696746b756e0670c81 (diff)
Start new Master implementation.
Diffstat (limited to 'same/src/test/java/com/orbekk')
-rw-r--r--same/src/test/java/com/orbekk/same/NewMasterTest.java79
1 files changed, 79 insertions, 0 deletions
diff --git a/same/src/test/java/com/orbekk/same/NewMasterTest.java b/same/src/test/java/com/orbekk/same/NewMasterTest.java
new file mode 100644
index 0000000..098b141
--- /dev/null
+++ b/same/src/test/java/com/orbekk/same/NewMasterTest.java
@@ -0,0 +1,79 @@
+package com.orbekk.same;
+
+import static org.junit.Assert.*;
+
+import java.util.List;
+import org.codehaus.jackson.type.TypeReference;
+import org.junit.Before;
+import org.junit.Test;
+
+public class NewMasterTest {
+ private State state = new State("TestNetwork");
+ private TestConnectionManager connections = new TestConnectionManager();
+ private TestBroadcaster broadcaster = new TestBroadcaster();
+ private NewMaster master;
+ private MasterService masterS;
+
+ public static class UnreachableClient implements ClientService {
+ @Override
+ public void notifyNetwork(String networkName, String masterUrl)
+ throws Exception {
+ throw new Exception("Unreachable client");
+ }
+
+ @Override
+ public void setState(String component, String data, long revision)
+ throws Exception {
+ throw new Exception("Unreachable client");
+ }
+
+ @Override
+ public void discoveryRequest(String remoteUrl) throws Exception {
+ throw new Exception("Unreachable client");
+ }
+ }
+
+ @Before
+ public void setUp() {
+ state.update(".masterUrl", "http://master/MasterService.json", 1);
+ master = new NewMaster(state, connections, broadcaster);
+ masterS = master.getService();
+ connections.masterMap.put("http://master/MasterService.json",
+ masterS);
+ }
+
+ @Test
+ public void updateStateRequest() throws Exception {
+ Client client1 = new Client(
+ new State("ClientNetwork"), connections,
+ "http://client/ClientService.json");
+ ClientService client1S = client1.getService();
+ connections.clientMap.put("http://client/ClientService.json", client1S);
+ Client client2 = new Client(
+ new State("ClientNetwork"), connections,
+ "http://client2/ClientService.json");
+ ClientService client2S = client2.getService();
+ connections.clientMap.put("http://client2/ClientService.json", client2S);
+
+ client1.joinNetwork("http://master/MasterService.json");
+ client2.joinNetwork("http://master/MasterService.json");
+
+ master.performWork();
+ assertTrue(state.getList(".participants").contains("http://client/ClientService.json"));
+ assertTrue(state.getList(".participants").contains("http://client2/ClientService.json"));
+ assertEquals(state, client1.testGetState());
+
+ assertTrue(masterS.updateStateRequest("A", "1", 0));
+ master.performWork();
+
+ assertEquals(state, client1.testGetState());
+ assertEquals(state, client2.testGetState());
+
+ assertFalse(masterS.updateStateRequest("A", "2", 0));
+ assertTrue(masterS.updateStateRequest("A", "3", 1));
+ master.performWork();
+
+ assertEquals(state, client1.testGetState());
+ assertEquals(state, client2.testGetState());
+ }
+}