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

Concurrentmap Iteration

Browse Source
This commit is contained in:
niranjandarshann 2025-01-22 16:10:12 +05:30
parent a78983906f
commit 84b8f181e4
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/volume/plugins.go
View File

@ -653,7 +653,12 @@ func (pm *VolumePluginMgr) FindPluginBySpec(spec *Spec) (VolumePlugin, error) {
} }
} }
pm.mutex.RUnlock()
pm.mutex.Lock()
pm.refreshProbedPlugins() pm.refreshProbedPlugins()
pm.mutex.Unlock()
pm.mutex.RLock()
for _, plugin := range pm.probedPlugins { for _, plugin := range pm.probedPlugins {
if plugin.CanSupport(spec) { if plugin.CanSupport(spec) {
match = plugin match = plugin
@ -681,7 +686,11 @@ func (pm *VolumePluginMgr) FindPluginByName(name string) (VolumePlugin, error) {
match = v match = v
} }
pm.mutex.RUnlock()
pm.mutex.Lock()
pm.refreshProbedPlugins() pm.refreshProbedPlugins()
pm.mutex.Unlock()
pm.mutex.RLock()
if plugin, found := pm.probedPlugins[name]; found { if plugin, found := pm.probedPlugins[name]; found {
if match != nil { if match != nil {
return nil, fmt.Errorf("multiple volume plugins matched: %s and %s", match.GetPluginName(), plugin.GetPluginName()) return nil, fmt.Errorf("multiple volume plugins matched: %s and %s", match.GetPluginName(), plugin.GetPluginName())