CVS update: JGroups/src/org/jgroups/protocols/pbcast NAKACK.java
"Bela Ban" <[email protected]> Mon, 20 Sep 2010 11:51:11 +0000
| Newsgroups | gmane.comp.java.javagroups.cvs |
|---|---|
| Message-ID | <[email protected]> |
User: belaban
Date: 10/09/20 11:51:11
Modified: src/org/jgroups/protocols/pbcast NAKACK.java
Log:
ns
Revision Changes Path
1.258 +3 -2 JGroups/src/org/jgroups/protocols/pbcast/NAKACK.java
Index: NAKACK.java
===================================================================
RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/protocols/pbcast/NAKACK.java,v
retrieving revision 1.257
retrieving revision 1.258
diff -u -r1.257 -r1.258
--- NAKACK.java 17 Sep 2010 11:56:13 -0000 1.257
+++ NAKACK.java 20 Sep 2010 11:51:10 -0000 1.258
@@ -32,7 +32,7 @@
* instead of the requester by setting use_mcast_xmit to true.
*
* @author Bela Ban
- * @version $Id: NAKACK.java,v 1.257 2010/09/17 11:56:13 belaban Exp $
+ * @version $Id: NAKACK.java,v 1.258 2010/09/20 11:51:10 belaban Exp $
*/
@MBean(description="Reliable transmission multipoint FIFO protocol")
@DeprecatedProperty(names={"max_xmit_size", "eager_lock_release", "stats_list_size"})
@@ -811,7 +811,8 @@
// http://jira.jboss.com/jira/browse/JGRP-379
if(msg.isFlagSet(Message.OOB)) {
if(added) {
- msg=win.get(hdr.seqno);
+ if(loopback)
+ msg=win.get(hdr.seqno);
if(msg != null && msg.isFlagSet(Message.OOB)) {
if(msg.setTransientFlagIfAbsent(Message.OOB_DELIVERED))
up_prot.up(new Event(Event.MSG, msg));
------------------------------------------------------------------------------
Start uncovering the many advantages of virtual appliances
and start using them to simplify application deployment and
accelerate your shift to cloud computing.
http://p.sf.net/sfu/novell-sfdev2dev