summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/SameController.java
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-04-24 16:27:33 +0200
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-04-24 16:28:54 +0200
commitb9469eb43b5647605ad7b9662f584c2efbef5153 (patch)
tree5a14e1213b8aa8956c639f4687c8d662aaad9773 /same/src/main/java/com/orbekk/same/SameController.java
parentb78972404f4b0a5dbccb6849021c2ca2d5e8bb46 (diff)
Remove unused code.
– Remove old HTTP code. – Remove Jetty, Jsonrpc and servlet dependencies. – Remove state viewer servlet. – Remove unmaintained tests (rely on functional tests instead).
Diffstat (limited to 'same/src/main/java/com/orbekk/same/SameController.java')
-rw-r--r--same/src/main/java/com/orbekk/same/SameController.java23
1 files changed, 1 insertions, 22 deletions
diff --git a/same/src/main/java/com/orbekk/same/SameController.java b/same/src/main/java/com/orbekk/same/SameController.java
index a16f57a..e28db59 100644
--- a/same/src/main/java/com/orbekk/same/SameController.java
+++ b/same/src/main/java/com/orbekk/same/SameController.java
@@ -9,15 +9,10 @@ import com.orbekk.paxos.PaxosServiceImpl;
import com.orbekk.protobuf.Rpc;
import com.orbekk.protobuf.SimpleProtobufServer;
import com.orbekk.same.config.Configuration;
-import com.orbekk.same.http.JettyServerBuilder;
-import com.orbekk.same.http.ServerContainer;
-import com.orbekk.same.http.StateServlet;
public class SameController {
private Logger logger = LoggerFactory.getLogger(getClass());
- private ServerContainer server;
private SimpleProtobufServer pServer;
- private MasterServiceProxy masterService;
private Master master;
private Client client;
private PaxosServiceImpl paxos;
@@ -65,24 +60,15 @@ public class SameController {
configuration.get("localIp"), configuration.getInt("port"));
String clientUrl = baseUrl + "ClientService.json";
- MasterServiceProxy master = new MasterServiceProxy();
Client client = new Client(clientState, connections,
clientUrl, myLocation);
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();
SimpleProtobufServer pServer = SimpleProtobufServer.create(pport);
pServer.registerService(client.getNewService());
SameController controller = new SameController(
- configuration, connections, server, master, client,
+ configuration, connections, client,
paxos, broadcaster, pServer);
return controller;
}
@@ -90,16 +76,12 @@ public class SameController {
public SameController(
Configuration configuration,
ConnectionManager connections,
- ServerContainer server,
- MasterServiceProxy master,
Client client,
PaxosServiceImpl paxos,
Broadcaster serviceBroadcaster,
SimpleProtobufServer pServer) {
this.configuration = configuration;
this.connections = connections;
- this.server = server;
- this.masterService = master;
this.client = client;
this.paxos = paxos;
this.serviceBroadcaster = serviceBroadcaster;
@@ -107,7 +89,6 @@ public class SameController {
}
public void start() throws Exception {
- server.start();
pServer.start();
client.setMasterController(masterController);
client.start();
@@ -119,7 +100,6 @@ public class SameController {
if (master != null) {
master.interrupt();
}
- server.stop();
pServer.interrupt();
} catch (Exception e) {
logger.error("Failed to stop webserver", e);
@@ -127,7 +107,6 @@ public class SameController {
}
public void join() {
- server.join();
client.interrupt();
if (master != null) {
master.interrupt();