CVS update: JGroups/src/org/jgroups/protocols DAISYCHAIN.java
"Bela Ban" <[email protected]>
| Newsgroups | gmane.comp.java.javagroups.cvs |
|---|---|
| Message-ID | <[email protected]> |
User: belaban
Date: 10/09/13 12:02:47
Modified: src/org/jgroups/protocols DAISYCHAIN.java
Log:
ns
Revision Changes Path
1.11 +7 -4 JGroups/src/org/jgroups/protocols/DAISYCHAIN.java
Index: DAISYCHAIN.java
===================================================================
RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/protocols/DAISYCHAIN.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- DAISYCHAIN.java 24 Aug 2010 12:15:41 -0000 1.10
+++ DAISYCHAIN.java 13 Sep 2010 12:02:47 -0000 1.11
@@ -18,7 +18,7 @@
* send another message. This leads to much better throughput, see the ref in the JIRA.<p/>
* JIRA: https://jira.jboss.org/browse/JGRP-1021
* @author Bela Ban
- * @version $Id: DAISYCHAIN.java,v 1.10 2010/08/24 12:15:41 belaban Exp $
+ * @version $Id: DAISYCHAIN.java,v 1.11 2010/09/13 12:02:47 belaban Exp $
*/
@Experimental @Unsupported
@MBean(description="Protocol just above the transport which disseminates multicasts via daisy chaining")
@@ -142,9 +142,12 @@
protected void handleView(View view) {
view_size=view.size();
- next=Util.pickNext(view.getMembers(), local_addr);
- if(log.isDebugEnabled())
- log.debug("next=" + next);
+ Address tmp=Util.pickNext(view.getMembers(), local_addr);
+ if(tmp != null && !tmp.equals(local_addr)) {
+ next=tmp;
+ if(log.isDebugEnabled())
+ log.debug("next=" + next);
+ }
}
------------------------------------------------------------------------------
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