File backend_linux.go has 676 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package plugin // import "github.com/docker/docker/plugin"

import (
    "archive/tar"
    "bytes"

Function splitConfigRootFSFromTar has a Cognitive Complexity of 40 (exceeds 20 allowed). Consider refactoring.

Open

func splitConfigRootFSFromTar(in io.ReadCloser, config *[]byte) io.ReadCloser {
    pr, pw := io.Pipe()
    go func() {
        tarReader := tar.NewReader(in)
        tarWriter := tar.NewWriter(pw)

• Read up
  Read up

Method Manager.CreateFromContext has 90 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pm *Manager) CreateFromContext(ctx context.Context, tarCtx io.ReadCloser, options *types.PluginCreateOptions) (err error) {
    pm.muGC.RLock()
    defer pm.muGC.RUnlock()

    ref, err := reference.ParseNormalizedNamed(options.RepoName)

Method Manager.Push has 81 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pm *Manager) Push(ctx context.Context, name string, metaHeader http.Header, authConfig *registry.AuthConfig, outStream io.Writer) error {
    p, err := pm.config.Store.GetV2Plugin(name)
    if err != nil {
        return err
    }

Method Manager.Push has a Cognitive Complexity of 29 (exceeds 20 allowed). Consider refactoring.

Open

func (pm *Manager) Push(ctx context.Context, name string, metaHeader http.Header, authConfig *registry.AuthConfig, outStream io.Writer) error {
    p, err := pm.config.Store.GetV2Plugin(name)
    if err != nil {
        return err
    }

• Read up
  Read up

Method Manager.CreateFromContext has 19 return statements (exceeds 4 allowed).

Open

func (pm *Manager) CreateFromContext(ctx context.Context, tarCtx io.ReadCloser, options *types.PluginCreateOptions) (err error) {
    pm.muGC.RLock()
    defer pm.muGC.RUnlock()

    ref, err := reference.ParseNormalizedNamed(options.RepoName)

Function computePrivileges has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func computePrivileges(c types.PluginConfig) types.PluginPrivileges {
    var privileges types.PluginPrivileges
    if c.Network.Type != "null" && c.Network.Type != "bridge" && c.Network.Type != "" {
        privileges = append(privileges, types.PluginPrivilege{
            Name:        "network",

Function splitConfigRootFSFromTar has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func splitConfigRootFSFromTar(in io.ReadCloser, config *[]byte) io.ReadCloser {
    pr, pw := io.Pipe()
    go func() {
        tarReader := tar.NewReader(in)
        tarWriter := tar.NewWriter(pw)

Method Manager.Push has 11 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Push(ctx context.Context, name string, metaHeader http.Header, authConfig *registry.AuthConfig, outStream io.Writer) error {
    p, err := pm.config.Store.GetV2Plugin(name)
    if err != nil {
        return err
    }

Method Manager.Pull has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (pm *Manager) Pull(ctx context.Context, ref reference.Named, name string, metaHeader http.Header, authConfig *registry.AuthConfig, privileges types.PluginPrivileges, outStream io.Writer, opts ...CreateOpt) (err error) {

Method Manager.List has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func (pm *Manager) List(pluginFilters filters.Args) ([]types.Plugin, error) {
    if err := pluginFilters.Validate(acceptedPluginFilterTags); err != nil {
        return nil, err
    }

• Read up
  Read up

Method Manager.Privileges has 9 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Privileges(ctx context.Context, ref reference.Named, metaHeader http.Header, authConfig *registry.AuthConfig) (types.PluginPrivileges, error) {
    var (
        config     types.PluginConfig
        configSeen bool
    )

Method Manager.Upgrade has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (pm *Manager) Upgrade(ctx context.Context, ref reference.Named, name string, metaHeader http.Header, authConfig *registry.AuthConfig, privileges types.PluginPrivileges, outStream io.Writer) (err error) {

Method Manager.Upgrade has 8 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Upgrade(ctx context.Context, ref reference.Named, name string, metaHeader http.Header, authConfig *registry.AuthConfig, privileges types.PluginPrivileges, outStream io.Writer) (err error) {
    p, err := pm.config.Store.GetV2Plugin(name)
    if err != nil {
        return err
    }

Method Manager.Pull has 7 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Pull(ctx context.Context, ref reference.Named, name string, metaHeader http.Header, authConfig *registry.AuthConfig, privileges types.PluginPrivileges, outStream io.Writer, opts ...CreateOpt) (err error) {
    pm.muGC.RLock()
    defer pm.muGC.RUnlock()

    // revalidate because Pull is public

Function splitConfigRootFSFromTar has 7 return statements (exceeds 4 allowed).

Open

func splitConfigRootFSFromTar(in io.ReadCloser, config *[]byte) io.ReadCloser {
    pr, pw := io.Pipe()
    go func() {
        tarReader := tar.NewReader(in)
        tarWriter := tar.NewWriter(pw)

Method Manager.Remove has 6 return statements (exceeds 4 allowed).

Open

func (pm *Manager) Remove(name string, config *backend.PluginRmConfig) error {
    p, err := pm.config.Store.GetV2Plugin(name)
    pm.mu.RLock()
    c := pm.cMap[p]
    pm.mu.RUnlock()

Method Manager.Push has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (pm *Manager) Push(ctx context.Context, name string, metaHeader http.Header, authConfig *registry.AuthConfig, outStream io.Writer) error {

Function atomicRemoveAll has 5 return statements (exceeds 4 allowed).

Open

func atomicRemoveAll(dir string) error {
    renamed := dir + "-removing"

    err := os.Rename(dir, renamed)
    switch {