summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/ClientServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'same/src/main/java/com/orbekk/same/ClientServiceImpl.java')
-rw-r--r--same/src/main/java/com/orbekk/same/ClientServiceImpl.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/same/src/main/java/com/orbekk/same/ClientServiceImpl.java b/same/src/main/java/com/orbekk/same/ClientServiceImpl.java
index 6675c15..36918cf 100644
--- a/same/src/main/java/com/orbekk/same/ClientServiceImpl.java
+++ b/same/src/main/java/com/orbekk/same/ClientServiceImpl.java
@@ -21,7 +21,11 @@ public class ClientServiceImpl implements ClientService, UrlReceiver {
@Override
public void setState(String component, String data, long revision) {
- state.forceUpdate(component, data, revision);
+ boolean status = state.update(component, data, revision);
+ if (!status) {
+ logger.warn("Ignoring update: {}",
+ new State.Component(component, revision, data));
+ }
}
@Override
@@ -37,6 +41,7 @@ public class ClientServiceImpl implements ClientService, UrlReceiver {
public void joinNetwork(String masterUrl) {
if (myUrl != null) {
MasterService master = connections.getMaster(masterUrl);
+ state.clear();
master.joinNetworkRequest(myUrl);
} else {
logger.error("Tried to join network at {}, but my url is unknown. " +