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/data_node.go | |
| parent | 4af8c427ebb15451d1e2516859e5840ba9ed41b7 (diff) | |
| download | seaweedfs-6690236754096132ef92aacf6f46db1ccfc62cff.tar.xz seaweedfs-6690236754096132ef92aacf6f46db1ccfc62cff.zip | |
rename variables
Diffstat (limited to 'weed/topology/data_node.go')
| -rw-r--r-- | weed/topology/data_node.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/topology/data_node.go b/weed/topology/data_node.go index 0ce6fdbee..ee0d37956 100644 --- a/weed/topology/data_node.go +++ b/weed/topology/data_node.go @@ -54,14 +54,14 @@ func (dn *DataNode) getOrCreateDisk(diskType string) *Disk { return disk } -func (dn *DataNode) doAddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChangedRO bool) { +func (dn *DataNode) doAddOrUpdateVolume(v storage.VolumeInfo) (isNew, isChanged bool) { disk := dn.getOrCreateDisk(v.DiskType) return disk.AddOrUpdateVolume(v) } // UpdateVolumes detects new/deleted/changed volumes on a volume server // used in master to notify master clients of these changes. -func (dn *DataNode) UpdateVolumes(actualVolumes []storage.VolumeInfo) (newVolumes, deletedVolumes, changeRO []storage.VolumeInfo) { +func (dn *DataNode) UpdateVolumes(actualVolumes []storage.VolumeInfo) (newVolumes, deletedVolumes, changedVolumes []storage.VolumeInfo) { actualVolumeMap := make(map[needle.VolumeId]storage.VolumeInfo) for _, v := range actualVolumes { @@ -94,12 +94,12 @@ func (dn *DataNode) UpdateVolumes(actualVolumes []storage.VolumeInfo) (newVolume } } for _, v := range actualVolumes { - isNew, isChangedRO := dn.doAddOrUpdateVolume(v) + isNew, isChanged := dn.doAddOrUpdateVolume(v) if isNew { newVolumes = append(newVolumes, v) } - if isChangedRO { - changeRO = append(changeRO, v) + if isChanged { + changedVolumes = append(changedVolumes, v) } } return |