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 {