diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-03-10 15:24:45 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-03-10 15:24:45 +0500 |
| commit | 834210a9dc05b8b0a4cc62a0d2d4e2a19804e17b (patch) | |
| tree | 7874f2f2a86f18b4042f3a37fe4fde63e55ae6f4 | |
| parent | 197ade6aebeea1316a757156cb7d6249bd102bd9 (diff) | |
| download | seaweedfs-834210a9dc05b8b0a4cc62a0d2d4e2a19804e17b.tar.xz seaweedfs-834210a9dc05b8b0a4cc62a0d2d4e2a19804e17b.zip | |
avoid connect to the old filler address
https://github.com/chrislusf/seaweedfs/issues/2545
| -rw-r--r-- | weed/filer/meta_aggregator.go | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index 1e8b89ad5..83c8a945d 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -76,9 +76,6 @@ func (ma *MetaAggregator) setActive(address pb.ServerAddress, isActive bool) (no } } else { if _, found := ma.peerStatues[address]; found { - ma.peerStatues[address] -= 1 - } - if ma.peerStatues[address] <= 0 { delete(ma.peerStatues, address) } } |