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/08/13 11:34:53
Modified: src/org/jgroups/protocols DAISYCHAIN.java
Log:
ns
Revision Changes Path
1.3 +3 -2 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.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- DAISYCHAIN.java 13 Aug 2010 10:23:52 -0000 1.2
+++ DAISYCHAIN.java 13 Aug 2010 11:34:53 -0000 1.3
@@ -19,7 +19,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.2 2010/08/13 10:23:52 belaban Exp $
+ * @version $Id: DAISYCHAIN.java,v 1.3 2010/08/13 11:34:53 belaban Exp $
*/
@MBean(description="Protocol just above the transport which disseminates multicasts via daisy chaining")
public class DAISYCHAIN extends Protocol {
@@ -41,7 +41,7 @@
public Object down(final Event evt) {
switch(evt.getType()) {
case Event.MSG:
- Message msg=(Message)evt.getArg();
+ final Message msg=(Message)evt.getArg();
Address dest=msg.getDest();
if(dest != null && !dest.isMulticastAddress())
break; // only process multicast messages
@@ -59,6 +59,7 @@
if(loopback) {
if(log.isTraceEnabled()) log.trace(new StringBuilder("looping back message ").append(msg));
+ msg.setSrc(local_addr);
Executor pool=msg.isFlagSet(Message.OOB)? getTransport().getOOBThreadPool()
: getTransport().getDefaultThreadPool();
------------------------------------------------------------------------------
This SF.net email is sponsored by
Make an app they can't live without
Enter the BlackBerry Developer Challenge
http://p.sf.net/sfu/RIM-dev2dev