Skip to content
Browse files

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

  • Loading branch information...
1 parent 63541c7 commit 950c3846d8be37ca00aa0243663d00abe92b9f80 @dereed dereed committed Feb 15, 2011
Showing with 5 additions and 0 deletions.
  1. +5 −0 src/org/jgroups/stack/NakReceiverWindow.java
View
5 src/org/jgroups/stack/NakReceiverWindow.java
@@ -59,6 +59,7 @@
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();
}

0 comments on commit 950c384

Please sign in to comment.
Something went wrong with that request. Please try again.