You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@turbine.apache.org by as...@apache.org on 2002/02/26 07:03:58 UTC
cvs commit: jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/javagroups/utils JGSocketOpener.java JGRpcOpener.java
asmuts 02/02/25 22:03:58
Modified: src/java/org/apache/stratum/jcs/auxiliary/lateral/javagroups/utils
JGSocketOpener.java JGRpcOpener.java
Log:
added merge for concurrent startup of bootstrappers
Revision Changes Path
1.2 +2 -2 jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/javagroups/utils/JGSocketOpener.java
Index: JGSocketOpener.java
===================================================================
RCS file: /home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/javagroups/utils/JGSocketOpener.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- JGSocketOpener.java 24 Feb 2002 06:15:42 -0000 1.1
+++ JGSocketOpener.java 26 Feb 2002 06:03:58 -0000 1.2
@@ -71,7 +71,7 @@
*
* @author <a href="mailto:asmuts@yahoo.com">Aaron Smuts</a>
* @created January 15, 2002
- * @version $Id: JGSocketOpener.java,v 1.1 2002/02/24 06:15:42 asmuts Exp $
+ * @version $Id: JGSocketOpener.java,v 1.2 2002/02/26 06:03:58 asmuts Exp $
*/
public class JGSocketOpener implements Runnable
{
@@ -123,7 +123,7 @@
try
{
// make configurable
- String props="UDP(mcast_addr=" + lca.getUdpMulticastAddr() + ";mcast_port=" + lca.getUdpMulticastPort()+ "):PING:FD:STABLE:NAKACK:UNICAST:" +
+ String props="UDP(mcast_addr=" + lca.getUdpMulticastAddr() + ";mcast_port=" + lca.getUdpMulticastPort()+ "):PING:MERGE2(min_interval=5000;max_interval=10000):FD:STABLE:NAKACK:UNICAST:" +
"FRAG:FLUSH:GMS:VIEW_ENFORCER:STATE_TRANSFER:QUEUE";
javagroups = new JChannel(props);
1.2 +2 -2 jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/javagroups/utils/JGRpcOpener.java
Index: JGRpcOpener.java
===================================================================
RCS file: /home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/javagroups/utils/JGRpcOpener.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- JGRpcOpener.java 24 Feb 2002 06:15:42 -0000 1.1
+++ JGRpcOpener.java 26 Feb 2002 06:03:58 -0000 1.2
@@ -74,7 +74,7 @@
*
* @author <a href="mailto:asmuts@yahoo.com">Aaron Smuts</a>
* @created January 15, 2002
- * @version $Id: JGRpcOpener.java,v 1.1 2002/02/24 06:15:42 asmuts Exp $
+ * @version $Id: JGRpcOpener.java,v 1.2 2002/02/26 06:03:58 asmuts Exp $
*/
public class JGRpcOpener implements Runnable
{
@@ -132,7 +132,7 @@
try
{
- String props="UDP(mcast_addr=" + ilca.getUdpMulticastAddr() + ";mcast_port=" + ilca.getUdpMulticastPort()+ "):PING:FD:STABLE:NAKACK:UNICAST:FLUSH:GMS:VIEW_ENFORCER:QUEUE";
+ String props="UDP(mcast_addr=" + ilca.getUdpMulticastAddr() + ";mcast_port=" + ilca.getUdpMulticastPort()+ "):PING:MERGE2(min_interval=5000;max_interval=10000):FD:STABLE:NAKACK:UNICAST:FLUSH:GMS:VIEW_ENFORCER:QUEUE";
rpcCh = new JChannel(props);
rpcCh.setOpt(rpcCh.LOCAL, Boolean.FALSE);
disp = new RpcDispatcher( rpcCh, null, null, ilcl );
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>