diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-01-11 14:27:48 +0100 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-01-11 14:27:48 +0100 |
commit | 14205be283ad5b54a94c07308ab3e336f3069653 (patch) | |
tree | f3db2914c71385b8e0532ef9bbcf508cd1f98a21 /jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java | |
parent | df3a22794ea14ce702dbf17b2a57d6bcf0a8c9a8 (diff) |
Implement master functionality.
- The first participant in the network is considered the master.
- Forward join requests to the master.
Diffstat (limited to 'jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java')
-rw-r--r-- | jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java index 7e61a2d..0e17f54 100644 --- a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java +++ b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java @@ -35,9 +35,9 @@ public class SameServiceImpl implements SameService { } @Override - public void notifyParticipation(String networkName, + public void notifyParticipation(String networkName, String masterId, Map<String, String> participants) { - logger.info("Joining network {}.", networkName); + logger.info("Joining network {}. Master is {}", networkName, masterId); int i = 1; for (Map.Entry<String, String> e : participants.entrySet()) { String clientId = e.getKey(); @@ -46,6 +46,6 @@ public class SameServiceImpl implements SameService { new Object[]{networkName, i, clientId, url}); i++; } - logger.warn("Joining not implemented."); + sameState.joinNetwork(networkName, masterId, participants); } } |