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

[Ron Sigal]

  User: rsigal  
  Date: 07/12/15 02:08:05

  Modified:    src/main/org/jboss/jrunit/communication  MessageBus.java
  Log:
  JBREM-876: TestDriver and ServerTestHarness get jrunit.bind_addr and jrunit.mcast_addr System parameters to configure jgroups.
  
  Revision  Changes    Path
  1.18      +23 -40    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.17
  retrieving revision 1.18
  diff -u -b -r1.17 -r1.18
  --- MessageBus.java	13 Dec 2005 13:12:39 -0000	1.17
  +++ MessageBus.java	15 Dec 2007 07:08:05 -0000	1.18
  @@ -27,51 +27,34 @@
      private RemoteMemberListener memberListener = null;
   
      private String busName = "BusDemo";
  -   private String props =
  -   "UDP(mcast_addr=228.15.2.3;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=127.0.0.1):"+
  +   private String props;
  +   private static Logger log = Logger.getLogger(MessageBus.class);
  +
  +
  +   public MessageBus() throws Exception
  +   {
  +      String bind_address = System.getProperty("jrunit.bind_addr", "127.0.0.1");
  +      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);
  +      
  +      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 + "):"+
      "PING(timeout=2000;num_initial_members=3;up_thread=false;down_thread=false):"+
      "MERGE2(min_interval=10000;max_interval=20000):"+
      "FD_SOCK():"+
      "VERIFY_SUSPECT(timeout=1500;up_thread=false;down_thread=false):" +
      "pbcast.NAKACK(gc_lag=50;retransmit_timeout=600,1200,2400,4800;max_xmit_size=8192;up_thread=false;down_thread=false):"+
  -   "UNICAST(timeout=600,1200,2400;window_size=100;min_threshold=10;down_thread=false):"+
  +         "UNICAST(timeout=600,1200,2400;down_thread=false):"+
      "pbcast.STABLE(desired_avg_gossip=20000;up_thread=false;down_thread=false):"+
      "FRAG(frag_size=8192;down_thread=false;up_thread=false):"+
      "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=true;print_local_addr=true):"+
  -//   "pbcast.STATE_TRANSFER(up_thread=true;down_thread=true)";
      "pbcast.STATE_TRANSFER(up_thread=true;down_thread=false)";
  -   /*private String props = "UDP(mcast_addr=228.1.2.3;mcast_port=45566;ip_ttl=32;" +
  -                          "mcast_send_buf_size=150000;mcast_recv_buf_size=80000):" +
  -                          "PING(timeout=2000;num_initial_members=3):" +
  -                          "MERGE2(min_interval=5000;max_interval=10000):" +
  -                          "FD_SOCK:" +
  -                          "VERIFY_SUSPECT(timeout=1500):" +
  -                          "pbcast.NAKACK(gc_lag=50;retransmit_timeout=600,1200,2400,4800):" +
  -                          "UNICAST(timeout=5000):" +
  -                          "pbcast.STABLE(desired_avg_gossip=20000):" +
  -                          "FRAG(frag_size=8096;down_thread=false;up_thread=false):" +
  -                // "CAUSAL:" +
  -                          "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;" +
  -                          "shun=false;print_local_addr=true)"; */
  -
  -    /*private static final String props = "UDP(mcast_addr=228.1.2.3;mcast_port=45566;ip_ttl=8;ip_mcast=true;mcast_send_buf_size=800000;mcast_recv_buf_size=150000;ucast_send_buf_size=800000;ucast_recv_buf_size=150000;loopback=false):" +
  -    "PING(timeout=2000;num_initial_members=3;up_thread=true;down_thread=true):" +
  -    "MERGE2(min_interval=10000;max_interval=20000):" +
  -    "FD(shun=true;up_thread=true;down_thread=true;timeout=2500;max_tries=5):" +
  -    "VERIFY_SUSPECT(timeout=3000;num_msgs=3;up_thread=true;down_thread=true):" +
  -    "pbcast.NAKACK(gc_lag=50;retransmit_timeout=300,600,1200,2400,4800;max_xmit_size=8192;up_thread=true;down_thread=true):"+
  -    "UNICAST(timeout=300,600,1200,2400,4800;window_size=100;min_threshold=10;down_thread=true):"+
  -    "pbcast.STABLE(desired_avg_gossip=20000;up_thread=true;down_thread=true):" +
  -    "FRAG(frag_size=8192;down_thread=true;up_thread=true):" +
  -    "pbcast.GMS(join_timeout=5000;join_retry_timeout=2000;shun=true;print_local_addr=true):" +
  -    "pbcast.STATE_TRANSFER(up_thread=true;down_thread=true)"; */
   
  -
  -   private static Logger log = Logger.getLogger(MessageBus.class);
  -
  -
  -   public MessageBus() throws Exception
  -   {
         bus = new NotificationBus(busName, props);
      }