From 45398a9db74af2723ffdd9b1b0cbb46c3db46030 Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 18 Nov 2025 21:51:29 -0800 Subject: [PATCH] avoid returning too quickly and ensure proper cleaning up --- weed/mq/broker/broker_grpc_pub_follow.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/weed/mq/broker/broker_grpc_pub_follow.go b/weed/mq/broker/broker_grpc_pub_follow.go index ec8e4ecf1..d8f472249 100644 --- a/weed/mq/broker/broker_grpc_pub_follow.go +++ b/weed/mq/broker/broker_grpc_pub_follow.go @@ -53,9 +53,10 @@ func (b *MessageQueueBroker) PublishFollowMe(stream mq_pb.SeaweedMessaging_Publi // TODO: change this to DataMessage // log the message - if err := logBuffer.AddToBuffer(dataMessage); err != nil { - glog.Errorf("Failed to add message to log buffer: %v", err) - return fmt.Errorf("failed to add message to log buffer: %w", err) + if addErr := logBuffer.AddToBuffer(dataMessage); addErr != nil { + err = fmt.Errorf("failed to add message to log buffer: %w", addErr) + glog.Errorf("Failed to add message to log buffer: %v", addErr) + break } // send back the ack