diff options
Diffstat (limited to 'weed/topology/topology_event_handling.go')
| -rw-r--r-- | weed/topology/topology_event_handling.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/weed/topology/topology_event_handling.go b/weed/topology/topology_event_handling.go index ff1c642a6..109f29ee0 100644 --- a/weed/topology/topology_event_handling.go +++ b/weed/topology/topology_event_handling.go @@ -65,10 +65,9 @@ func (t *Topology) SetVolumeCapacityFull(volumeInfo storage.VolumeInfo) bool { if !volumeInfo.ReadOnly { disk := dn.getOrCreateDisk(volumeInfo.DiskType) - deltaDiskUsages := newDiskUsages() - deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.ToDiskType(volumeInfo.DiskType)) - deltaDiskUsage.activeVolumeCount = -1 - disk.UpAdjustDiskUsageDelta(deltaDiskUsages) + disk.UpAdjustDiskUsageDelta(types.ToDiskType(volumeInfo.DiskType), &DiskUsageCounts{ + activeVolumeCount: -1, + }) } } @@ -96,7 +95,9 @@ func (t *Topology) UnRegisterDataNode(dn *DataNode) { } negativeUsages := dn.GetDiskUsages().negative() - dn.UpAdjustDiskUsageDelta(negativeUsages) + for dt, du := range negativeUsages.usages { + dn.UpAdjustDiskUsageDelta(dt, du) + } dn.DeltaUpdateVolumes([]storage.VolumeInfo{}, dn.GetVolumes()) dn.DeltaUpdateEcShards([]*erasure_coding.EcVolumeInfo{}, dn.GetEcShards()) if dn.Parent() != nil { |