diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-02-27 16:08:54 +0100 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-02-27 16:08:54 +0100 |
commit | c58c649531e4884a92f07d9b12f0ad77fbcf5d6a (patch) | |
tree | 38d2997ec6cdaed9120dba012b61afbb8b2e53ea /same/src/main/java/com/orbekk/same/DiscoveryService.java | |
parent | ee51a98e9b61336610d667de57a8cff70d0ac1d9 (diff) |
Clean up source code.
Clean up source code with Eclipse. In particular remove tabs.
Diffstat (limited to 'same/src/main/java/com/orbekk/same/DiscoveryService.java')
-rw-r--r-- | same/src/main/java/com/orbekk/same/DiscoveryService.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/same/src/main/java/com/orbekk/same/DiscoveryService.java b/same/src/main/java/com/orbekk/same/DiscoveryService.java index d9af9bb..1987c69 100644 --- a/same/src/main/java/com/orbekk/same/DiscoveryService.java +++ b/same/src/main/java/com/orbekk/same/DiscoveryService.java @@ -11,13 +11,14 @@ public class DiscoveryService extends Thread { private Logger logger = LoggerFactory.getLogger(getClass()); BroadcastListener broadcastListener; DiscoveryListener listener; - + public DiscoveryService(DiscoveryListener listener, BroadcastListener broadcastListener) { this.listener = listener; this.broadcastListener = broadcastListener; } - + + @Override public void run() { logger.info("DiscoveryService starting."); while (!Thread.interrupted()) { @@ -28,12 +29,12 @@ public class DiscoveryService extends Thread { } String content = new String(packet.getData(), 0, packet.getLength()); String[] words = content.split(" "); - + if (!content.startsWith("Discover") || words.length < 2) { logger.warn("Invalid discovery message: {}", content); continue; } - + String url = words[1]; logger.info("Received discovery from {}", url); if (listener != null) { @@ -42,7 +43,7 @@ public class DiscoveryService extends Thread { } logger.info("DiscoveryService stopped."); } - + @Override public void interrupt() { logger.info("Interrupt()"); super.interrupt(); |