gossip-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ecapri...@apache.org
Subject incubator-gossip git commit: GOSSIP-91 Fixed random test failure in SharedDataEventTest
Date Wed, 28 Jun 2017 12:57:06 GMT
Repository: incubator-gossip
Updated Branches:
  refs/heads/master 176944951 -> f71460ab3


GOSSIP-91 Fixed random test failure in SharedDataEventTest


Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/f71460ab
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/f71460ab
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/f71460ab

Branch: refs/heads/master
Commit: f71460ab3d5e8de7350e28488fb930a3a4af1236
Parents: 1769449
Author: Mirage Abeysekara <mirage.12@cse.mrt.ac.lk>
Authored: Tue Jun 27 18:49:56 2017 +0530
Committer: Mirage Abeysekara <mirage.12@cse.mrt.ac.lk>
Committed: Tue Jun 27 18:49:56 2017 +0530

----------------------------------------------------------------------
 .../test/java/org/apache/gossip/SharedDataEventTest.java | 11 +++++++++++
 1 file changed, 11 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/f71460ab/gossip-itest/src/test/java/org/apache/gossip/SharedDataEventTest.java
----------------------------------------------------------------------
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,


Mime
View raw message