diff options
Diffstat (limited to 'same/src/main/java/com/orbekk/same/ClientServiceImpl.java')
-rw-r--r-- | same/src/main/java/com/orbekk/same/ClientServiceImpl.java | 7 |
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. " + |