Method setupNewPlugin

daemon/pkg/plugin/manager_linux.go:270–296

(configDigest digest.Digest, privileges *plugin.Privileges)

}

func (pm *Manager) setupNewPlugin(configDigest digest.Digest, privileges *plugin.Privileges) (plugin.Config, error) {
	configRA, err := pm.blobStore.ReaderAt(context.TODO(), ocispec.Descriptor{Digest: configDigest})
	if err != nil {
		return plugin.Config{}, err
	}
	defer configRA.Close()

	configR := content.NewReader(configRA)

	var config plugin.Config
	dec := json.NewDecoder(configR)
	if err := dec.Decode(&config); err != nil {
		return plugin.Config{}, errors.Wrapf(err, "failed to parse config")
	}
	if dec.More() {
		return plugin.Config{}, errors.New("invalid config json")
	}

	requiredPrivileges := computePrivileges(config)
	if privileges != nil {
		if err := validatePrivileges(requiredPrivileges, *privileges); err != nil {
			return plugin.Config{}, err
		}
	}

	return config, nil
}

// createPlugin creates a new plugin. take lock before calling.
func (pm *Manager) createPlugin(name string, configDigest, manifestDigest digest.Digest, blobsums []digest.Digest, rootFSDir string, privileges *plugin.Privileges, opts ...CreateOpt) (_ *v2.Plugin, retErr error) {