added names to the threads, in order to allow jvisualvm debug

removed a "My DEBUG" message on the console

1 files changed, 6 insertions, 2 deletions

diff --git a/src/IvyWatcher.java b/src/IvyWatcher.java
index 54eca11..cbd3910 100755
--- a/src/IvyWatcher.java
+++ b/src/IvyWatcher.java
@@ -98,6 +98,7 @@ class IvyWatcher extends Thread {
   private int port;
   private volatile Thread listenThread = null;
   private InetAddress group;
+  // FIXME should not be static ? (findbugs)
   private static int serial=0;
   private int myserial=serial++;
   private String busWatcherId = null;
@@ -114,6 +115,7 @@ class IvyWatcher extends Thread {
     this.port=port;
     busWatcherId=bus.getWatcherId();
     listenThread = new Thread(this);
+    listenThread.setName("Ivy Watcher thread for "+domainaddr+":"+port);
     // create the MulticastSocket
     try {
       group = InetAddress.getByName(domainaddr);
@@ -199,7 +201,7 @@ class IvyWatcher extends Thread {
 	      try {
 		Socket s = new Socket(remotehost,remotePort);
 		s.setReceiveBufferSize(bus.getBufferSize());
-		System.out.println("MY DEBUG - buffer size="+s.getReceiveBufferSize());
+		//System.out.println("MY DEBUG - buffer size="+s.getReceiveBufferSize());
 		s.setTcpNoDelay(true);
 	        bus.createIvyClient(s,remotePort,false);
 	      } catch ( java.net.ConnectException jnc ) {
@@ -261,7 +263,9 @@ class IvyWatcher extends Thread {
       this.data=data;
       bus = b;
       packet=new DatagramPacket(data.getBytes(),data.length(),group,port);
-      new Thread((PacketSender.this)).start();
+      Thread t = new Thread((PacketSender.this));
+      t.setName("Ivy Packet sender");
+      t.start();
     }
     public void run() {
       traceDebug("PacketSender thread started"); // THREADDEBUG