Skip to content

Commit

Permalink
ns
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Dec 19, 2024
1 parent 215c942 commit b6e06fa
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions tests/junit-functional/org/jgroups/tests/RelayTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -837,14 +837,14 @@ public void testFailover(Class<? extends RELAY> cl) throws Exception {
for(int i=1; i <=5; i++)
a.send(target, "hello-" + i);

Util.waitUntil(3000, 100,
Util.waitUntil(5000, 100,
() -> ((RELAY)d.getProtocolStack().findProtocol(RELAY.class)).isSiteMaster());
MyReceiver<Message> r=getReceiver(d);
Util.waitUntil(2000, 200, () -> r.size() == 5);
Util.waitUntil(5000, 200, () -> r.size() == 5);

Table<Message> send_win=unicast.getSendWindow(target);
// wait until the ack from D has been received
Util.waitUntil(2000, 100, () -> send_win.getHighestDelivered() == send_win.getHighestReceived());
Util.waitUntil(5000, 100, () -> send_win.getHighestDelivered() == send_win.getHighestReceived());
relay.setRouteStatusListener(null);
}

Expand Down

0 comments on commit b6e06fa

Please sign in to comment.