diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-01-11 15:33:19 +0100 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-01-11 15:33:19 +0100 |
commit | ee0b57e81fce368e931a0d7282d8d84a9ecffd71 (patch) | |
tree | 549062eb4601e703c0333199da200fe5abf90eb2 /jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java | |
parent | 47e43eefebae63afee1a1743602c15e3b1ede8ff (diff) |
Add participant synchronization.
- No error handling in the protocol at the moment.
Diffstat (limited to 'jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java')
-rw-r--r-- | jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java | 31 |
1 files changed, 20 insertions, 11 deletions
diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java index 0e17f54..a946c61 100644 --- a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java +++ b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java @@ -35,17 +35,26 @@ public class SameServiceImpl implements SameService { } @Override - public void notifyParticipation(String networkName, String masterId, - Map<String, String> participants) { + public void notifyParticipation(String networkName, String masterId) { logger.info("Joining network {}. Master is {}", networkName, masterId); - int i = 1; - for (Map.Entry<String, String> e : participants.entrySet()) { - String clientId = e.getKey(); - String url = e.getValue(); - logger.info(" {} participant {}: {}, {}", - new Object[]{networkName, i, clientId, url}); - i++; - } - sameState.joinNetwork(networkName, masterId, participants); + // int i = 1; + // for (Map.Entry<String, String> e : participants.entrySet()) { + // String clientId = e.getKey(); + // String url = e.getValue(); + // logger.info(" {} participant {}: {}, {}", + // new Object[]{networkName, i, clientId, url}); + // i++; + // } + sameState.joinNetwork(networkName, masterId); + } + + @Override + public void setParticipants(Map<String, String> participants) { + sameState.setParticipants(participants); + } + + @Override + public void setState(String newState) { + logger.error("setState not implemented."); } } |