diff options
| author | chrislu <chris.lu@gmail.com> | 2022-09-11 19:18:42 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-09-11 19:18:42 -0700 |
| commit | 6690236754096132ef92aacf6f46db1ccfc62cff (patch) | |
| tree | f8d14c8d618168c28da8d2732ce2751c3b1776ee /weed/topology/disk.go | |
| parent | 4af8c427ebb15451d1e2516859e5840ba9ed41b7 (diff) | |
| download | seaweedfs-6690236754096132ef92aacf6f46db1ccfc62cff.tar.xz seaweedfs-6690236754096132ef92aacf6f46db1ccfc62cff.zip | |
rename variables
Diffstat (limited to 'weed/topology/disk.go')
| -rw-r--r-- | weed/topology/disk.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/topology/disk.go b/weed/topology/disk.go index 1917d7126..f4adc0e72 100644 --- a/weed/topology/disk.go +++ b/weed/topology/disk.go @@ -144,13 +144,13 @@ func (d *Disk) String() string { return fmt.Sprintf("Disk:%s, volumes:%v, ecShards:%v", d.NodeImpl.String(), d.volumes, d.ecShards) } -func (d *Disk) AddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChangedRO bool) { +func (d *Disk) AddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChanged bool) { d.Lock() defer d.Unlock() return d.doAddOrUpdateVolume(v) } -func (d *Disk) doAddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChangedRO bool) { +func (d *Disk) doAddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChanged bool) { deltaDiskUsages := newDiskUsages() deltaDiskUsage := deltaDiskUsages.getOrCreateDisk(types.ToDiskType(v.DiskType)) if oldV, ok := d.volumes[v.Id]; !ok { @@ -175,7 +175,7 @@ func (d *Disk) doAddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChangedRO boo } d.UpAdjustDiskUsageDelta(deltaDiskUsages) } - isChangedRO = d.volumes[v.Id].ReadOnly != v.ReadOnly + isChanged = d.volumes[v.Id].ReadOnly != v.ReadOnly d.volumes[v.Id] = v } return |