Merge pull request #44310 from thaJeztah/daemon_getPluginExecRoot

daemon: getPluginExecRoot(): pass config
This commit is contained in:
Brian Goff 2022-10-25 11:52:35 -07:00 committed by GitHub
commit 6c5ca9779b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 5 deletions

View File

@ -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,

View File

@ -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"
}

View File

@ -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 {