diff options
| author | bingoohuang <bingoo.huang@gmail.com> | 2019-01-17 09:17:19 +0800 |
|---|---|---|
| committer | bingoohuang <bingoo.huang@gmail.com> | 2019-01-17 09:17:19 +0800 |
| commit | ab6be025d76748388ad3eea6fe6ca000db1c2435 (patch) | |
| tree | 1be9b1b5e7f91693f4cabe3ae0d114cb7f7dced6 /weed/topology/volume_growth.go | |
| parent | 6ddfaf33cba953b92a5e3383a15bf26ab1845dbc (diff) | |
| download | seaweedfs-ab6be025d76748388ad3eea6fe6ca000db1c2435.tar.xz seaweedfs-ab6be025d76748388ad3eea6fe6ca000db1c2435.zip | |
go fmt and fix some typo
Diffstat (limited to 'weed/topology/volume_growth.go')
| -rw-r--r-- | weed/topology/volume_growth.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/weed/topology/volume_growth.go b/weed/topology/volume_growth.go index ddf687419..9bf013ca6 100644 --- a/weed/topology/volume_growth.go +++ b/weed/topology/volume_growth.go @@ -126,7 +126,7 @@ func (vg *VolumeGrowth) findEmptySlotsForOneVolume(topo *Topology, option *Volum } //find main rack and other racks - mainRack, otherRacks, rack_err := mainDataCenter.(*DataCenter).RandomlyPickNodes(rp.DiffRackCount+1, func(node Node) error { + mainRack, otherRacks, rackErr := mainDataCenter.(*DataCenter).RandomlyPickNodes(rp.DiffRackCount+1, func(node Node) error { if option.Rack != "" && node.IsRack() && node.Id() != NodeId(option.Rack) { return fmt.Errorf("Not matching preferred rack:%s", option.Rack) } @@ -148,12 +148,12 @@ func (vg *VolumeGrowth) findEmptySlotsForOneVolume(topo *Topology, option *Volum } return nil }) - if rack_err != nil { - return nil, rack_err + if rackErr != nil { + return nil, rackErr } //find main rack and other racks - mainServer, otherServers, server_err := mainRack.(*Rack).RandomlyPickNodes(rp.SameRackCount+1, func(node Node) error { + mainServer, otherServers, serverErr := mainRack.(*Rack).RandomlyPickNodes(rp.SameRackCount+1, func(node Node) error { if option.DataNode != "" && node.IsDataNode() && node.Id() != NodeId(option.DataNode) { return fmt.Errorf("Not matching preferred data node:%s", option.DataNode) } @@ -162,8 +162,8 @@ func (vg *VolumeGrowth) findEmptySlotsForOneVolume(topo *Topology, option *Volum } return nil }) - if server_err != nil { - return nil, server_err + if serverErr != nil { + return nil, serverErr } servers = append(servers, mainServer.(*DataNode)) |
