From 44ab42d03c754cffe67a8643b8054fff71ce426d Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 16 Mar 2024 17:11:42 -0700 Subject: [PATCH] unnecessary --- weed/mq/broker/broker_grpc_sub.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/weed/mq/broker/broker_grpc_sub.go b/weed/mq/broker/broker_grpc_sub.go index 1141ff47f..940af7490 100644 --- a/weed/mq/broker/broker_grpc_sub.go +++ b/weed/mq/broker/broker_grpc_sub.go @@ -175,12 +175,10 @@ func (b *MessageQueueBroker) FollowInMemoryMessages(req *mq_pb.FollowInMemoryMes atomic.StoreInt32(&localTopicPartition.FollowerId, followerId) glog.V(0).Infof("FollowInMemoryMessages %s connected on %v %v", clientName, t, partition) - isConnected := true sleepIntervalCount := 0 var counter int64 defer func() { - isConnected = false glog.V(0).Infof("FollowInMemoryMessages %s on %v %v disconnected, sent %d", clientName, t, partition, counter) }() @@ -200,9 +198,6 @@ func (b *MessageQueueBroker) FollowInMemoryMessages(req *mq_pb.FollowInMemoryMes var prevFlushTsNs int64 _, _, err = localTopicPartition.LogBuffer.LoopProcessLogData(clientName, startPosition, 0, func() bool { - if !isConnected { - return false - } sleepIntervalCount++ if sleepIntervalCount > 32 { sleepIntervalCount = 32