diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-06-15 21:11:31 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-06-15 21:11:31 -0700 |
| commit | 56eb522b136966d38b257ade7da07479092ce12c (patch) | |
| tree | 8775c059be3abf172e2e14e160841cf1a9111671 | |
| parent | 055374a50bc3cfe78be6d73514182decb8531666 (diff) | |
| download | seaweedfs-56eb522b136966d38b257ade7da07479092ce12c.tar.xz seaweedfs-56eb522b136966d38b257ade7da07479092ce12c.zip | |
fix stats when a collection is deleted
| -rw-r--r-- | weed/storage/store.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/weed/storage/store.go b/weed/storage/store.go index f27f2412f..6ff996a3c 100644 --- a/weed/storage/store.go +++ b/weed/storage/store.go @@ -250,6 +250,11 @@ func (s *Store) CollectHeartbeat() *master_pb.Heartbeat { } if !deleteVolume { collectionVolumeSize[v.Collection] += volumeMessage.Size + } else { + collectionVolumeSize[v.Collection] -= volumeMessage.Size + if collectionVolumeSize[v.Collection] <= 0 { + delete(collectionVolumeSize, v.Collection) + } } if _, exist := collectionVolumeReadOnlyCount[v.Collection]; !exist { |