Update of /var/cvs/applications/clustering/src/org/mmbase/clustering/multicast
In directory
james.mmbase.org:/tmp/cvs-serv2657/applications/clustering/src/org/mmbase/clustering/multicast
Modified Files:
ChangesReceiver.java ChangesSender.java Multicast.java
Log Message:
mmbase unicast host configurable
Added javadoc
See also:
http://cvs.mmbase.org/viewcvs/applications/clustering/src/org/mmbase/clustering/multicast
Index: ChangesReceiver.java
===================================================================
RCS file:
/var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/ChangesReceiver.java,v
retrieving revision 1.15
retrieving revision 1.16
diff -u -b -r1.15 -r1.16
--- ChangesReceiver.java 21 Jun 2007 15:50:23 -0000 1.15
+++ ChangesReceiver.java 9 May 2008 11:33:54 -0000 1.16
@@ -23,7 +23,7 @@
* @author Daniel Ockeloen
* @author Rico Jansen
* @author Nico Klasens
- * @version $Id: ChangesReceiver.java,v 1.15 2007/06/21 15:50:23 nklasens Exp $
+ * @version $Id: ChangesReceiver.java,v 1.16 2008/05/09 11:33:54 nklasens Exp $
*/
public class ChangesReceiver implements Runnable {
@@ -53,6 +53,7 @@
* @param mport port of the multicast
* @param dpsize datapacket receive size
* @param nodesToSpawn Queue of received messages
+ * @throws UnknownHostException when multicastHost is not found
*/
ChangesReceiver(String multicastHost, int mport, int dpsize,
BlockingQueue<byte[]> nodesToSpawn) throws UnknownHostException {
this.mport = mport;
Index: ChangesSender.java
===================================================================
RCS file:
/var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/ChangesSender.java,v
retrieving revision 1.15
retrieving revision 1.16
diff -u -b -r1.15 -r1.16
--- ChangesSender.java 12 Dec 2007 16:17:20 -0000 1.15
+++ ChangesSender.java 9 May 2008 11:33:54 -0000 1.16
@@ -26,7 +26,7 @@
* @author Daniel Ockeloen
* @author Rico Jansen
* @author Nico Klasens
- * @version $Id: ChangesSender.java,v 1.15 2007/12/12 16:17:20 michiel Exp $
+ * @version $Id: ChangesSender.java,v 1.16 2008/05/09 11:33:54 nklasens Exp $
*/
public class ChangesSender implements Runnable {
@@ -58,6 +58,7 @@
* @param mTTL time-to-live of the multicast packet (0-255)
* @param nodesToSend Queue of messages to send
* @param send Statistics object in which to administer duration costs
+ * @throws UnknownHostException when multicastHost is not found
*/
ChangesSender(String multicastHost, int mport, int mTTL,
BlockingQueue<byte[]> nodesToSend, Statistics send) throws UnknownHostException
{
this.mport = mport;
Index: Multicast.java
===================================================================
RCS file:
/var/cvs/applications/clustering/src/org/mmbase/clustering/multicast/Multicast.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -u -b -r1.12 -r1.13
--- Multicast.java 21 Jun 2007 15:50:23 -0000 1.12
+++ Multicast.java 9 May 2008 11:33:54 -0000 1.13
@@ -25,7 +25,7 @@
* @author Daniel Ockeloen
* @author Rico Jansen
* @author Nico Klasens
- * @version $Id: Multicast.java,v 1.12 2007/06/21 15:50:23 nklasens Exp $
+ * @version $Id: Multicast.java,v 1.13 2008/05/09 11:33:54 nklasens Exp $
*/
public class Multicast extends ClusterManager {
@@ -78,6 +78,8 @@
}
/**
+ * Read configuration settings
+ * @param configuration read from config resource
* @since MMBase-1.8.1
*/
protected synchronized void readConfiguration(Map<String,String>
configuration) {
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
