NetworkDrivers were still using v1 to Get plugins. Fix that.
Signed-off-by: Anusha Ragunathan <anusha@docker.com>
| ... | ... |
@@ -1059,9 +1059,14 @@ func SandboxKeyWalker(out *Sandbox, key string) SandboxWalker {
|
| 1059 | 1059 |
} |
| 1060 | 1060 |
|
| 1061 | 1061 |
func (c *controller) loadDriver(networkType string) error {
|
| 1062 |
- // Plugins pkg performs lazy loading of plugins that acts as remote drivers. |
|
| 1063 |
- // As per the design, this Get call will result in remote driver discovery if there is a corresponding plugin available. |
|
| 1064 |
- _, err := plugins.Get(networkType, driverapi.NetworkPluginEndpointType) |
|
| 1062 |
+ var err error |
|
| 1063 |
+ |
|
| 1064 |
+ if pg := c.GetPluginGetter(); pg != nil {
|
|
| 1065 |
+ _, err = pg.Get(networkType, driverapi.NetworkPluginEndpointType, plugingetter.LOOKUP) |
|
| 1066 |
+ } else {
|
|
| 1067 |
+ _, err = plugins.Get(networkType, driverapi.NetworkPluginEndpointType) |
|
| 1068 |
+ } |
|
| 1069 |
+ |
|
| 1065 | 1070 |
if err != nil {
|
| 1066 | 1071 |
if err == plugins.ErrNotFound {
|
| 1067 | 1072 |
return types.NotFoundErrorf(err.Error()) |
| ... | ... |
@@ -1073,7 +1078,15 @@ func (c *controller) loadDriver(networkType string) error {
|
| 1073 | 1073 |
} |
| 1074 | 1074 |
|
| 1075 | 1075 |
func (c *controller) loadIPAMDriver(name string) error {
|
| 1076 |
- if _, err := c.GetPluginGetter().Get(name, ipamapi.PluginEndpointType, plugingetter.LOOKUP); err != nil {
|
|
| 1076 |
+ var err error |
|
| 1077 |
+ |
|
| 1078 |
+ if pg := c.GetPluginGetter(); pg != nil {
|
|
| 1079 |
+ _, err = pg.Get(name, ipamapi.PluginEndpointType, plugingetter.LOOKUP) |
|
| 1080 |
+ } else {
|
|
| 1081 |
+ _, err = plugins.Get(name, ipamapi.PluginEndpointType) |
|
| 1082 |
+ } |
|
| 1083 |
+ |
|
| 1084 |
+ if err != nil {
|
|
| 1077 | 1085 |
if err == plugins.ErrNotFound {
|
| 1078 | 1086 |
return types.NotFoundErrorf(err.Error()) |
| 1079 | 1087 |
} |