(ignite) branch master updated: IGNITE-27206 Fixed flaky the testRemovedConnectionMetrics test (#12545)

[namelchev]

This is an automated email from the ASF dual-hosted git repository.

namelchev pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 944931ea73b IGNITE-27206 Fixed flaky the testRemovedConnectionMetrics 
test (#12545)
944931ea73b is described below

commit 944931ea73b39e7d14087bb199d663b4f8b65ad2
Author: Vladimir Steshin <vlads...@gmail.com>
AuthorDate: Fri Dec 5 10:56:33 2025 +0300

    IGNITE-27206 Fixed flaky the testRemovedConnectionMetrics test (#12545)
---
 .../communication/tcp/CommunicationConnectionPoolMetricsTest.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/CommunicationConnectionPoolMetricsTest.java
 
b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/CommunicationConnectionPoolMetricsTest.java
index 90b45051a86..5189eacc8a1 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/CommunicationConnectionPoolMetricsTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/CommunicationConnectionPoolMetricsTest.java
@@ -79,6 +79,9 @@ public class CommunicationConnectionPoolMetricsTest extends 
GridCommonAbstractTe
     /** */
     private volatile long maxConnIdleTimeout = 
TcpCommunicationSpi.DFLT_IDLE_CONN_TIMEOUT;
 
+    /** */
+    private int ackSendThreshold = TcpCommunicationSpi.DFLT_ACK_SND_THRESHOLD;
+
     /** */
     private volatile int createClientDelay;
 
@@ -126,6 +129,7 @@ public class CommunicationConnectionPoolMetricsTest extends 
GridCommonAbstractTe
         communicationSpi.setConnectionsPerNode(connsPerNode)
             .setUsePairedConnections(pairedConns)
             .setIdleConnectionTimeout(maxConnIdleTimeout)
+            .setAckSendThreshold(ackSendThreshold)
             .setMessageQueueLimit(msgQueueLimit);
 
         cfg.setCommunicationSpi(communicationSpi);
@@ -140,6 +144,10 @@ public class CommunicationConnectionPoolMetricsTest 
extends GridCommonAbstractTe
     public void testRemovedConnectionMetrics() throws Exception {
         maxConnIdleTimeout = 500;
 
+        // Prevents keeping connections idle by lazy sending of the 
unacknowledged messages.
+        if (pairedConns)
+            ackSendThreshold = 1;
+
         Ignite srvr = startGridsMultiThreaded(2);
         Ignite cli = startClientGrid(G.allGrids().size());