From 980f590ef8db3c17567c343d279102a0caa022dd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Thu, 26 Jan 2012 18:18:44 +0100 Subject: Server/Client discovery service. --- .../src/main/java/com/orbekk/discovery/SameService.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) (limited to 'same-android/src/main/java/com/orbekk/discovery/SameService.java') diff --git a/same-android/src/main/java/com/orbekk/discovery/SameService.java b/same-android/src/main/java/com/orbekk/discovery/SameService.java index 149b882..154239f 100644 --- a/same-android/src/main/java/com/orbekk/discovery/SameService.java +++ b/same-android/src/main/java/com/orbekk/discovery/SameService.java @@ -12,7 +12,10 @@ import android.widget.Toast; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.orbekk.same.MasterApp; + public class SameService extends Service { + final static int PORT = 15066; private Logger logger = LoggerFactory.getLogger(getClass()); private Thread discoveryThread = null; @@ -26,7 +29,7 @@ public class SameService extends Service { @Override public void run() { while (!Thread.interrupted()) { byte[] data = new byte[1024]; - DatagramPacket packet = broadcast.receiveBroadcast(15066); + DatagramPacket packet = broadcast.receiveBroadcast(PORT); String content = new String(packet.getData(), 0, packet.getLength()); Message message = Message.obtain(); message.obj = content; @@ -49,6 +52,11 @@ public class SameService extends Service { } }; + private void sendBroadcastDiscovery() { + byte[] data = "Discover".getBytes(); + new Broadcast(this).sendBroadcast(data, PORT); + } + @Override public IBinder onBind(Intent intent) { return null; @@ -64,6 +72,9 @@ public class SameService extends Service { discoveryThread.start(); } } + if (intent.getAction().equals("join")) { + sendBroadcastDiscovery(); + } return START_STICKY; } -- cgit v1.2.3