From 14ddd1dbe356dab4759808042a2b56cc222e1bec Mon Sep 17 00:00:00 2001
From: tanzegen <39859116+tanzegen@users.noreply.github.com>
Date: Thu, 11 Jan 2024 13:44:24 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E5=9B=9E=E6=94=B6=E5=BF=83=E8=B7=B3respons?=
 =?UTF-8?q?e=E6=B6=88=E6=81=AF=EF=BC=8C=E4=BB=A5=E9=81=BF=E5=85=8DGettyRem?=
 =?UTF-8?q?oting.futures=E5=86=85=E5=AD=98=E6=B3=84=E9=9C=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../processor/client/client_heart_beat_processon.go         | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/pkg/remoting/processor/client/client_heart_beat_processon.go b/pkg/remoting/processor/client/client_heart_beat_processon.go
index 0b40342dc..f43fc8000 100644
--- a/pkg/remoting/processor/client/client_heart_beat_processon.go
+++ b/pkg/remoting/processor/client/client_heart_beat_processon.go
@@ -38,5 +38,11 @@ func (f *clientHeartBeatProcessor) Process(ctx context.Context, rpcMessage messa
 			log.Debug("received PONG from {}", ctx)
 		}
 	}
+	msgFuture := getty.GetGettyRemotingInstance().GetMessageFuture(rpcMessage.ID)
+	if msgFuture != nil {
+		// 心跳消息目前没有处理逻辑，所以这里不能notify，否则会导致msgFuture.Done阻塞
+		// getty.GetGettyRemotingInstance().NotifyRpcMessageResponse(rpcMessage)
+		getty.GetGettyRemotingInstance().RemoveMessageFuture(rpcMessage.ID)
+	}
 	return nil
 }