diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-16 17:11:42 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-16 17:11:42 -0700 |
| commit | 44ab42d03c754cffe67a8643b8054fff71ce426d (patch) | |
| tree | f56eb7f25915f8f707ebaef0205f292e598fdacc | |
| parent | 3f2dd8cc3eca4a7782d0857e5c2b2ca41ee4b94f (diff) | |
| download | seaweedfs-44ab42d03c754cffe67a8643b8054fff71ce426d.tar.xz seaweedfs-44ab42d03c754cffe67a8643b8054fff71ce426d.zip | |
unnecessary
| -rw-r--r-- | weed/mq/broker/broker_grpc_sub.go | 5 |
1 files changed, 0 insertions, 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 |