Skip to content

Commit feafc65

Browse files
committed
fix
1 parent 3c62dbe commit feafc65

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7581,7 +7581,7 @@ private void processClientMetricsUpdateMessage(TcpDiscoveryClientMetricsUpdateMe
75817581
ClientMessageWorker wrk = clientMsgWorkers.get(msg.creatorNodeId());
75827582

75837583
if (wrk != null)
7584-
wrk.metrics(new ClusterMetricsSnapshot());
7584+
wrk.metrics(new ClusterMetricsSnapshot(msg.metricsMessage()));
75857585
else if (log.isDebugEnabled())
75867586
log.debug("Received client metrics update message from unknown client node: " + msg);
75877587
}

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryIoSession.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,8 @@ <T> T readMessage() throws IgniteCheckedException, IOException {
170170
if (MESSAGE_SERIALIZATION != serMode) {
171171
detectSslAlert(serMode, in);
172172

173+
// IOException type is important for ServerImpl for connection error processing behavior.
174+
// It may search the cause (X.hasCause).
173175
throw new IOException("Received unexpected byte while reading discovery message: " + serMode);
174176
}
175177

0 commit comments

Comments
 (0)