diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-27 22:59:50 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-27 22:59:50 -0700 |
| commit | 2a0ab7e90d728ffbab89300e72075d8b35bc54a3 (patch) | |
| tree | 880d0399b8f179f37c2edbdfe1f688cdba147ccc /weed/mq/topic/local_partition.go | |
| parent | 059a1207081644b6c6369b09044ce96d0368e66e (diff) | |
| download | seaweedfs-2a0ab7e90d728ffbab89300e72075d8b35bc54a3.tar.xz seaweedfs-2a0ab7e90d728ffbab89300e72075d8b35bc54a3.zip | |
fix
Diffstat (limited to 'weed/mq/topic/local_partition.go')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index 3c902a503..53324d846 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -179,7 +179,7 @@ func (p *LocalPartition) MaybeConnectToFollowers(initMessage *mq_pb.PublishMessa } func (p *LocalPartition) MaybeShutdownLocalPartition() (hasShutdown bool) { - if p.MaybeShutdownLocalPartition() { + if p.canShutdownLocalPartition() { if p.FollowerStream != nil { // send close to the follower if followErr := p.FollowerStream.Send(&mq_pb.PublishFollowMeRequest{ |