(ignite) branch master updated: IGNITE-23040 Fix GridNioSslSelfTest (#11505)

[ivandasch]

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

ivandasch 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 8782b4882ff IGNITE-23040 Fix GridNioSslSelfTest (#11505)
8782b4882ff is described below

commit 8782b4882ffdc51c2b72f45e190d3cab35ef3d24
Author: Semyon Zikunov <43781436+supermink...@users.noreply.github.com>
AuthorDate: Tue Sep 24 18:17:58 2024 +1000

    IGNITE-23040 Fix GridNioSslSelfTest (#11505)
---
 .../org/apache/ignite/internal/util/nio/GridNioSelfTest.java   | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/util/nio/GridNioSelfTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/util/nio/GridNioSelfTest.java
index 06dbed3910f..255e263a4d5 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/util/nio/GridNioSelfTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/util/nio/GridNioSelfTest.java
@@ -652,7 +652,9 @@ public class GridNioSelfTest extends GridCommonAbstractTest 
{
                 client = createClient(U.getLocalHost(), srvr.port(), 
U.getLocalHost());
 
                 client.sendMessage(createMessage(), MSG_SIZE);
+                client.receiveMessage();
                 client.sendMessage(createMessage(), MSG_SIZE);
+                client.receiveMessage();
 
                 client.close();
             }
@@ -729,8 +731,10 @@ public class GridNioSelfTest extends 
GridCommonAbstractTest {
                     try {
                         client = createClient(U.getLocalHost(), srvr.port(), 
U.getLocalHost());
 
-                        for (int i = 0; i < MSG_CNT; i++)
+                        for (int i = 0; i < MSG_CNT; i++) {
                             client.sendMessage(data, data.length);
+                            client.receiveMessage();
+                        }
                     }
                     catch (Exception e) {
                         error("Failed to send message.", e);
@@ -890,6 +894,7 @@ public class GridNioSelfTest extends GridCommonAbstractTest 
{
                             deliveryDurations.put(msg.getId(), start);
 
                             client.sendMessage(data, data.length);
+                            client.receiveMessage();
 
                             long end = System.currentTimeMillis();
 
@@ -1333,6 +1338,9 @@ public class GridNioSelfTest extends 
GridCommonAbstractTest {
 
             if (latch != null)
                 latch.countDown();
+
+            //sending ack of processing message
+            ses.send(new byte[] {(byte)0xDEADBEEF});
         }
 
         /**