Permalink
Browse files

let unicast messages pass up (https://issues.jboss.org/browse/JGRP-1341)

  • Loading branch information...
1 parent b0b33b6 commit 7860afd2135b31d6741be0885fcb37cc652c6cfd Bela Ban committed Jul 1, 2011
Showing with 4 additions and 0 deletions.
  1. +4 −0 src/org/jgroups/protocols/BARRIER.java
@@ -1,6 +1,7 @@
package org.jgroups.protocols;
import org.jgroups.Event;
+import org.jgroups.Message;
import org.jgroups.annotations.ManagedAttribute;
import org.jgroups.annotations.Property;
import org.jgroups.stack.Protocol;
@@ -93,6 +94,9 @@ public Object down(Event evt) {
public Object up(Event evt) {
switch(evt.getType()) {
case Event.MSG:
+ Message msg=(Message)evt.getArg();
+ if(msg.getDest() != null) // https://issues.jboss.org/browse/JGRP-1341: let unicast messages pass
+ return up_prot.up(evt);
Thread current_thread=Thread.currentThread();
in_flight_threads.put(current_thread, NULL);
if(barrier_closed.get()) {

0 comments on commit 7860afd

Please sign in to comment.