Permalink
Browse files

Become_server_queue was never flushed (JGRP-1522) - fixed now

  • Loading branch information...
1 parent 8442139 commit be2134c9edaaf365a8bca1812b5b3db8e643d818 Bela Ban committed Oct 5, 2012
Showing with 2 additions and 6 deletions.
  1. +1 −3 src/org/jgroups/protocols/pbcast/NAKACK.java
  2. +1 −3 src/org/jgroups/protocols/pbcast/NAKACK2.java
@@ -534,10 +534,8 @@ public Object down(Event evt) {
break;
case Event.BECOME_SERVER:
- boolean was_server=is_server;
is_server=true;
- if(!was_server)
- flushBecomeServerQueue();
+ flushBecomeServerQueue();
break;
case Event.SET_LOCAL_ADDRESS:
@@ -494,10 +494,8 @@ public Object down(Event evt) {
break;
case Event.BECOME_SERVER:
- boolean was_server=is_server;
is_server=true;
- if(!was_server)
- flushBecomeServerQueue();
+ flushBecomeServerQueue();
break;
case Event.SET_LOCAL_ADDRESS:

0 comments on commit be2134c

Please sign in to comment.