Vladsz83 commented on code in PR #11327:
URL: https://github.com/apache/ignite/pull/11327#discussion_r1595490698
##########
modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryNetworkIssuesTest.java:
##########
@@ -243,14 +253,31 @@ public void
testBackwardNodeCheckWithSameLoopbackSingleLocalAddress() throws Exc
*/
@Test
public void testBackwardNodeCheckWithSameLoopbackSeveralLocalAddresses()
throws Exception {
- doTestBackwardNodeCheckWithSameLoopback("0.0.0.0");
+ ListeningTestLogger testMethodLog = new ListeningTestLogger(log);
+
+ String startLogMsg = "Checking connection to node";
+
+ Collection<LogListener> lsnrs = new ArrayList<>();
+
+
lsnrs.add(LogListener.matches(startLogMsg).andMatches("result=success").times(1).build());
+
lsnrs.add(LogListener.matches(startLogMsg).andMatches("result=skipped").times(3).build());
+ lsnrs.add(LogListener.matches("Connection check to previous node
done").times(1).build());
+
+ lsnrs.forEach(testMethodLog::registerListener);
+
+ doTestBackwardNodeCheckWithSameLoopback("0.0.0.0", testMethodLog);
+
+ for (LogListener lsnr : lsnrs)
+ waitForCondition(lsnr::check, getTestTimeout());
+
+ testMethodLog.clearListeners();
}
/**
* Performs Tests backward node ping if {@link
TcpDiscoveryNode#socketAddresses()} contains same loopback address as of local
node.
* Assumes several local address are resolved.
*/
- private void doTestBackwardNodeCheckWithSameLoopback(String localhost)
throws Exception {
+ private void doTestBackwardNodeCheckWithSameLoopback(String localhost,
ListeningTestLogger testMethodLog) throws Exception {
Review Comment:
Suggestion: `@Nullable` to `ListeningTestLogger testMethodLog`
--
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]
