diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-31 17:49:34 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-31 17:49:34 -0700 |
| commit | 47975e75bfb12928f8a5caaaf79395168d15f27c (patch) | |
| tree | 721408325faf8df3f863d26c634b2d480e7584f6 | |
| parent | 237e68059d836d6abf199097997f3315722e992d (diff) | |
| download | seaweedfs-47975e75bfb12928f8a5caaaf79395168d15f27c.tar.xz seaweedfs-47975e75bfb12928f8a5caaaf79395168d15f27c.zip | |
purge old code
| -rw-r--r-- | weed/mq/topic/local_partition.go | 2 |
1 files changed, 0 insertions, 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) } |