[ignite] branch master updated: IGNITE-19158 Improved message about received partition file during snapshot restore (#10762)

[mpetrov]

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

mpetrov 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 a107d200789 IGNITE-19158 Improved message about received partition 
file during snapshot restore (#10762)
a107d200789 is described below

commit a107d2007894363ffefdac27ee9e209227652c94
Author: Julia Bakulina <96814257+j-bak...@users.noreply.github.com>
AuthorDate: Wed Jul 12 18:19:55 2023 +0300

    IGNITE-19158 Improved message about received partition file during snapshot 
restore (#10762)
---
 .../ignite/internal/managers/communication/GridIoManager.java    | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
index 1fc734d3f12..4433000c34c 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
@@ -31,7 +31,6 @@ import java.net.Socket;
 import java.net.SocketTimeoutException;
 import java.nio.channels.Channel;
 import java.nio.channels.FileChannel;
-import java.nio.channels.ReadableByteChannel;
 import java.nio.channels.SocketChannel;
 import java.nio.channels.WritableByteChannel;
 import java.time.Instant;
@@ -2917,7 +2916,7 @@ public class GridIoManager extends 
GridManagerAdapter<CommunicationSpi<Serializa
         ReceiverContext rcvCtx,
         ObjectInputStream in,
         ObjectOutputStream out,
-        ReadableByteChannel ch
+        SocketChannel ch
     ) throws NodeStoppingException, InterruptedException {
         try {
             while (true) {
@@ -2964,9 +2963,11 @@ public class GridIoManager extends 
GridManagerAdapter<CommunicationSpi<Serializa
                     rcvCtx.rcv.close();
 
                     U.log(log, "File has been received " +
-                        "[name=" + rcvCtx.rcv.state().name() + ", 
transferred=" + rcvCtx.rcv.transferred() +
+                        "[name=" + rcvCtx.rcv.state().name() +
+                        ", transferred=" + rcvCtx.rcv.transferred() +
                         ", time=" + (double)((U.currentTimeMillis() - 
startTime) / 1000) + " sec" +
-                        ", rmtId=" + rcvCtx.rmtNodeId + ']');
+                        ", rmtId=" + rcvCtx.rmtNodeId +
+                        ", rmtAddr=" + ch.getRemoteAddress() + ']');
 
                     rcvCtx.rcv = null;
                 }