fix:Reclaim the heartbeat response message to avoid memory leakage of…

… GettyRemoting.futures (#665) * fix:回收心跳response消息，以避免GettyRemoting.futures内存泄露 * remove chinese comment --------- Co-authored-by: tanzegen <[email protected]> Co-authored-by: Xin Wang <[email protected]>
apache · Dec 21, 2024 · cd8588e · cd8588e
1 parent 8ce1006
commit cd8588e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/remoting/processor/client/client_heart_beat_processon.go b/pkg/remoting/processor/client/client_heart_beat_processon.go
@@ -38,5 +38,9 @@ func (f *clientHeartBeatProcessor) Process(ctx context.Context, rpcMessage messa
 			log.Debug("received PONG from {}", ctx)
 		}
 	}
+	msgFuture := getty.GetGettyRemotingInstance().GetMessageFuture(rpcMessage.ID)
+	if msgFuture != nil {
+		getty.GetGettyRemotingInstance().RemoveMessageFuture(rpcMessage.ID)
+	}
 	return nil
 }