github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-06 10:43:56 +00:00
Code Issues Projects Releases Wiki Activity

Check error return from WaitForCacheSync

Browse Source
This commit is contained in:
Ted Yu 2019-09-21 07:02:51 -07:00
parent 53b3c8968e
commit 384aaad468
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -60,8 +60,6 @@ const (
CsiResyncPeriod = time.Minute CsiResyncPeriod = time.Minute
) )
var deprecatedSocketDirVersions = []string{"0.1.0", "0.2.0", "0.3.0", "0.4.0"}
type csiPlugin struct { type csiPlugin struct {
host volume.VolumeHost host volume.VolumeHost
blockEnabled bool blockEnabled bool
@ -745,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 {
@ -784,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)