Method pushDescriptor.Upload has 112 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pd *pushDescriptor) Upload(ctx context.Context, progressOutput progress.Output) (distribution.Descriptor, error) {
    // Skip foreign layers unless this registry allows nondistributable artifacts.
    if !pd.endpoint.AllowNondistributableArtifacts {
        if fs, ok := pd.layer.(distribution.Describable); ok {
            if d := fs.Descriptor(); len(d.URLs) > 0 {

Method Cluster.ServiceLogs has 112 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Cluster) ServiceLogs(ctx context.Context, selector *backend.LogSelector, config *container.LogsOptions) (<-chan *backend.LogMessage, error) {
    c.mu.RLock()
    defer c.mu.RUnlock()

    state := c.currentNodeState()

Function DirCopy has 112 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func DirCopy(srcDir, dstDir string, copyMode Mode, copyOpaqueXattrs bool) error {
    copyWithFileRange := true
    copyWithFileClone := true

    // This is a map of source file inodes to dst file paths

Function WithNamespaces has 111 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func WithNamespaces(daemon *Daemon, c *container.Container) coci.SpecOpts {
    return func(ctx context.Context, _ coci.Client, _ *containers.Container, s *coci.Spec) error {
        userNS := false
        // user
        if c.HostConfig.UsernsMode.IsPrivate() {

Function compare has 39 return statements (exceeds 4 allowed).

Open

func compare(a, b *container.Config) bool {
    if a == nil || b == nil {
        return false
    }

Method cnmNetworkAllocator.AllocateService has a Cognitive Complexity of 39 (exceeds 20 allowed). Consider refactoring.

Open

func (na *cnmNetworkAllocator) AllocateService(s *api.Service) (err error) {
    defer func() {
        if err != nil {
            na.DeallocateService(s)
        }

• Read up
  Read up

Method client.newStdioPipes has a Cognitive Complexity of 39 (exceeds 20 allowed). Consider refactoring.

Open

func (c *client) newStdioPipes(fifos *cio.FIFOSet) (_ *stdioPipes, err error) {
    p := &stdioPipes{}
    if fifos.Stdin != "" {
        c.logger.WithField("stdin", fifos.Stdin).Debug("listen")
        l, err := winio.ListenPipe(fifos.Stdin, nil)

• Read up
  Read up

Method controller.Start has a Cognitive Complexity of 39 (exceeds 20 allowed). Consider refactoring.

Open

func (r *controller) Start(ctx context.Context) error {
    if err := r.checkClosed(); err != nil {
        return err
    }

• Read up
  Read up

Method Daemon.ContainerExecStart has a Cognitive Complexity of 39 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) ContainerExecStart(ctx context.Context, name string, options backend.ExecStartConfig) (err error) {
    var (
        cStdin           io.ReadCloser
        cStdout, cStderr io.Writer
    )

• Read up
  Read up

Method Daemon.createNetwork has a Cognitive Complexity of 39 (exceeds 20 allowed). Consider refactoring.

Open

func (daemon *Daemon) createNetwork(cfg *config.Config, create networktypes.CreateRequest, id string, agent bool) (*networktypes.CreateResponse, error) {
    if network.IsPredefined(create.Name) {
        return nil, PredefinedNetworkError(create.Name)
    }

• Read up
  Read up

File splunk.go has 558 lines of code (exceeds 500 allowed). Consider refactoring.

Open

// Package splunk provides the log driver for forwarding server logs to
// Splunk HTTP Event Collector endpoint.
package splunk // import "github.com/docker/docker/daemon/logger/splunk"

import (

Method driver.Join has 109 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.ipvlan.Join", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid),
        attribute.String("sboxKey", sboxKey)))

Method ImageService.ImageDelete has 109 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) ImageDelete(ctx context.Context, imageRef string, force, prune bool) (response []imagetypes.DeleteResponse, retErr error) {
    start := time.Now()
    defer func() {
        if retErr == nil {
            dimages.ImageActions.WithValues("delete").UpdateSince(start)

Sandbox has 28 methods (exceeds 20 allowed). Consider refactoring.

Open

func (sb *Sandbox) processOptions(options ...SandboxOption) {
    for _, opt := range options {
        if opt != nil {
            opt(sb)
        }

File push_v2.go has 555 lines of code (exceeds 500 allowed). Consider refactoring.

Open

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

import (
    "context"
    "fmt"

Method ImageService.ImportImage has 108 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (i *ImageService) ImportImage(ctx context.Context, ref reference.Named, platform *ocispec.Platform, msg string, layerReader io.Reader, changes []string) (image.ID, error) {
    refString := ""
    if ref != nil {
        refString = ref.String()
    }

Method Sandbox.populateNetworkResources has a Cognitive Complexity of 38 (exceeds 20 allowed). Consider refactoring.

Open

func (sb *Sandbox) populateNetworkResources(ctx context.Context, ep *Endpoint) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.Sandbox.populateNetworkResources", trace.WithAttributes(
        attribute.String("endpoint.Name", ep.Name())))
    defer span.End()

• Read up
  Read up

Function Go has a Cognitive Complexity of 38 (exceeds 20 allowed). Consider refactoring.

Open

func Go(flags int, setupfn func() error, fn func()) error {
    started := make(chan error)

    maskedFlags := flags
    for f := range reversibleSetnsFlags {

• Read up
  Read up

Method driver.Join has a Cognitive Complexity of 38 (exceeds 20 allowed). Consider refactoring.

Open

func (d *driver) Join(ctx context.Context, nid, eid string, sboxKey string, jinfo driverapi.JoinInfo, options map[string]interface{}) error {
    ctx, span := otel.Tracer("").Start(ctx, "libnetwork.drivers.macvlan.Join", trace.WithAttributes(
        attribute.String("nid", nid),
        attribute.String("eid", eid),
        attribute.String("sboxKey", sboxKey)))

• Read up
  Read up

Method PluginSpec.Unmarshal has 37 return statements (exceeds 4 allowed).

Open

func (m *PluginSpec) Unmarshal(dAtA []byte) error {
    l := len(dAtA)
    iNdEx := 0
    for iNdEx < l {
        preIndex := iNdEx