diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-04-24 16:27:33 +0200 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-04-24 16:28:54 +0200 |
commit | b9469eb43b5647605ad7b9662f584c2efbef5153 (patch) | |
tree | 5a14e1213b8aa8956c639f4687c8d662aaad9773 /same/src/main/java/com/orbekk/same/SameController.java | |
parent | b78972404f4b0a5dbccb6849021c2ca2d5e8bb46 (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.java | 23 |
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(); |