summaryrefslogtreecommitdiff
path: root/same
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-03-27 10:42:34 +0200
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-03-27 10:42:34 +0200
commite6a2fe124bd1c3c2dc70c4182e4ec4094df95677 (patch)
tree8d13090063b52189a2b3a252adbc4d182c33a151 /same
parenta40161ac665ce982518d8ceea6f6bc6fede10651 (diff)
Change same-android to work with new Same version.
Diffstat (limited to 'same')
-rw-r--r--same/src/main/java/com/orbekk/same/Master.java4
-rw-r--r--same/src/main/java/com/orbekk/same/SameController.java9
2 files changed, 4 insertions, 9 deletions
diff --git a/same/src/main/java/com/orbekk/same/Master.java b/same/src/main/java/com/orbekk/same/Master.java
index ade0b1e..529d729 100644
--- a/same/src/main/java/com/orbekk/same/Master.java
+++ b/same/src/main/java/com/orbekk/same/Master.java
@@ -30,6 +30,10 @@ public class Master {
this.myUrl = myUrl;
}
+ public String getUrl() {
+ return myUrl;
+ }
+
private MasterService serviceImpl = new MasterService() {
@Override
public boolean updateStateRequest(String component,
diff --git a/same/src/main/java/com/orbekk/same/SameController.java b/same/src/main/java/com/orbekk/same/SameController.java
index 95b8c29..8c17807 100644
--- a/same/src/main/java/com/orbekk/same/SameController.java
+++ b/same/src/main/java/com/orbekk/same/SameController.java
@@ -58,31 +58,22 @@ public class SameController {
timeout, timeout);
State clientState = new State(".InvalidClientNetwork");
Broadcaster broadcaster = BroadcasterImpl.getDefaultBroadcastRunner();
-
String baseUrl = String.format("http://%s:%s/",
configuration.get("localIp"), configuration.getInt("port"));
-
- String masterUrl = baseUrl + "MasterService.json";
String clientUrl = baseUrl + "ClientService.json";
MasterServiceProxy master = new MasterServiceProxy();
-// Master master = Master.create(connections, broadcaster,
-// masterUrl, configuration.get("networkName"));
-
Client client = new Client(clientState, connections,
clientUrl, BroadcasterImpl.getDefaultBroadcastRunner());
PaxosServiceImpl paxos = new PaxosServiceImpl("");
-
StateServlet stateServlet = new StateServlet(client.getInterface(),
new VariableFactory(client.getInterface()));
-
ServerContainer server = new JettyServerBuilder(port)
.withServlet(stateServlet, "/_/state")
.withService(client.getService(), ClientService.class)
.withService(master, MasterService.class)
.withService(paxos, PaxosService.class)
.build();
-
SameController controller = new SameController(
configuration, connections, server, master, client,
paxos, broadcaster);