You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by jj...@apache.org on 2020/06/29 14:08:25 UTC
[geode] branch develop updated: GEODE-8176: Fix flakiness in
testPingWrongServer (#5303)
This is an automated email from the ASF dual-hosted git repository.
jjramos pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 34cfe04 GEODE-8176: Fix flakiness in testPingWrongServer (#5303)
34cfe04 is described below
commit 34cfe04c35a49377db229c495a4a8b9afcb278f4
Author: Alberto Bustamante Reyes <al...@users.noreply.github.com>
AuthorDate: Mon Jun 29 16:07:29 2020 +0200
GEODE-8176: Fix flakiness in testPingWrongServer (#5303)
---
.../cache/tier/sockets/ClientServerMiscDUnitTest.java | 13 ++++++-------
1 file changed, 6 insertions(+), 7 deletions(-)
diff --git a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ClientServerMiscDUnitTest.java b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ClientServerMiscDUnitTest.java
index b8667f4..1bd1ca0 100755
--- a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ClientServerMiscDUnitTest.java
+++ b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ClientServerMiscDUnitTest.java
@@ -18,7 +18,6 @@ package org.apache.geode.internal.cache.tier.sockets;
import static org.apache.geode.cache.Region.SEPARATOR;
import static org.apache.geode.test.awaitility.GeodeAwaitility.await;
import static org.assertj.core.api.Assertions.assertThat;
-import static org.junit.Assert.assertEquals;
import org.junit.Test;
@@ -89,7 +88,7 @@ public class ClientServerMiscDUnitTest extends ClientServerMiscDUnitTestBase {
RegionEntry entry2 = ((LocalRegion) region).getRegionEntry(server_k1);
int entryVersion2 = entry.getVersionStamp().getEntryVersion();
server.invoke(() -> {
- // create a "remote" invalidateion event and invalidate the already-invalid entry
+ // create a "remote" invalidation event and invalidate the already-invalid entry
LocalRegion localRegion = (LocalRegion) getCache().getRegion(regionPath);
VersionTag tag = localRegion.getRegionEntry(server_k1).getVersionStamp().asVersionTag();
InternalDistributedMember id = localRegion.getMyId();
@@ -117,22 +116,22 @@ public class ClientServerMiscDUnitTest extends ClientServerMiscDUnitTestBase {
InternalDistributedMember server2ID = server2.invoke("get ID", () -> cache.getMyId());
pool = (PoolImpl) createClientCache(NetworkUtils.getServerHostName(), PORT1);
// send the ping to server1 but use server2's identifier so the ping will be forwarded
-
ClientProxyMembershipID proxyID = server1.invoke(
() -> CacheClientNotifier.getInstance().getClientProxies().iterator().next().getProxyID());
- logger.info("ProxyID is : " + proxyID);
server2.invoke(() -> {
assertThat(ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().contains(proxyID))
.isFalse();
- assertEquals(0, ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().size());
+ assertThat(ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().size())
+ .isEqualTo(0);
});
PingOp.execute(pool, new ServerLocation(NetworkUtils.getServerHostName(), PORT1), server2ID);
// if the ping made it to server2 it will have the client's ID in its health monitor
server2.invoke(() -> {
- assertEquals(1, ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().size());
+ await("For heartbeat to be received").untilAsserted(() -> assertThat(
+ ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().size())
+ .isEqualTo(1));
ClientProxyMembershipID proxyIDFound =
ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().iterator().next();
- logger.info("ProxyID found in clientHealthMonitor: " + proxyIDFound);
assertThat(
ClientHealthMonitor.getInstance().getClientHeartbeats().keySet().contains(proxyID))
.isTrue();