[MMBASE CVS] applications/clustering/src/org/mmbase/clustering/multicast ChangesReceiver.java Multicast.java

[Michiel Meeuwissen]

Update of /var/cvs/applications/clustering/src/org/mmbase/clustering/multicast
In directory james.mmbase.org:/tmp/cvs-serv21137/multicast

Modified Files:
      Tag: MMBase-1_8
        ChangesReceiver.java Multicast.java 
Log Message:
  MMB-1691


See also: 
http://cvs.mmbase.org/viewcvs/applications/clustering/src/org/mmbase/clustering/multicast
See also: http://www.mmbase.org/jira/browse/MMB-1691


Index: ChangesReceiver.java
===================================================================
RCS file: 
/var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/ChangesReceiver.java,v
retrieving revision 1.13
retrieving revision 1.13.2.1
diff -u -b -r1.13 -r1.13.2.1
--- ChangesReceiver.java        6 Jul 2006 11:27:27 -0000       1.13
+++ ChangesReceiver.java        22 Jul 2008 15:04:08 -0000      1.13.2.1
@@ -24,7 +24,7 @@
  * @author Daniel Ockeloen
  * @author Rico Jansen
  * @author Nico Klasens
- * @version $Id: ChangesReceiver.java,v 1.13 2006/07/06 11:27:27 michiel Exp $
+ * @version $Id: ChangesReceiver.java,v 1.13.2.1 2008/07/22 15:04:08 michiel 
Exp $
  */
 public class ChangesReceiver implements Runnable {
 
@@ -87,7 +87,6 @@
             // nothing
         }
         if (kicker != null) {
-            kicker.setPriority(Thread.MIN_PRIORITY);
             kicker.interrupt();
             kicker = null;
         } else {


Index: Multicast.java
===================================================================
RCS file: 
/var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/Multicast.java,v
retrieving revision 1.10
retrieving revision 1.10.2.1
diff -u -b -r1.10 -r1.10.2.1
--- Multicast.java      6 Jul 2006 11:40:48 -0000       1.10
+++ Multicast.java      22 Jul 2008 15:04:08 -0000      1.10.2.1
@@ -26,7 +26,7 @@
  * @author Daniel Ockeloen
  * @author Rico Jansen
  * @author Nico Klasens
- * @version $Id: Multicast.java,v 1.10 2006/07/06 11:40:48 michiel Exp $
+ * @version $Id: Multicast.java,v 1.10.2.1 2008/07/22 15:04:08 michiel Exp $
  */
 public class Multicast extends ClusterManager {
 
@@ -119,6 +119,9 @@
     }
 
     protected synchronized void startCommunicationThreads() {
+        if (multicastPort == -1) {
+            log.service("Not starting multicast threads because port number 
configured to be -1");
+        } else {
         try {
             mcs = new ChangesSender(multicastHost, multicastPort, 
multicastTTL, nodesToSend, send);
         } catch (java.net.UnknownHostException e) {
@@ -130,6 +133,7 @@
             log.error(e);
         }
     }
+    }
 
     protected synchronized void stopCommunicationThreads() {
         if (mcs != null) {
_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs