WIP

anton-vinogradov · anton-vinogradov · commit 051812a73365 · 2025-11-13T17:54:46.000+03:00
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
@@ -6845,7 +6845,7 @@ else if (log.isDebugEnabled())
                             if (dcNode.isPresent()) {
                                 res.redirectAddresses(dcNode.get().socketAddresses());
 
-                                spi.writeToSocket(sock, spi.socketStream(sock), res, spi.getEffectiveSocketTimeout(srvSock));
+                                spi.writeMessage(ses, res, spi.getEffectiveSocketTimeout(srvSock));
 
                                 return;
                             }

Original file line number	Diff line number	Diff line change
`@@ -6845,7 +6845,7 @@ else if (log.isDebugEnabled())`
`6845`	`6845`	`if (dcNode.isPresent()) {`
`6846`	`6846`	`res.redirectAddresses(dcNode.get().socketAddresses());`
`6847`	`6847`
`6848`		`- spi.writeToSocket(sock, spi.socketStream(sock), res, spi.getEffectiveSocketTimeout(srvSock));`
	`6848`	`+ spi.writeMessage(ses, res, spi.getEffectiveSocketTimeout(srvSock));`
`6849`	`6849`
`6850`	`6850`	`return;`
`6851`	`6851`	`}`