CVS update: JGroups/src/org/jgroups/protocols FRAG.java
"Bela Ban" <[email protected]>
| Newsgroups | gmane.comp.java.javagroups.cvs |
|---|---|
| Message-ID | <[email protected]> |
User: belaban
Date: 10/08/26 15:38:22
Modified: src/org/jgroups/protocols FRAG.java
Log:
ns
Revision Changes Path
1.52 +3 -3 JGroups/src/org/jgroups/protocols/FRAG.java
Index: FRAG.java
===================================================================
RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/protocols/FRAG.java,v
retrieving revision 1.51
retrieving revision 1.52
diff -u -r1.51 -r1.52
--- FRAG.java 5 Mar 2010 09:04:54 -0000 1.51
+++ FRAG.java 26 Aug 2010 15:38:22 -0000 1.52
@@ -42,7 +42,7 @@
*
* @author Bela Ban
* @author Filip Hanik
- * @version $Id: FRAG.java,v 1.51 2010/03/05 09:04:54 belaban Exp $
+ * @version $Id: FRAG.java,v 1.52 2010/08/26 15:38:22 belaban Exp $
*/
@MBean(description="Fragments messages larger than fragmentation size into smaller packets")
public class FRAG extends Protocol {
@@ -201,7 +201,7 @@
*/
private void fragment(Message msg, long size) {
Address dest=msg.getDest(), src=msg.getSrc();
- long id=curr_id.getAndIncrement(); // used as seqnos
+ long frag_id=curr_id.getAndIncrement(); // used as seqnos
int num_frags;
try {
@@ -224,7 +224,7 @@
for(int i=0; i < num_frags; i++) {
Message frag_msg=new Message(dest, src, fragments[i]);
- FragHeader hdr=new FragHeader(id, i, num_frags);
+ FragHeader hdr=new FragHeader(frag_id, i, num_frags);
frag_msg.putHeader(this.id, hdr);
Event evt=new Event(Event.MSG, frag_msg);
down_prot.down(evt);
------------------------------------------------------------------------------
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