CVS update: JGroups/src/org/jgroups/protocols/pbcast NAKACK.java
"Bela Ban" <[email protected]>
| Newsgroups | gmane.comp.java.javagroups.cvs |
|---|---|
| Message-ID | <[email protected]> |
User: belaban
Date: 10/08/27 09:26:08
Modified: src/org/jgroups/protocols/pbcast NAKACK.java
Log:
using NRW.getDigest(): reduces locking on NRW
Revision Changes Path
1.256 +3 -3 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.255
retrieving revision 1.256
diff -u -r1.255 -r1.256
--- NAKACK.java 14 Jun 2010 08:11:19 -0000 1.255
+++ NAKACK.java 27 Aug 2010 09:26:08 -0000 1.256
@@ -32,7 +32,7 @@
* instead of the requester by setting use_mcast_xmit to true.
*
* @author Bela Ban
- * @version $Id: NAKACK.java,v 1.255 2010/06/14 08:11:19 belaban Exp $
+ * @version $Id: NAKACK.java,v 1.256 2010/08/27 09:26:08 belaban Exp $
*/
@MBean(description="Reliable transmission multipoint FIFO protocol")
@DeprecatedProperty(names={"max_xmit_size", "eager_lock_release", "stats_list_size"})
@@ -1192,8 +1192,8 @@
for(Map.Entry<Address,NakReceiverWindow> entry: xmit_table.entrySet()) {
Address sender=entry.getKey(); // guaranteed to be non-null (CCHM)
NakReceiverWindow win=entry.getValue(); // guaranteed to be non-null (CCHM)
- long low=win.getLowestSeen(), highest_delivered=win.getHighestDelivered(), highest_received=win.getHighestReceived();
- map.put(sender, new Digest.Entry(low, highest_delivered, highest_received));
+ long[] digest=win.getDigest();
+ map.put(sender, new Digest.Entry(digest[0], digest[1], digest[2]));
}
return new Digest(map);
}
------------------------------------------------------------------------------
Sell apps to millions through the Intel(R) Atom(Tm) Developer Program
Be part of this innovative community and reach millions of netbook users
worldwide. Take advantage of special opportunities to increase revenue and
speed time-to-market. Join now, and jumpstart your future.
http://p.sf.net/sfu/intel-atom-d2d