[jboss-cvs] jrunit/src/main/org/jboss/jrunit/communication ...

[Ron Sigal]

  User: rsigal  
  Date: 08/03/07 02:41:15

  Modified:    src/main/org/jboss/jrunit/communication  MessageBus.java
  Log:
  JBREM-876: Made some more jgroups parameters configurable.
  
  Revision  Changes    Path
  1.19      +22 -5     jrunit/src/main/org/jboss/jrunit/communication/MessageBus.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MessageBus.java
  ===================================================================
  RCS file: /cvsroot/jboss/jrunit/src/main/org/jboss/jrunit/communication/MessageBus.java,v
  retrieving revision 1.18
  retrieving revision 1.19
  diff -u -b -r1.18 -r1.19
  --- MessageBus.java	15 Dec 2007 07:08:05 -0000	1.18
  +++ MessageBus.java	7 Mar 2008 07:41:15 -0000	1.19
  @@ -37,13 +37,29 @@
         System.out.println("jrunit using bind_address: " + bind_address);
         
         String mcast_address = System.getProperty("jrunit.mcast_addr", "228.15.2.3");
  -      System.out.println("jrunit using mcast_address: " + mcast_address);
  +      System.out.println("jrunit using mcast_addr: " + mcast_address);
  +      
  +      String mcast_port = System.getProperty("jrunit.mcast_port", "45565");
  +      System.out.println("jrunit using mcast_port: " + mcast_port);
  +      
  +      String receiveOnAllInterfaces = System.getProperty("jrunit.receive_on_all_interfaces", "false");
  +      System.out.println("jrunit using receive_on_all_interfaces=" + receiveOnAllInterfaces);
  +
  +      String sendOnAllInterfaces = System.getProperty("jrunit.send_on_all_interfaces", "false");
  +      System.out.println("jrunit using send_on_all_interfaces=" + sendOnAllInterfaces);
  +      
  +      String sendInterfaces = System.getProperty("jrunit.send_interfaces", "none");
  +      if (!sendInterfaces.equals("none"))
  +         System.out.println("jrunit using send_interfaces=" + sendInterfaces);
         
         props =
  -         "UDP(mcast_addr="
  -               + mcast_address
  -               + ";mcast_port=45566;ip_ttl=64;ip_mcast=true;mcast_send_buf_size=150000;mcast_recv_buf_size=80000;ucast_send_buf_size=150000;ucast_recv_buf_size=80000;loopback=false;"
  -               + "bind_addr=" + bind_address + "):"+
  +         "UDP(mcast_addr=" + mcast_address
  +               + ";mcast_port=" + mcast_port 
  +               + ";bind_addr=" + bind_address
  +               + ";receive_on_all_interfaces=" + receiveOnAllInterfaces
  +               + ";send_on_all_interfaces=" + sendOnAllInterfaces
  +               + (!sendInterfaces.equals("none") ? ";send_interfaces=" + sendInterfaces : "")
  +               + ";ip_ttl=64;ip_mcast=true;mcast_send_buf_size=150000;mcast_recv_buf_size=80000;ucast_send_buf_size=150000;ucast_recv_buf_size=80000;loopback=false):" +
            "PING(timeout=2000;num_initial_members=3;up_thread=false;down_thread=false):"+
            "MERGE2(min_interval=10000;max_interval=20000):"+
            "FD_SOCK():"+
  @@ -55,6 +71,7 @@
            "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=true;print_local_addr=true):"+
            "pbcast.STATE_TRANSFER(up_thread=true;down_thread=false)";
         
  +      System.out.println("props: " + props);
         bus = new NotificationBus(busName, props);
      }