summaryrefslogtreecommitdiff
path: root/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-01-11 14:27:48 +0100
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-01-11 14:27:48 +0100
commit14205be283ad5b54a94c07308ab3e336f3069653 (patch)
treef3db2914c71385b8e0532ef9bbcf508cd1f98a21 /jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java
parentdf3a22794ea14ce702dbf17b2a57d6bcf0a8c9a8 (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.java6
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);
}
}