zstan commented on code in PR #12825:
URL: https://github.com/apache/ignite/pull/12825#discussion_r2911164248
##########
modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreWithIgniteTxFailureTest.java:
##########
@@ -201,6 +200,23 @@ public void testSystemExceptionAfterCacheStoreCommit()
throws Exception {
checkKeysOnHealthyNodes(keysOnFaultyNode);
}
+ /** Check client node availability. */
+ private void checkClientIsAvailable() {
+ assertTrue("Client node should survive test scenario",
+ G.allGrids()
+ .stream()
+ .filter(ignite -> ((IgniteEx)ignite).context().clientNode())
+ .count() == 1);
+ }
+
+ /** Check that faulty node is absent in current topology. */
+ private void checkFultyNode(int faultyNodeIdx) {
+ assertTrue("Faulty node should survive test scenario, idx=" +
faultyNodeIdx,
Review Comment:
done
##########
modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreWithIgniteTxFailureTest.java:
##########
@@ -201,6 +200,23 @@ public void testSystemExceptionAfterCacheStoreCommit()
throws Exception {
checkKeysOnHealthyNodes(keysOnFaultyNode);
}
+ /** Check client node availability. */
+ private void checkClientIsAvailable() {
+ assertTrue("Client node should survive test scenario",
+ G.allGrids()
+ .stream()
+ .filter(ignite -> ((IgniteEx)ignite).context().clientNode())
+ .count() == 1);
+ }
+
+ /** Check that faulty node is absent in current topology. */
+ private void checkFultyNode(int faultyNodeIdx) {
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
