Modified BundlerStressTest

bin/bundler-stress_test.sh

@@ -0,0 +1,18 @@
+#!/bin/bash
+
+## Rund BundlerStressTest, writes results to $OUTPUT (removes it first, when started)
+
+## The bundler to be tested
+BUNDLERS="no-bundler transfer-queue per-destination"
+OUTPUT="bst.txt"
+THREADS="1 8 100"
+PROPS="$HOME/tcp.xml"
+PGM=BundlerStressTest
+
+rm -f $OUTPUT
+for i in $BUNDLERS;
+  do for j in $THREADS;
+    do jt $PGM -props $PROPS -bundler $i -num_sender_threads $j -interactive false -time 30 -warmup 10 >> $OUTPUT;
+    done;
+  done;
+

src/org/jgroups/protocols/pbcast/NAKACK2.java

@@ -236,9 +236,9 @@ public void setResendLastSeqno(boolean flag) {
     /** Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.redhat.com/browse/JGRP-1539) */
     protected final Map<Address,Long>   xmit_task_map=new ConcurrentHashMap<>();
 
-    protected volatile boolean          leaving=false;
-    protected volatile boolean          running=false;
-    protected TimeScheduler             timer=null;
+    protected volatile boolean          leaving;
+    protected volatile boolean          running;
+    protected TimeScheduler             timer;
     protected LastSeqnoResender         last_seqno_resender;
     protected final Lock                rebroadcast_lock=new ReentrantLock();
     protected final Condition           rebroadcast_done=rebroadcast_lock.newCondition();