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; }