summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/Master.java
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main/java/com/orbekk/same/Master.java')
-rw-r--r--same/src/main/java/com/orbekk/same/Master.java26
1 files changed, 6 insertions, 20 deletions
diff --git a/same/src/main/java/com/orbekk/same/Master.java b/same/src/main/java/com/orbekk/same/Master.java
index 4327a7a..473fd1e 100644
--- a/same/src/main/java/com/orbekk/same/Master.java
+++ b/same/src/main/java/com/orbekk/same/Master.java
@@ -17,7 +17,6 @@ package com.orbekk.same;
import java.util.ArrayList;
import java.util.List;
-import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import org.slf4j.Logger;
@@ -28,15 +27,14 @@ import com.google.protobuf.RpcController;
import com.orbekk.protobuf.Rpc;
import com.orbekk.same.Services.ClientState;
import com.orbekk.same.Services.Empty;
-import com.orbekk.same.Services.UpdateComponentResponse;
import com.orbekk.same.State.Component;
import com.orbekk.util.WorkQueue;
public class Master {
private Logger logger = LoggerFactory.getLogger(getClass());
private final ConnectionManager connections;
- private String myUrl;
private String myLocation; // Protobuf server location, i.e., myIp:port
+ private String networkName;
private AtomicLong revision = new AtomicLong(1);
State state;
private volatile int masterId = 1;
@@ -65,36 +63,29 @@ public class Master {
public static Master create(ConnectionManager connections,
String myUrl, String networkName,
String myLocation, RpcFactory rpcf) {
- State state = new State(networkName);
- state.update(".masterUrl", myUrl, 1);
- state.update(".masterLocation", myLocation, 1);
- return new Master(state, connections, myUrl, myLocation, rpcf);
+ State state = new State();
+ return new Master(state, connections, networkName, myLocation, rpcf);
}
Master(State initialState, ConnectionManager connections,
- String myUrl, String myLocation, RpcFactory rpcf) {
+ String networkName, String myLocation, RpcFactory rpcf) {
this.state = initialState;
this.connections = connections;
- this.myUrl = myUrl;
this.myLocation = myLocation;
+ this.networkName = networkName;
this.rpcf = rpcf;
}
public String getNetworkName() {
- return state.getDataOf(".networkName");
+ return networkName;
}
public String getLocation() {
return myLocation;
}
- public String getUrl() {
- return myUrl;
- }
-
public Services.MasterState getMasterInfo() {
return Services.MasterState.newBuilder()
- .setMasterUrl(getUrl())
.setMasterLocation(getLocation())
.setNetworkName(getNetworkName())
.setMasterId(masterId)
@@ -247,9 +238,6 @@ public class Master {
/** This master should take over from an earlier master. */
public void resumeFrom(State lastKnownState, final int masterId) {
state = lastKnownState;
- state.update(".masterUrl", myUrl, state.getRevision(".masterUrl") + 100);
- state.update(".masterLocation", myLocation,
- state.getRevision(".masterLocation") + 100);
this.masterId = masterId;
for (final String location : state.getList(State.PARTICIPANTS)) {
@@ -268,7 +256,5 @@ public class Master {
}
client.masterTakeover(rpc, getMasterInfo(), done);
}
- updateStateRequestThread.add(".masterUrl");
- updateStateRequestThread.add(".masterLocation");
}
}