[JBPAPP-5946] Port JGRP-1205 to 2.6.16 one-off

belaban · Feb 15, 2011 · 950c384 · 950c384
1 parent 63541c7
commit 950c384
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/org/jgroups/stack/NakReceiverWindow.java b/src/org/jgroups/stack/NakReceiverWindow.java
@@ -59,6 +59,7 @@ public interface Listener {
 
     Address local_addr=null;
 
+    private volatile boolean running=true;
 
     /** Lowest seqno, modified on stable(). On stable(), we purge msgs [low digest.highest_delivered] */
     @GuardedBy("lock")
@@ -239,6 +240,9 @@ public boolean add(long seqno, Message msg) {
 
         lock.writeLock().lock();
         try {
+            if(!running)
+                return false;
+
             next_to_add=highest_received +1;
             old_next=next_to_add;
 
@@ -494,6 +498,7 @@ public void stable(long seqno) {
     public void reset() {
         lock.writeLock().lock();
         try {
+            running = false;
             retransmitter.reset();
             _reset();
         }