From a107d2007894363ffefdac27ee9e209227652c94 Mon Sep 17 00:00:00 2001 From: Julia Bakulina <96814257+J-Bakuli@users.noreply.github.com> Date: Wed, 12 Jul 2023 18:19:55 +0300 Subject: [PATCH] IGNITE-19158 Improved message about received partition file during snapshot restore (#10762) --- .../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 1fc734d3f126c..4433000c34cf3 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.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 @@ private void receiveFromChannel( ReceiverContext rcvCtx, ObjectInputStream in, ObjectOutputStream out, - ReadableByteChannel ch + SocketChannel ch ) throws NodeStoppingException, InterruptedException { try { while (true) { @@ -2964,9 +2963,11 @@ private void receiveFromChannel( 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; }