Merge pull request #78754 from cwdsuzhou/June/csi_attach_close_chan

Avoid to keep the watcher open for too long
This commit is contained in:
Kubernetes Prow Robot 2019-06-17 04:36:37 -07:00 committed by GitHub
commit e46b9ca656
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -169,9 +169,13 @@ func (c *csiAttacher) waitForVolumeAttachmentInternal(volumeHandle, attachID str
if err != nil {
return "", fmt.Errorf("watch error:%v for volume %v", err, volumeHandle)
}
var watcherClosed bool
ch := watcher.ResultChan()
defer watcher.Stop()
defer func() {
if !watcherClosed {
watcher.Stop()
}
}()
for {
select {
@ -197,8 +201,11 @@ func (c *csiAttacher) waitForVolumeAttachmentInternal(volumeHandle, attachID str
return "", errors.New("volume attachment has been deleted")
case watch.Error:
// close the watcher to avoid keeping the watcher too log
watcher.Stop()
watcherClosed = true
// start another cycle
c.waitForVolumeAttachmentInternal(volumeHandle, attachID, timer, timeout)
return c.waitForVolumeAttachmentInternal(volumeHandle, attachID, timer, timeout)
}
case <-timer.C: