summaryrefslogtreecommitdiff
path: root/same/src
diff options
context:
space:
mode:
Diffstat (limited to 'same/src')
-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.java6
-rw-r--r--same/src/main/java/com/orbekk/same/SameController.java16
-rw-r--r--same/src/test/java/com/orbekk/same/ClientServiceImplTest.java2
-rw-r--r--same/src/test/java/com/orbekk/same/MasterServiceImplTest.java12
6 files changed, 24 insertions, 24 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;
}
}
diff --git a/same/src/test/java/com/orbekk/same/ClientServiceImplTest.java b/same/src/test/java/com/orbekk/same/ClientServiceImplTest.java
index 2c5604a..4dfc54a 100644
--- a/same/src/test/java/com/orbekk/same/ClientServiceImplTest.java
+++ b/same/src/test/java/com/orbekk/same/ClientServiceImplTest.java
@@ -8,7 +8,7 @@ import static org.mockito.Mockito.*;
public class ClientServiceImplTest {
private State state = new State("ClientNetwork");
private TestConnectionManager connections = new TestConnectionManager();
- private ClientServiceImpl client = new ClientServiceImpl(state, connections,
+ private Client client = new Client(state, connections,
"http://client/ClientService.json");
private ClientService clientS = client.getService();
diff --git a/same/src/test/java/com/orbekk/same/MasterServiceImplTest.java b/same/src/test/java/com/orbekk/same/MasterServiceImplTest.java
index cc89054..0e7c81d 100644
--- a/same/src/test/java/com/orbekk/same/MasterServiceImplTest.java
+++ b/same/src/test/java/com/orbekk/same/MasterServiceImplTest.java
@@ -12,7 +12,7 @@ public class MasterServiceImplTest {
private State state = new State("TestNetwork");
private TestConnectionManager connections = new TestConnectionManager();
private TestBroadcaster broadcaster = new TestBroadcaster();
- private MasterServiceImpl master;
+ private Master master;
public static class UnreachableClient implements ClientService {
@Override
@@ -36,7 +36,7 @@ public class MasterServiceImplTest {
@Before
public void setUp() {
state.update(".masterUrl", "http://master/MasterService.json", 1);
- master = new MasterServiceImpl(state, connections, broadcaster);
+ master = new Master(state, connections, broadcaster);
connections.masterMap.put("http://master/MasterService.json", master);
}
@@ -66,7 +66,7 @@ public class MasterServiceImplTest {
@Test
public void clientJoin() {
- ClientServiceImpl client = new ClientServiceImpl(
+ Client client = new Client(
new State("ClientNetwork"), connections,
"http://client/ClientService.json");
ClientService clientS = client.getService();
@@ -79,12 +79,12 @@ public class MasterServiceImplTest {
@Test
public void validStateRequest() {
- ClientServiceImpl client1 = new ClientServiceImpl(
+ Client client1 = new Client(
new State("ClientNetwork"), connections,
"http://client/ClientService.json");
ClientService client1S = client1.getService();
connections.clientMap.put("http://client/ClientService.json", client1S);
- ClientServiceImpl client2 = new ClientServiceImpl(
+ Client client2 = new Client(
new State("ClientNetwork"), connections,
"http://client2/ClientService.json");
ClientService client2S = client2.getService();
@@ -114,7 +114,7 @@ public class MasterServiceImplTest {
@Test
public void masterRemovesParticipant() {
- ClientServiceImpl client = new ClientServiceImpl(
+ Client client = new Client(
new State("ClientNetwork"), connections,
"http://client/ClientService.json");
ClientService clientS = client.getService();