[MMBASE SCM] r42990 - in mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering: . multicast unicast

[michiel]

Author: michiel
Date: 2010-07-23 18:20:59 +0200 (Fri, 23 Jul 2010)
New Revision: 42990

Modified:
   
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/Converter.java
   
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/multicast/ChangesSender.java
   
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/unicast/Unicast.java
Log:
damn

Modified: 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/Converter.java
===================================================================
--- 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/Converter.java
     2010-07-23 15:17:11 UTC (rev 42989)
+++ 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/Converter.java
     2010-07-23 16:20:59 UTC (rev 42990)
@@ -70,7 +70,7 @@
         org.mmbase.clustering.multicast.ChangesSender multiCastSender
             = new org.mmbase.clustering.multicast.ChangesSender(multicastHost, 
multicastPort, multicastTimeToLive, uniToMultiNodes, stats);
         multiCastSender.start();
-        multiCastSender.getSocket().setLoopbackMode(true);
+        //multiCastSender.getSocket().setLoopbackMode(true);
 
         synchronized(Converter.class) {
 

Modified: 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/multicast/ChangesSender.java
===================================================================
--- 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/multicast/ChangesSender.java
       2010-07-23 15:17:11 UTC (rev 42989)
+++ 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/multicast/ChangesSender.java
       2010-07-23 16:20:59 UTC (rev 42990)
@@ -118,7 +118,7 @@
                 DatagramPacket dp = new DatagramPacket(data, data.length, ia, 
mport);
                 try {
                     if (log.isDebugEnabled()) {
-                        log.debug("SEND=> " + dp.getLength() + " bytes to " + 
dp.getAddress());
+                        log.debug("SEND=> " + dp.getLength() + " bytes to " + 
dp.getAddress() + ":" + mport);
                     }
                     ms.send(dp);
                 } catch (IOException e) {

Modified: 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/unicast/Unicast.java
===================================================================
--- 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/unicast/Unicast.java
       2010-07-23 15:17:11 UTC (rev 42989)
+++ 
mmbase/trunk/applications/clustering/src/main/java/org/mmbase/clustering/unicast/Unicast.java
       2010-07-23 16:20:59 UTC (rev 42990)
@@ -149,9 +149,9 @@
 
             try {
                 ucr = new ChangesReceiver(unicastHost, unicastPort, 
nodesToSpawn, version);
-                ucs.start();
+                ucr.start();
             } catch (java.io.IOException ioe) {
-                log.error(ioe);
+                log.error(ioe.getMessage(), ioe);
             }
         }
     }

_______________________________________________
Cvs mailing list
Cvs@lists.mmbase.org
http://lists.mmbase.org/mailman/listinfo/cvs