Skip to content

Commit

Permalink
Merge pull request #44310 from thaJeztah/daemon_getPluginExecRoot
Browse files Browse the repository at this point in the history
daemon: getPluginExecRoot(): pass config
  • Loading branch information
cpuguy83 committed Oct 25, 2022
2 parents 7b1245d + 19c5d21 commit 6c5ca97
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions daemon/daemon.go
Original file line number Diff line number Diff line change
Expand Up @@ -907,13 +907,13 @@ func NewDaemon(ctx context.Context, config *config.Config, pluginStore *plugin.S
}
rt = *rtPtr
}
return pluginexec.New(ctx, getPluginExecRoot(config.Root), pluginCli, config.ContainerdPluginNamespace, m, rt)
return pluginexec.New(ctx, getPluginExecRoot(config), pluginCli, config.ContainerdPluginNamespace, m, rt)
}

// Plugin system initialization should happen before restore. Do not change order.
d.pluginManager, err = plugin.NewManager(plugin.ManagerConfig{
Root: filepath.Join(config.Root, "plugins"),
ExecRoot: getPluginExecRoot(config.Root),
ExecRoot: getPluginExecRoot(config),
Store: d.PluginStore,
CreateExecutor: createPluginExec,
RegistryService: registryService,
Expand Down
2 changes: 1 addition & 1 deletion daemon/daemon_linux.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import (
// instead of deriving path from daemon's exec-root. This is because
// plugin socket files are created here and they cannot exceed max
// path length of 108 bytes.
func getPluginExecRoot(root string) string {
func getPluginExecRoot(_ *config.Config) string {
return "/run/docker/plugins"
}

Expand Down
4 changes: 2 additions & 2 deletions daemon/daemon_windows.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,8 +55,8 @@ func adjustParallelLimit(n int, limit int) int {
}

// Windows has no concept of an execution state directory. So use config.Root here.
func getPluginExecRoot(root string) string {
return filepath.Join(root, "plugins")
func getPluginExecRoot(cfg *config.Config) string {
return filepath.Join(cfg.Root, "plugins")
}

func (daemon *Daemon) parseSecurityOpt(container *container.Container, hostConfig *containertypes.HostConfig) error {
Expand Down

0 comments on commit 6c5ca97

Please sign in to comment.