summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/MasterServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main/java/com/orbekk/same/MasterServiceImpl.java')
-rw-r--r--same/src/main/java/com/orbekk/same/MasterServiceImpl.java13
1 files changed, 11 insertions, 2 deletions
diff --git a/same/src/main/java/com/orbekk/same/MasterServiceImpl.java b/same/src/main/java/com/orbekk/same/MasterServiceImpl.java
index 4a842ab..32a8781 100644
--- a/same/src/main/java/com/orbekk/same/MasterServiceImpl.java
+++ b/same/src/main/java/com/orbekk/same/MasterServiceImpl.java
@@ -17,9 +17,17 @@ public class MasterServiceImpl implements MasterService, Runnable {
private List<String> _fullStateReceivers = new ArrayList<String>();
private Thread workerThread = null;
- public MasterServiceImpl(State initialState, ConnectionManager connections,
+ public static MasterServiceImpl create(ConnectionManager connections,
+ Broadcaster broadcaster, String myUrl) {
+ State state = new State("DefaultMaster");
+ state.update(".masterUrl", myUrl, 1);
+ return new MasterServiceImpl(state, connections, broadcaster);
+ }
+
+ /** Constructor for internal use.
+ */
+ private MasterServiceImpl(State initialState, ConnectionManager connections,
Broadcaster broadcaster) {
- state = initialState;
this.connections = connections;
this.broadcaster = broadcaster;
}
@@ -140,6 +148,7 @@ public class MasterServiceImpl implements MasterService, Runnable {
if (workerThread == null) {
workerThread = new Thread(this);
workerThread.start();
+ logger.info("Master thread started. {}", state);
}
}