added test for resize()

belaban · Dec 16, 2010 · b7c4cfa · b7c4cfa
1 parent 767b88b
commit b7c4cfa
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/src/org/jgroups/util/RetransmitTable.java b/src/org/jgroups/util/RetransmitTable.java
@@ -420,7 +420,7 @@ protected int computeIndex(long seqno) {
         int diff=(int)(seqno - offset);
         if(diff < 0)
             return diff;
-        return (int)(seqno - offset) % msgs_per_row;
+        return diff % msgs_per_row;
     }
 
 

diff --git a/tests/junit-functional/org/jgroups/tests/RetransmitTableTest.java b/tests/junit-functional/org/jgroups/tests/RetransmitTableTest.java
@@ -175,6 +175,18 @@ public void testResizeWithPurge2() {
 
         table.purge(43);
         addAndGet(table, 52, "hello-52");
+        assert table.get(43) == null;
+
+        for(long i=44; i < 50; i++) {
+            Message msg=table.get(i);
+            assert msg != null && msg.getObject().equals("hello-" + i);
+        }
+
+        assert table.get(50) == null;
+        assert table.get(51) == null;
+        Message msg=table.get(52);
+        assert msg != null && msg.getObject().equals("hello-52");
+        assert table.get(53) == null;
     }