Skip to content

Commit

Permalink
added 2 new tests
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Jun 9, 2008
1 parent dd50560 commit eb319af
Showing 1 changed file with 34 additions and 2 deletions.
@@ -1,4 +1,4 @@
// $Id: NakReceiverWindowTest.java,v 1.1 2007/07/04 07:29:33 belaban Exp $
// $Id: NakReceiverWindowTest.java,v 1.1.4.1 2008/06/09 09:23:15 belaban Exp $

package org.jgroups.tests;

Expand Down Expand Up @@ -462,7 +462,38 @@ public void test10000() {
}


void add(int num_msgs) {
public void testHasMessagesToRemove() {
NakReceiverWindow win=new NakReceiverWindow(sender, cmd, 0);
assertFalse(win.hasMessagesToRemove());
win.add(2, new Message());
assertFalse(win.hasMessagesToRemove());
win.add(1, oob());
assertTrue(win.hasMessagesToRemove());
win.remove();
assertTrue(win.hasMessagesToRemove());
win.remove();
assertFalse(win.hasMessagesToRemove());
}

public void testRemoveOOBMessage() {
NakReceiverWindow win=new NakReceiverWindow(sender, cmd, 0);
System.out.println("win = " + win);
win.add(2, new Message());
System.out.println("win = " + win);
assertNull(win.removeOOBMessage());
assertNull(win.remove());
win.add(1, oob());
System.out.println("win = " + win);
assertNotNull(win.removeOOBMessage());
System.out.println("win = " + win);
assertNull(win.removeOOBMessage());
assertNotNull(win.remove());
assertNull(win.remove());
assertNull(win.removeOOBMessage());
}


private void add(int num_msgs) {
long start, stop;
double time_per_msg;
NakReceiverWindow win=new NakReceiverWindow(sender, cmd, 1);
Expand All @@ -483,6 +514,7 @@ private Message oob() {
}



private void check(NakReceiverWindow win, long lowest, long highest_received, long highest_delivered) {
assertEquals("lowest=" + lowest + ", win.lowest=" + win.getLowestSeen(), lowest, win.getLowestSeen());
assertEquals("highest_received=" + highest_received + ", win.highest_received=" + win.getHighestReceived(),
Expand Down

0 comments on commit eb319af

Please sign in to comment.