Skip to content

Commit a36704b

Browse files
committed
Clean up staticcheck issues.
1 parent 12e6930 commit a36704b

File tree

3 files changed

+8
-4
lines changed

3 files changed

+8
-4
lines changed

hack/.staticcheck_failures

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -251,6 +251,5 @@ vendor/k8s.io/kubectl/pkg/describe/versioned
251251
vendor/k8s.io/kubectl/pkg/scale
252252
vendor/k8s.io/legacy-cloud-providers/aws
253253
vendor/k8s.io/legacy-cloud-providers/azure
254-
vendor/k8s.io/legacy-cloud-providers/vsphere
255254
vendor/k8s.io/metrics/pkg/client/custom_metrics
256255
vendor/k8s.io/sample-controller

staging/src/k8s.io/legacy-cloud-providers/vsphere/nodemanager.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -181,10 +181,10 @@ func (nm *NodeManager) DiscoverNode(node *v1.Node) error {
181181
}()
182182

183183
for i := 0; i < POOL_SIZE; i++ {
184+
wg.Add(1)
184185
go func() {
185186
for res := range queueChannel {
186187
ctx, cancel := context.WithCancel(context.Background())
187-
defer cancel()
188188
vm, err := res.datacenter.GetVMByUUID(ctx, nodeUUID)
189189
if err != nil {
190190
klog.V(4).Infof("Error while looking for vm=%+v in vc=%s and datacenter=%s: %v",
@@ -195,6 +195,7 @@ func (nm *NodeManager) DiscoverNode(node *v1.Node) error {
195195
klog.V(4).Infof("Did not find node %s in vc=%s and datacenter=%s",
196196
node.Name, res.vc, res.datacenter.Name())
197197
}
198+
cancel()
198199
continue
199200
}
200201
if vm != nil {
@@ -210,12 +211,12 @@ func (nm *NodeManager) DiscoverNode(node *v1.Node) error {
210211
for range queueChannel {
211212
}
212213
setVMFound(true)
214+
cancel()
213215
break
214216
}
215217
}
216218
wg.Done()
217219
}()
218-
wg.Add(1)
219220
}
220221
wg.Wait()
221222
if vmFound {

staging/src/k8s.io/legacy-cloud-providers/vsphere/vsphere.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -657,7 +657,7 @@ func (vs *VSphere) NodeAddresses(ctx context.Context, nodeName k8stypes.NodeName
657657
// Below logic can be executed only on master as VC details are present.
658658
addrs := []v1.NodeAddress{}
659659
// Create context
660-
ctx, cancel := context.WithCancel(context.Background())
660+
ctx, cancel := context.WithCancel(ctx)
661661
defer cancel()
662662
vsi, err := vs.getVSphereInstance(nodeName)
663663
if err != nil {
@@ -1640,6 +1640,10 @@ func (vs *VSphere) GetVolumeLabels(volumePath string) (map[string]string, error)
16401640
return nil, err
16411641
}
16421642
dsZones, err = vs.collapseZonesInRegion(ctx, dsZones)
1643+
if err != nil {
1644+
klog.Errorf("Failed to collapse zones. %v", err)
1645+
return nil, err
1646+
}
16431647
// FIXME: For now, pick the first zone of datastore as the zone of volume
16441648
labels := make(map[string]string)
16451649
if len(dsZones) > 0 {

0 commit comments

Comments
 (0)