rdev/gossip-revisited
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

GOSSIP-91 Fixed random test failure in SharedDataEventTest

Browse Source
This commit is contained in:
Mirage Abeysekara
2017-06-27 18:49:56 +05:30
parent 1769449515
commit f71460ab3d
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
gossip-itest/src/test/java/org/apache/gossip/SharedDataEventTest.java
View File

@ -171,6 +171,17 @@ public class SharedDataEventTest extends AbstractIntegrationBase {
Assert.assertTrue(receivingNodeDataNewValue instanceof GrowOnlyCounter); Assert.assertTrue(receivingNodeDataNewValue instanceof GrowOnlyCounter);
Assert.assertEquals(1, ((GrowOnlyCounter) receivingNodeDataNewValue).value().longValue()); 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 // Node 3 Updates the gCounter by 4
GrowOnlyCounter gc = (GrowOnlyCounter) clients.get(2).findCrdt(gCounterKey); GrowOnlyCounter gc = (GrowOnlyCounter) clients.get(2).findCrdt(gCounterKey);
GrowOnlyCounter gcNew = new GrowOnlyCounter(gc, GrowOnlyCounter gcNew = new GrowOnlyCounter(gc,