|
@@ -107,19 +107,15 @@ func lookup(name string) (volume.Driver, error) {
|
|
|
return nil, fmt.Errorf("Error looking up volume plugin %s: %v", name, err)
|
|
|
}
|
|
|
|
|
|
- drivers.Lock()
|
|
|
- defer drivers.Unlock()
|
|
|
- if ext, ok := drivers.extensions[name]; ok {
|
|
|
- return ext, nil
|
|
|
- }
|
|
|
-
|
|
|
d := NewVolumeDriver(name, p.Client())
|
|
|
if err := validateDriver(d); err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
|
|
|
if p.IsLegacy() {
|
|
|
+ drivers.Lock()
|
|
|
drivers.extensions[name] = d
|
|
|
+ drivers.Unlock()
|
|
|
}
|
|
|
return d, nil
|
|
|
}
|