From f71460ab3d5e8de7350e28488fb930a3a4af1236 Mon Sep 17 00:00:00 2001 From: Mirage Abeysekara Date: Tue, 27 Jun 2017 18:49:56 +0530 Subject: [PATCH] GOSSIP-91 Fixed random test failure in SharedDataEventTest --- .../java/org/apache/gossip/SharedDataEventTest.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/gossip-itest/src/test/java/org/apache/gossip/SharedDataEventTest.java b/gossip-itest/src/test/java/org/apache/gossip/SharedDataEventTest.java index 56f1657..8dbfcb3 100644 --- a/gossip-itest/src/test/java/org/apache/gossip/SharedDataEventTest.java +++ b/gossip-itest/src/test/java/org/apache/gossip/SharedDataEventTest.java @@ -171,6 +171,17 @@ public class SharedDataEventTest extends AbstractIntegrationBase { Assert.assertTrue(receivingNodeDataNewValue instanceof GrowOnlyCounter); Assert.assertEquals(1, ((GrowOnlyCounter) receivingNodeDataNewValue).value().longValue()); + // check whether Node 3 received the gCounter + TUnit.assertThat(() -> { + GrowOnlyCounter gc = (GrowOnlyCounter) clients.get(2).findCrdt(gCounterKey); + if (gc == null) { + return ""; + } else { + return gc; + } + }).afterWaitingAtMost(10, TimeUnit.SECONDS).isEqualTo( + new GrowOnlyCounter(new GrowOnlyCounter.Builder(clients.get(0)).increment(1L))); + // Node 3 Updates the gCounter by 4 GrowOnlyCounter gc = (GrowOnlyCounter) clients.get(2).findCrdt(gCounterKey); GrowOnlyCounter gcNew = new GrowOnlyCounter(gc,