From 47975e75bfb12928f8a5caaaf79395168d15f27c Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 31 Mar 2024 17:49:34 -0700 Subject: [PATCH] purge old code --- weed/mq/topic/local_partition.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index 40ab3cee6..895faf596 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -27,7 +27,6 @@ type LocalPartition struct { LogBuffer *log_buffer.LogBuffer Publishers *LocalPartitionPublishers Subscribers *LocalPartitionSubscribers - FollowerId int32 followerStream mq_pb.SeaweedMessaging_PublishFollowMeClient followerGrpcConnection *grpc.ClientConn @@ -218,6 +217,5 @@ func (p *LocalPartition) Shutdown() { p.closePublishers() p.closeSubscribers() p.LogBuffer.ShutdownLogBuffer() - atomic.StoreInt32(&p.FollowerId, 0) glog.V(0).Infof("local partition %v shutting down", p.Partition) }