This is an automated email from the ASF dual-hosted git repository. isapego pushed a commit to branch ignite-17607 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit f9188fa9bef4858e67f3837905ba3f52440cd07c Author: Igor Sapego <[email protected]> AuthorDate: Tue Mar 7 15:13:30 2023 +0300 IGNITE-17607 Fix get cluster node --- .../client/handler/requests/cluster/ClientClusterGetNodesRequest.java | 2 ++ .../main/java/org/apache/ignite/internal/client/TcpIgniteClient.java | 3 +++ .../platforms/dotnet/Apache.Ignite/Internal/IgniteClientInternal.cs | 4 ++++ 3 files changed, 9 insertions(+) diff --git a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/cluster/ClientClusterGetNodesRequest.java b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/cluster/ClientClusterGetNodesRequest.java index 20032f4fa5..4d3d137083 100644 --- a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/cluster/ClientClusterGetNodesRequest.java +++ b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/cluster/ClientClusterGetNodesRequest.java @@ -42,6 +42,8 @@ public class ClientClusterGetNodesRequest { out.packArrayHeader(nodes.size()); for (ClusterNode node : nodes) { + out.packArrayHeader(4); + out.packString(node.id()); out.packString(node.name()); out.packString(node.address().host()); diff --git a/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java b/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java index 8ab6beaafa..e5b644b250 100644 --- a/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java +++ b/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java @@ -160,6 +160,9 @@ public class TcpIgniteClient implements IgniteClient { List<ClusterNode> res = new ArrayList<>(cnt); for (int i = 0; i < cnt; i++) { + int fieldCnt = r.in().unpackArrayHeader(); + assert fieldCnt == 4; + res.add(new ClusterNode( r.in().unpackString(), r.in().unpackString(), diff --git a/modules/platforms/dotnet/Apache.Ignite/Internal/IgniteClientInternal.cs b/modules/platforms/dotnet/Apache.Ignite/Internal/IgniteClientInternal.cs index d71548cf61..fe00808716 100644 --- a/modules/platforms/dotnet/Apache.Ignite/Internal/IgniteClientInternal.cs +++ b/modules/platforms/dotnet/Apache.Ignite/Internal/IgniteClientInternal.cs @@ -18,6 +18,7 @@ namespace Apache.Ignite.Internal { using System.Collections.Generic; + using System.Diagnostics; using System.Net; using System.Threading.Tasks; using Ignite.Compute; @@ -85,6 +86,9 @@ namespace Apache.Ignite.Internal for (var i = 0; i < count; i++) { + var fieldCount = r.ReadArrayHeader(); + Debug.Assert(fieldCount == 4, "fieldCount == 4"); + res.Add(new ClusterNode( Id: r.ReadString(), Name: r.ReadString(),
