github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 08:17:26 +00:00
Code Issues Projects Releases Wiki Activity

Fix keep the watcher open for too long

Browse Source
This commit is contained in:
caiweidong 2019-06-06 14:47:36 +08:00
parent ef7808fec5
commit 0508bea9b6
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/volume/csi/csi_attacher.go
View File

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