Skip to content

Commit

Permalink
COH-31696: Build: Intermittent failure ReadWriteBackingMapTests.testC…
Browse files Browse the repository at this point in the history
…acheStoreUpdateOnWriteAsyncPutAll

(auto-submit 113769 after successfully running remote remote.full)
Job ID: job.9.20250131163600.16616

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v14.1.2.0/": change = 113924]
  • Loading branch information
chpatel3 committed Jan 31, 2025
1 parent c44be11 commit d567198
Showing 1 changed file with 8 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -630,7 +630,8 @@ public void testNonBlockingFailover()
}

// stop second member and check that restore/index build gets triggered for partitions coming back
stopCacheServer("storage1");
stopCacheServer(sServerName);

// wait for server to stop
Eventually.assertDeferred(() -> cache.getCacheService().getCluster().getMemberSet().size(),
Matchers.is(1), within(5, TimeUnit.MINUTES));
Expand Down Expand Up @@ -1940,6 +1941,8 @@ private void testCacheStoreUpdate(String sCacheName, boolean fUsePutAll)
store.getStorageMap().clear();
store.resetStats();

Eventually.assertDeferred(() -> cache.size(), is(0));

if (store instanceof TestBinaryCacheStore)
{
((TestBinaryCacheStore) store).setProcessor(new AbstractProcessor()
Expand All @@ -1964,7 +1967,7 @@ public Object process(Entry entry)
}
});
// non-blocking needs delay
cDelay = 5000L;
cDelay = 10000L;
}

try
Expand All @@ -1978,6 +1981,8 @@ public Object process(Entry entry)
definiteSleep(cDelay);
}

Eventually.assertDeferred(() -> cache.size(), is(mapData.size()));

for (int i = 0; i < mapData.size(); i++)
{
Eventually.assertThat(testName,
Expand All @@ -1990,7 +1995,7 @@ public Object process(Entry entry)
Eventually.assertDeferred(() -> ExternalizableHelper.isDecorated((Binary)
rwbm.getInternalCache().get(convDown.convert(ii)),
ExternalizableHelper.DECO_STORE),
is (false));
is(false));
}
}
}
Expand Down

0 comments on commit d567198

Please sign in to comment.