diff options
Diffstat (limited to 'same/src/main/java')
-rw-r--r-- | same/src/main/java/com/orbekk/same/Client.java (renamed from same/src/main/java/com/orbekk/same/ClientServiceImpl.java) | 4 | ||||
-rw-r--r-- | same/src/main/java/com/orbekk/same/Master.java (renamed from same/src/main/java/com/orbekk/same/MasterServiceImpl.java) | 8 | ||||
-rw-r--r-- | same/src/main/java/com/orbekk/same/Same.java | 6 | ||||
-rw-r--r-- | same/src/main/java/com/orbekk/same/SameController.java | 16 |
4 files changed, 17 insertions, 17 deletions
diff --git a/same/src/main/java/com/orbekk/same/ClientServiceImpl.java b/same/src/main/java/com/orbekk/same/Client.java index c503919..ce3947c 100644 --- a/same/src/main/java/com/orbekk/same/ClientServiceImpl.java +++ b/same/src/main/java/com/orbekk/same/Client.java @@ -11,7 +11,7 @@ import org.slf4j.LoggerFactory; import com.orbekk.util.WorkQueue; -public class ClientServiceImpl implements DiscoveryListener { +public class Client implements DiscoveryListener { private Logger logger = LoggerFactory.getLogger(getClass()); private ConnectionManager connections; private State state; @@ -57,7 +57,7 @@ public class ClientServiceImpl implements DiscoveryListener { } }; - public ClientServiceImpl(State state, ConnectionManager connections, + public Client(State state, ConnectionManager connections, String myUrl) { this.state = state; this.connections = connections; diff --git a/same/src/main/java/com/orbekk/same/MasterServiceImpl.java b/same/src/main/java/com/orbekk/same/Master.java index 7e25fc1..eaf0a8f 100644 --- a/same/src/main/java/com/orbekk/same/MasterServiceImpl.java +++ b/same/src/main/java/com/orbekk/same/Master.java @@ -8,7 +8,7 @@ import org.slf4j.LoggerFactory; import com.orbekk.same.State.Component; -public class MasterServiceImpl implements MasterService, Runnable { +public class Master implements MasterService, Runnable { private Logger logger = LoggerFactory.getLogger(getClass()); private final ConnectionManager connections; private State state; @@ -17,16 +17,16 @@ public class MasterServiceImpl implements MasterService, Runnable { private List<String> _fullStateReceivers = new ArrayList<String>(); private Thread workerThread = null; - public static MasterServiceImpl create(ConnectionManager connections, + public static Master create(ConnectionManager connections, Broadcaster broadcaster, String myUrl) { State state = new State("DefaultMaster"); state.update(".masterUrl", myUrl, 1); - return new MasterServiceImpl(state, connections, broadcaster); + return new Master(state, connections, broadcaster); } /** Constructor for internal use. */ - MasterServiceImpl(State initialState, ConnectionManager connections, + Master(State initialState, ConnectionManager connections, Broadcaster broadcaster) { this.state = initialState; this.connections = connections; diff --git a/same/src/main/java/com/orbekk/same/Same.java b/same/src/main/java/com/orbekk/same/Same.java index 69e1a0f..b152be4 100644 --- a/same/src/main/java/com/orbekk/same/Same.java +++ b/same/src/main/java/com/orbekk/same/Same.java @@ -10,7 +10,7 @@ import org.slf4j.LoggerFactory; @Deprecated public class Same implements SameInterface { private Logger logger = LoggerFactory.getLogger(getClass()); - private ClientServiceImpl client; + private Client client; private StateChangedProxy stateChangedProxy = new StateChangedProxy(); private class StateChangedProxy implements StateChangedListener { @@ -25,13 +25,13 @@ public class Same implements SameInterface { } } - public static Same createSame(ClientServiceImpl client) { + public static Same createSame(Client client) { Same same = new Same(client); client.setStateChangedListener(same.stateChangedProxy); return same; } - Same(ClientServiceImpl client) { + Same(Client client) { this.client = client; } diff --git a/same/src/main/java/com/orbekk/same/SameController.java b/same/src/main/java/com/orbekk/same/SameController.java index 44e1721..abf97c1 100644 --- a/same/src/main/java/com/orbekk/same/SameController.java +++ b/same/src/main/java/com/orbekk/same/SameController.java @@ -15,8 +15,8 @@ public class SameController { private Logger logger = LoggerFactory.getLogger(getClass()); private int port; private ServerContainer server; - private MasterServiceImpl master; - private ClientServiceImpl client; + private Master master; + private Client client; private PaxosServiceImpl paxos; /** @@ -37,10 +37,10 @@ public class SameController { String masterUrl = baseUrl + "MasterService.json"; String clientUrl = baseUrl + "ClientService.json"; - MasterServiceImpl master = MasterServiceImpl.create( + Master master = Master.create( connections, broadcaster, masterUrl); - ClientServiceImpl client = new ClientServiceImpl(state, connections, + Client client = new Client(state, connections, clientUrl); PaxosServiceImpl paxos = new PaxosServiceImpl(""); @@ -59,8 +59,8 @@ public class SameController { public SameController( int port, ServerContainer server, - MasterServiceImpl master, - ClientServiceImpl client, + Master master, + Client client, PaxosServiceImpl paxos) { this.port = port; this.server = server; @@ -103,11 +103,11 @@ public class SameController { client.joinNetwork(url); } - public ClientServiceImpl getClient() { + public Client getClient() { return client; } - public MasterServiceImpl getMaster() { + public Master getMaster() { return master; } } |