github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 20:53:33 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #82964 from yutedz/csi-drv-sync-err

Browse Source 
Check error return from WaitForCacheSync
This commit is contained in:
Kubernetes Prow Robot 2019-09-25 13:50:34 -07:00 committed by GitHub
commit 6e960ef466
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/volume/csi/csi_plugin.go
View File

@ -743,7 +743,9 @@ func (p *csiPlugin) skipAttach(driver string) (bool, error) {
kletHost, ok := p.host.(volume.KubeletVolumeHost) kletHost, ok := p.host.(volume.KubeletVolumeHost)
if ok { if ok {
kletHost.WaitForCacheSync() if err := kletHost.WaitForCacheSync(); err != nil {
return false, err
}
} }
if p.csiDriverLister == nil { if p.csiDriverLister == nil {
@ -782,7 +784,9 @@ func (p *csiPlugin) supportsVolumeLifecycleMode(driver string, volumeMode storag
if p.csiDriverLister != nil { if p.csiDriverLister != nil {
kletHost, ok := p.host.(volume.KubeletVolumeHost) kletHost, ok := p.host.(volume.KubeletVolumeHost)
if ok { if ok {
kletHost.WaitForCacheSync() if err := kletHost.WaitForCacheSync(); err != nil {
return err
}
} }
c, err := p.csiDriverLister.Get(driver) c, err := p.csiDriverLister.Get(driver)