From 14205be283ad5b54a94c07308ab3e336f3069653 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Wed, 11 Jan 2012 14:27:48 +0100 Subject: Implement master functionality. - The first participant in the network is considered the master. - Forward join requests to the master. --- jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java') 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 participants) { - logger.info("Joining network {}.", networkName); + logger.info("Joining network {}. Master is {}", networkName, masterId); int i = 1; for (Map.Entry 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); } } -- cgit v1.2.3