Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

ns

  • Loading branch information...
commit f1f1b653b554b9c37e8225ce7e9a6177642b2b76 1 parent a676ef9
@belaban authored
Showing with 6 additions and 0 deletions.
  1. +6 −0 tests/junit/org/jgroups/protocols/UNICAST_ContentionTest.java
View
6 tests/junit/org/jgroups/protocols/UNICAST_ContentionTest.java
@@ -101,6 +101,12 @@ public void testMessageReceptionUnderHighLoad(String props) throws Exception {
if(r1.getNum() == NUM_EXPECTED_MSGS && r2.getNum() == NUM_EXPECTED_MSGS)
break;
Util.sleep(500);
+ UNICAST2 unicast2=(UNICAST2)c1.getProtocolStack().findProtocol(UNICAST2.class);
+ if(unicast2 != null)
+ unicast2.sendStableMessages();
+ unicast2=(UNICAST2)c2.getProtocolStack().findProtocol(UNICAST2.class);
+ if(unicast2 != null)
+ unicast2.sendStableMessages();
}
System.out.println("c1 received " + r1.getNum() + " msgs, " + getNumberOfRetransmissions(c1) + " retransmissions");
Please sign in to comment.
Something went wrong with that request. Please try again.