funky-eyes commented on code in PR #7095:
URL: https://github.com/apache/incubator-seata/pull/7095#discussion_r2074952714
##########
core/src/main/java/org/apache/seata/core/rpc/netty/AbstractNettyRemotingClient.java:
##########
@@ -501,4 +512,71 @@ public void close(ChannelHandlerContext ctx,
ChannelPromise future) throws Excep
}
}
+ /**
+ * Iterates over futures and marks all MessageFutures associated with the
specified Channel as failed.
+ *
+ * @param channel The Channel that has been disconnected or encountered an
exception.
+ * @param cause The reason for the failure.
+ */
+ private void failFuturesForChannel(Channel channel, Throwable cause) {
+ Set<Integer> requestIds = channelToRequestIds.remove(channel);
+ if (requestIds != null) {
+ for (Integer requestId : requestIds) {
+ MessageFuture future = futures.remove(requestId);
Review Comment:
The childToParentMap has not been handled together.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@seata.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@seata.apache.org
For additional commands, e-mail: notifications-h...@seata.apache.org
