summaryrefslogtreecommitdiff
path: root/same/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main')
-rw-r--r--same/src/main/java/com/orbekk/same/Client.java11
-rw-r--r--same/src/main/java/com/orbekk/same/SameController.java3
-rw-r--r--same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java1
3 files changed, 2 insertions, 13 deletions
diff --git a/same/src/main/java/com/orbekk/same/Client.java b/same/src/main/java/com/orbekk/same/Client.java
index f9bd2a9..1b99ce4 100644
--- a/same/src/main/java/com/orbekk/same/Client.java
+++ b/same/src/main/java/com/orbekk/same/Client.java
@@ -1,7 +1,5 @@
package com.orbekk.same;
-import static com.orbekk.same.StackTraceUtil.throwableToString;
-
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CancellationException;
@@ -30,13 +28,11 @@ public class Client {
private volatile String myUrl;
private volatile String myLocation;
private volatile MasterController masterController = null;
- private final Broadcaster broadcaster;
private volatile Future<Integer> currentMasterProposal = null;
private volatile MasterState masterInfo;
private List<StateChangedListener> stateListeners =
new ArrayList<StateChangedListener>();
- private NetworkNotificationListener networkListener;
public class ClientInterfaceImpl implements ClientInterface {
private ClientInterfaceImpl() {
@@ -203,12 +199,11 @@ public class Client {
};
public Client(State state, ConnectionManager connections,
- String myUrl, String myLocation, Broadcaster broadcaster) {
+ String myUrl, String myLocation) {
this.state = state;
this.connections = connections;
this.myUrl = myUrl;
this.myLocation = myLocation;
- this.broadcaster = broadcaster;
}
public void start() {
@@ -280,10 +275,6 @@ public class Client {
return state;
}
- public void setNetworkListener(NetworkNotificationListener listener) {
- this.networkListener = listener;
- }
-
public ClientService getService() {
return serviceImpl;
}
diff --git a/same/src/main/java/com/orbekk/same/SameController.java b/same/src/main/java/com/orbekk/same/SameController.java
index 8aeebd6..c44d3bb 100644
--- a/same/src/main/java/com/orbekk/same/SameController.java
+++ b/same/src/main/java/com/orbekk/same/SameController.java
@@ -67,8 +67,7 @@ public class SameController {
MasterServiceProxy master = new MasterServiceProxy();
Client client = new Client(clientState, connections,
- clientUrl, myLocation,
- BroadcasterImpl.getDefaultBroadcastRunner());
+ clientUrl, myLocation);
PaxosServiceImpl paxos = new PaxosServiceImpl("");
StateServlet stateServlet = new StateServlet(client.getInterface(),
new VariableFactory(client.getInterface()));
diff --git a/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java b/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
index a2fc663..4e18416 100644
--- a/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
+++ b/same/src/main/java/com/orbekk/same/benchmark/ClientBenchmark.java
@@ -7,7 +7,6 @@ import java.util.concurrent.CountDownLatch;
import com.google.protobuf.RpcCallback;
import com.orbekk.protobuf.RpcChannel;
import com.orbekk.protobuf.Rpc;
-import com.orbekk.protobuf.RpcChannel;
import com.orbekk.same.benchmark.Example.Data;
public class ClientBenchmark {